diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala index 86d8a640ce..db0c3db717 100644 --- a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala +++ b/streampark-flink/streampark-flink-client/streampark-flink-client-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)