diff --git a/deploy/helm/streampark/conf/streampark-console-config/application.yml b/deploy/helm/streampark/conf/streampark-console-config/application.yml index f947a85db7..66a92ec7a6 100755 --- a/deploy/helm/streampark/conf/streampark-console-config/application.yml +++ b/deploy/helm/streampark/conf/streampark-console-config/application.yml @@ -92,8 +92,8 @@ streampark: # lark alert proxy,default https://open.feishu.cn lark-url: yarn: - # default sample, or kerberos - http-auth: sample + # default simple, or kerberos + http-auth: simple # HADOOP_USER_NAME hadoop-user-name: hdfs diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala b/streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala index e9178bc19e..449b0c2dd8 100644 --- a/streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala +++ b/streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala @@ -45,7 +45,7 @@ object CommonConfig { key = "streampark.yarn.http-auth", defaultValue = "", classType = classOf[String], - description = "yarn http auth type. ex: sample, kerberos") + description = "yarn http auth type. ex: simple, kerberos") val DOCKER_HOST: InternalOption = InternalOption( key = "streampark.docker.http-client.docker-host", diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala index 2839bcc5e2..f0464cfc3c 100644 --- a/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala +++ b/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala @@ -47,7 +47,7 @@ object YarnUtils extends Logger { lazy val PROXY_YARN_URL = InternalConfigHolder.get[String](CommonConfig.STREAMPARK_PROXY_YARN_URL) /** - * hadoop.http.authentication.type
get yarn http authentication mode.
ex: sample, kerberos + * hadoop.http.authentication.type
get yarn http authentication mode.
ex: simple, kerberos * * @return */ @@ -56,9 +56,9 @@ object YarnUtils extends Logger { "kerberos".equalsIgnoreCase(yarnHttpAuth) } - lazy val hasYarnHttpSampleAuth: Boolean = { + lazy val hasYarnHttpSimpleAuth: Boolean = { val yarnHttpAuth: String = InternalConfigHolder.get[String](CommonConfig.STREAMPARK_YARN_AUTH) - "sample".equalsIgnoreCase(yarnHttpAuth) + "simple".equalsIgnoreCase(yarnHttpAuth) } /** @@ -289,7 +289,7 @@ object YarnUtils extends Logger { }) } else { val url = - if (!hasYarnHttpSampleAuth) reqUrl + if (!hasYarnHttpSimpleAuth) reqUrl else { s"$reqUrl?user.name=${HadoopUtils.hadoopUserName}" } diff --git a/streampark-console/streampark-console-service/src/main/resources/application.yml b/streampark-console/streampark-console-service/src/main/resources/application.yml index f6f56807fb..60618778cc 100644 --- a/streampark-console/streampark-console-service/src/main/resources/application.yml +++ b/streampark-console/streampark-console-service/src/main/resources/application.yml @@ -77,8 +77,8 @@ streampark: # lark alert proxy,default https://open.feishu.cn lark-url: yarn: - # default sample, or kerberos - http-auth: sample + # default simple, or kerberos + http-auth: simple # HADOOP_USER_NAME hadoop-user-name: hdfs