From 9154d9b7b5d027762018e487ebdeac136b284e8d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=8F=E6=B8=85?=
 <62982788+597365581@users.noreply.github.com>
Date: Mon, 22 Feb 2021 15:18:43 +0800
Subject: [PATCH] Update AbstractCommandExecutor.java

---
 .../server/worker/task/AbstractCommandExecutor.java        | 7 ++++++-
 1 file changed, 6 insertions(+), 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 2ef9884e6d..949df4177a 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
@@ -347,7 +347,12 @@ public abstract class AbstractCommandExecutor {
                 String line;
                 logBuffer.add("welcome to use bigdata scheduling system...");
                 while ((line = inReader.readLine()) != null) {
-                    logBuffer.add(line);
+                    if (line.startsWith("${setValue(")) {
+                        varPool.append(line.substring("${setValue(".length(), line.length() - 2));
+                        varPool.append("$VarPool$");
+                    } else {
+                        logBuffer.add(line);
+                    }
                 }
             } catch (Exception e) {
                 logger.error(e.getMessage(), e);