[Improve] pyflink improvement

apache · Sep 2, 2023 · aa0eff2 · aa0eff2
1 parent 7db201d
commit aa0eff2
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...t-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala b/...t-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
@@ -36,6 +36,7 @@ import org.apache.flink.yarn.configuration.YarnConfigOptions
 import org.apache.hadoop.security.UserGroupInformation
 import org.apache.hadoop.yarn.api.records.ApplicationId
 
+import java.util
 import java.util.Collections
 
 import scala.collection.JavaConverters._
@@ -101,10 +102,11 @@ object YarnApplicationClient extends YarnClientTrait {
       }
 
       // yarn.ship-files
+      val shipFiles = new util.ArrayList[String]()
+      shipFiles.add(submitRequest.userJarFile.getParentFile.getAbsolutePath)
+
       flinkConfig
-        .safeSet(
-          YarnConfigOptions.SHIP_FILES,
-          submitRequest.userJarFile.getParentFile.getAbsolutePath)
+        .safeSet(YarnConfigOptions.SHIP_FILES, shipFiles)
         // python.files
         .safeSet(PythonOptions.PYTHON_FILES, submitRequest.userJarFile.getParentFile.getName)