diff --git a/zlt-job/job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java b/zlt-job/job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java index ff89001ab90c75b896e0c06d0cf20f7fd7e5d62e..e86bc7b90ced41693f12285b0a1c73d17c29d5cb 100644 --- a/zlt-job/job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java +++ b/zlt-job/job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java @@ -200,14 +200,12 @@ public class XxlJobFileAppender { BufferedReader reader = null; try { reader = new BufferedReader(new InputStreamReader(new FileInputStream(logFile), "utf-8")); - if (reader != null) { - StringBuilder sb = new StringBuilder(); - String line = null; - while ((line = reader.readLine()) != null) { - sb.append(line).append("\n"); - } - return sb.toString(); + StringBuilder sb = new StringBuilder(); + String line = null; + while ((line = reader.readLine()) != null) { + sb.append(line).append("\n"); } + return sb.toString(); } catch (IOException e) { logger.error(e.getMessage(), e); } finally { diff --git a/zlt-job/job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java b/zlt-job/job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java index 9fba156d593432a6f3850d0e45a129dfaa4e351b..225a9e91d10b31b771f2772a0f098ecbd343dd77 100644 --- a/zlt-job/job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java +++ b/zlt-job/job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java @@ -215,7 +215,7 @@ public class TriggerCallbackThread { } // retry callback, 100 lines per page - if (failCallbackParamList!=null && failCallbackParamList.size()>0) { + if (failCallbackParamList.size()>0) { int pagesize = 100; List pageData = new ArrayList<>(); for (int i = 0; i < failCallbackParamList.size(); i++) {