[incubator-streampark] branch dev updated: YarnUtils Deprecated method optimization (#2866)

[be...@apache.org]

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 3d63e4fc0 YarnUtils Deprecated method optimization (#2866)
3d63e4fc0 is described below

commit 3d63e4fc0960edea038b765fac8d43e7db2e5e7d
Author: ChengJie1053 <18...@163.com>
AuthorDate: Thu Jul 20 13:26:35 2023 +0800

    YarnUtils Deprecated method optimization (#2866)
---
 .../src/main/scala/org/apache/streampark/common/util/YarnUtils.scala  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 2c58dda15..6030cebb2 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
@@ -24,7 +24,7 @@ import org.apache.hadoop.net.NetUtils
 import org.apache.hadoop.yarn.api.records._
 import org.apache.hadoop.yarn.api.records.YarnApplicationState._
 import org.apache.hadoop.yarn.conf.{HAUtil, YarnConfiguration}
-import org.apache.hadoop.yarn.util.{ConverterUtils, RMHAUtils}
+import org.apache.hadoop.yarn.util.RMHAUtils
 import org.apache.hc.client5.http.config.RequestConfig
 
 import java.net.InetAddress
@@ -87,7 +87,7 @@ object YarnUtils extends Logger {
    * @return
    */
   def getState(appId: String): YarnApplicationState = {
-    val applicationId = ConverterUtils.toApplicationId(appId)
+    val applicationId = ApplicationId.fromString(appId)
     val state =
       try {
         val applicationReport = HadoopUtils.yarnClient.getApplicationReport(applicationId)