From 35f32cd16eb7d89a900863755506858e84c699dd Mon Sep 17 00:00:00 2001 From: xuhhui Date: Wed, 20 Jul 2022 11:06:10 +0800 Subject: [PATCH] [Improvement][Task]Improve seatunnel task command log (#11027) --- .../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; }