From 8824b5bab2120c451e30736f15279bf0ec1b0b79 Mon Sep 17 00:00:00 2001 From: EricGao888 Date: Fri, 10 May 2024 14:05:13 +0800 Subject: [PATCH] change args splitter --- .../task/aliyunserverlessspark/AliyunServerlessSparkTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java index 4f413808a6..897ea29bc3 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java @@ -185,7 +185,7 @@ public class AliyunServerlessSparkTask extends AbstractRemoteTask { workflowTag.setValue("true"); startJobRunRequest.setTags(Arrays.asList(envTag, workflowTag)); List entryPointArguments = StringUtils.isEmpty(aliyunServerlessSparkParameters.getEntryPointArguments()) ? - Collections.emptyList() : Arrays.asList(aliyunServerlessSparkParameters.getEntryPointArguments().split(";")); + Collections.emptyList() : Arrays.asList(aliyunServerlessSparkParameters.getEntryPointArguments().split("#")); JobDriver.JobDriverSparkSubmit jobDriverSparkSubmit = new JobDriver.JobDriverSparkSubmit() .setEntryPoint(aliyunServerlessSparkParameters.getEntryPoint()) .setEntryPointArguments(entryPointArguments)