streamis-job-launcher-base - refactor YarnAppVo

WeDataSphere · Jun 20, 2023 · 1d08d39 · 1d08d39
1 parent 4bc3fc2
commit 1d08d39
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/...c/main/java/com/webank/wedatasphere/streamis/jobmanager/launcher/entity/vo/YarnAppVo.java b/...c/main/java/com/webank/wedatasphere/streamis/jobmanager/launcher/entity/vo/YarnAppVo.java
@@ -12,7 +12,7 @@ public class YarnAppVo {
 
     private String applicationState;
 
-    private String appicationName;
+    private String applicationName;
 
     private String yarnAppType;
 
@@ -48,12 +48,12 @@ public void setApplicationState(String applicationState) {
         this.applicationState = applicationState;
     }
 
-    public String getAppicationName() {
-        return appicationName;
+    public String getApplicationName() {
+        return applicationName;
     }
 
-    public void setAppicationName(String appicationName) {
-        this.appicationName = appicationName;
+    public void setApplicationName(String applicationName) {
+        this.applicationName = applicationName;
     }
 
     public String getYarnAppType() {

diff --git a/...tasphere/streamis/jobmanager/launcher/linkis/job/client/LinkisFlinkManagerJobClient.scala b/...tasphere/streamis/jobmanager/launcher/linkis/job/client/LinkisFlinkManagerJobClient.scala
@@ -202,7 +202,7 @@ object LinkisFlinkManagerJobClient extends Logging {
         val rsList = JsonUtils.jackson.readValue(rsListStr, classOf[util.List[util.Map[String, String]]])
         rsList.asScala.foreach(map => {
           val tmpVo = new YarnAppVo()
-          tmpVo.setAppicationName(map.getOrDefault(ECConstants.YARN_APP_NAME_KEY, null))
+          tmpVo.setApplicationName(map.getOrDefault(ECConstants.YARN_APP_NAME_KEY, null))
           tmpVo.setApplicationState(map.getOrDefault(ECConstants.NODE_STATUS_KEY, null))
           tmpVo.setYarnAppType(map.getOrDefault(ECConstants.YARN_APP_TYPE_KEY, null))
           tmpVo.setApplicationId(map.getOrDefault(ECConstants.YARN_APPID_NAME_KEY, null))