From a0fa17a4f80870fdffcb2fbac16e671681497aa2 Mon Sep 17 00:00:00 2001 From: benjobs Date: Thu, 26 Oct 2023 16:48:41 +0800 Subject: [PATCH] minor improvement --- .../flink/client/trait/FlinkClientTrait.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala index bed7ed552a..bfcf682dcf 100644 --- a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala +++ b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala @@ -403,18 +403,18 @@ trait FlinkClientTrait extends Logger { programArgs ++= PropertiesUtils.extractArguments(submitRequest.args) if (submitRequest.applicationType == ApplicationType.STREAMPARK_FLINK) { - programArgs ++ PARAM_KEY_FLINK_CONF += submitRequest.flinkYaml - programArgs ++ PARAM_KEY_APP_NAME += DeflaterUtils.zipString(submitRequest.effectiveAppName) - programArgs ++ PARAM_KEY_FLINK_PARALLELISM += getParallelism(submitRequest).toString + programArgs += PARAM_KEY_FLINK_CONF += submitRequest.flinkYaml + programArgs += PARAM_KEY_APP_NAME += DeflaterUtils.zipString(submitRequest.effectiveAppName) + programArgs += PARAM_KEY_FLINK_PARALLELISM += getParallelism(submitRequest).toString submitRequest.developmentMode match { case DevelopmentMode.FLINK_SQL => - programArgs ++ PARAM_KEY_FLINK_SQL += submitRequest.flinkSQL + programArgs += PARAM_KEY_FLINK_SQL += submitRequest.flinkSQL if (submitRequest.appConf != null) { - programArgs ++ PARAM_KEY_APP_CONF += submitRequest.appConf + programArgs += PARAM_KEY_APP_CONF += submitRequest.appConf } case _ if Try(!submitRequest.appConf.startsWith("json:")).getOrElse(true) => - programArgs ++ PARAM_KEY_APP_CONF += submitRequest.appConf + programArgs += PARAM_KEY_APP_CONF += submitRequest.appConf } }