You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/06/24 11:46:09 UTC

(incubator-streampark) branch dev updated: [Improve] Fix a typo of YarnApplicationClient. (#3801)

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new b94212bed [Improve] Fix a typo of YarnApplicationClient. (#3801)
b94212bed is described below

commit b94212bed5062745567465312fc6faf852f3b529
Author: joyCurry30 <14...@users.noreply.github.com>
AuthorDate: Mon Jun 24 19:46:04 2024 +0800

    [Improve] Fix a typo of YarnApplicationClient. (#3801)
---
 .../apache/streampark/flink/client/impl/YarnApplicationClient.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
index 01471cff2..5223d7d0d 100644
--- a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
+++ b/streampark-flink/streampark-flink-client/streampark-flink-client-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