[Improve] Fix a typo of YarnApplicationClient.

joyCurry30 · Jun 24, 2024 · d21d726 · d21d726
1 parent 65f20f5
commit d21d726
Showing 1 changed file with 2 additions and 2 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
@@ -141,10 +141,10 @@ object YarnApplicationClient extends YarnClientTrait {
       flinkConfig: Configuration): SubmitResponse = {
     var proxyUserUgi: UserGroupInformation = UserGroupInformation.getCurrentUser
     val currentUser = UserGroupInformation.getCurrentUser
-    val eableProxyState =
+    val enableProxyState =
       !HadoopUtils.isKerberosSecurityEnabled(currentUser) && StringUtils.isNotEmpty(
         submitRequest.hadoopUser)
-    if (eableProxyState) {
+    if (enableProxyState) {
       proxyUserUgi = UserGroupInformation.createProxyUser(
         submitRequest.hadoopUser,
         currentUser