Update AbstractCommandExecutor.java

4 years ago · 0b602bcaf4
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
@ -348,7 +348,7 @@ public abstract class AbstractCommandExecutor {
                    long lastFlushTime = System.currentTimeMillis();
-                    while ((line = inReader.readLine()) != null || logBuffer.size()>0) {
+                    while ((line = inReader.readLine()) != null || logBuffer.size() > 0) {
                        if (line.startsWith("${setValue(")) {
                            varPool.append(line.substring("${setValue(".length(), line.length() - 2));
                            varPool.append("$VarPool$");