diff options
| author | LAPTOP-CUUVN8AS\wk <[email protected]> | 2022-06-23 16:36:53 +0800 |
|---|---|---|
| committer | LAPTOP-CUUVN8AS\wk <[email protected]> | 2022-06-23 16:36:53 +0800 |
| commit | f096d86247c3f85d30c9da1a4585f8b2eb0f43c9 (patch) | |
| tree | f6cce3ff36f5b4dfe1991ee8948083433539048e | |
| parent | 9828f4a7cc3cdf8aacad441aacb3d65c857da424 (diff) | |
schema部分校验的日志级别改为warn
| -rw-r--r-- | galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/LogStorageTtlJob.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/LogStorageTtlJob.java b/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/LogStorageTtlJob.java index d6dfc79..267b898 100644 --- a/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/LogStorageTtlJob.java +++ b/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/LogStorageTtlJob.java @@ -235,11 +235,11 @@ public class LogStorageTtlJob { } } else { - logger.error("table " + tablename + " schema not containsKey partition_key or ttl error "); + logger.warn("table " + tablename + " schema not containsKey partition_key or ttl error "); XxlJobLogger.log("table " + tablename + " schema not containsKey partition_key or ttl error "); } } else { - logger.error("table " + tablename + " schema not containsKey doc error "); + logger.warn("table " + tablename + " schema not containsKey doc error "); XxlJobLogger.log("table " + tablename + " schema not containsKey doc error "); } @@ -354,13 +354,13 @@ public class LogStorageTtlJob { schemaColumnMessageList = JsonPath.using(conf2).parse(content).read(schema, List.class); } else { - logger.error("table " + tablename + " schema not containsKey partition_key error "); + logger.warn("table " + tablename + " schema not containsKey partition_key error "); XxlJobLogger.log("table " + tablename + " schema not containsKey partition_key error "); return null; } }else { - logger.error("table " + tablename + " schema not containsKey doc error "); + logger.warn("table " + tablename + " schema not containsKey doc error "); XxlJobLogger.log("table " + tablename + " schema not containsKey doc error "); return null; } |