From 0b602bcaf4b8acdf7dca1d1ad00e5b2d73d62b69 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E6=B8=85?= <62982788+597365581@users.noreply.github.com> Date: Fri, 29 Jan 2021 10:20:49 +0800 Subject: [PATCH] Update AbstractCommandExecutor.java --- .../server/worker/task/AbstractCommandExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git 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 index 2235ef731b..c63af2cb61 100644 --- 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$");