Update AbstractCommandExecutor.java

4 years ago · 7ec5c94dfe
1 changed files with 1 additions and 1 deletions
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java
@ -353,7 +353,7 @@ public abstract class AbstractCommandExecutor {
                            varPool.append(line.substring("${setValue(".length(), line.length() - 2));
                            varPool.append("$VarPool$");
                        } else {
-                            if(null != line){
+                            if (null != line) {
                            logBuffer.add(line);
                            }
                            lastFlushTime = flush(lastFlushTime);