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 index 1990d5731c..fdbd834399 100644 --- 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 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();