This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 35f32cd16e [Improvement][Task]Improve seatunnel task command log
(#11027)
35f32cd16e is described below
commit 35f32cd16eb7d89a900863755506858e84c699dd
Author: xuhhui <[email protected]>
AuthorDate: Wed Jul 20 11:06:10 2022 +0800
[Improvement][Task]Improve seatunnel task command log (#11027)
---
.../apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
index ffec399565..a077aa1c7c 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
@@ -29,7 +29,6 @@ import
org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParameters
import org.apache.dolphinscheduler.plugin.task.api.parser.ParamUtils;
import org.apache.dolphinscheduler.plugin.task.api.parser.ParameterUtils;
-import org.apache.commons.collections4.MapUtils;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.BooleanUtils;
@@ -39,7 +38,6 @@ import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.ArrayList;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -115,7 +113,7 @@ public class SeatunnelTask extends AbstractTaskExecutor {
args.addAll(buildOptions());
String command = String.join(" ", args);
- logger.info("SeaTunnel Flink task command: {}", command);
+ logger.info("SeaTunnel task command: {}", command);
return command;
}