[Optimize]Optimize flink application mode status refresh (#3853)

Co-authored-by: liujian <[email protected]>
DataLinkDC · Sep 30, 2024 · 54ef08a · 54ef08a
1 parent 83878f4
commit 54ef08a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dinky-admin/src/main/java/org/dinky/job/handler/JobRefreshHandler.java b/dinky-admin/src/main/java/org/dinky/job/handler/JobRefreshHandler.java
@@ -300,7 +300,8 @@ private static Optional<JobStatus> getJobStatus(JobInfoDetail jobInfoDetail) {
         ClusterConfigurationDTO clusterCfg = jobInfoDetail.getClusterConfiguration();
         ClusterInstance clusterInstance = jobInfoDetail.getClusterInstance();
         if (!Asserts.isNull(clusterCfg)
-                && GatewayType.YARN_PER_JOB.getLongValue().equals(clusterInstance.getType())) {
+                && (GatewayType.YARN_PER_JOB.getLongValue().equals(clusterInstance.getType())
+                        || GatewayType.YARN_APPLICATION.getLongValue().equals(clusterInstance.getType()))) {
             try {
                 String appId = jobInfoDetail.getClusterInstance().getName();