Update YarnSessionClient.scala

apache · Sep 14, 2024 · f6879bf · f6879bf
1 parent b5f9fc1
commit f6879bf
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...lient-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala b/...lient-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
@@ -138,10 +138,7 @@ object YarnSessionClient extends YarnClientTrait {
     var client: ClusterClient[ApplicationId] = null
     try {
       val flinkConfig =
-        extractConfiguration(
-          deployRequest.flinkVersion.flinkHome,
-          deployRequest.properties,
-          deployRequest.clusterName)
+        extractConfiguration(deployRequest.flinkVersion.flinkHome, deployRequest.properties)
 
       deployClusterConfig(deployRequest, flinkConfig)