diff options
author | Luck <git@lucko.me> | 2024-10-26 11:08:49 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2024-10-26 11:08:49 +0100 |
commit | ef507b147a8a0c7d209b62303de50fb895851c82 (patch) | |
tree | 5598bacf0dd887914921c0186cc0c3d48df7ab1d /spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java | |
parent | c58ddcfc37971178087d7637979a2c17e9a44d09 (diff) | |
download | spark-ef507b147a8a0c7d209b62303de50fb895851c82.tar.gz spark-ef507b147a8a0c7d209b62303de50fb895851c82.tar.bz2 spark-ef507b147a8a0c7d209b62303de50fb895851c82.zip |
Improve error logging in various places
Diffstat (limited to 'spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java')
-rw-r--r-- | spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java b/spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java index f31963d..88bbf1d 100644 --- a/spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java +++ b/spark-velocity/src/main/java/me/lucko/spark/velocity/VelocitySparkPlugin.java @@ -122,14 +122,23 @@ public class VelocitySparkPlugin implements SparkPlugin, SimpleCommand { @Override public void log(Level level, String msg) { - if (level == Level.INFO) { - this.logger.info(msg); - } else if (level == Level.WARNING) { - this.logger.warn(msg); - } else if (level == Level.SEVERE) { + if (level.intValue() >= 1000) { // severe this.logger.error(msg); + } else if (level.intValue() >= 900) { // warning + this.logger.warn(msg); + } else { + this.logger.info(msg); + } + } + + @Override + public void log(Level level, String msg, Throwable throwable) { + if (level.intValue() >= 1000) { // severe + this.logger.error(msg, throwable); + } else if (level.intValue() >= 900) { // warning + this.logger.warn(msg, throwable); } else { - throw new IllegalArgumentException(level.getName()); + this.logger.info(msg, throwable); } } |