[Improve] delete job improvement (#2297)

apache · Feb 5, 2023 · f144237 · f144237
1 parent 5c0dca9
commit f144237
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git a/...ark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java b/...ark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java
@@ -30,5 +30,4 @@ public class Constant {
   public static final String TYPE_MENU = "0";
   public static final String APP_MENU_ID = "100015";
   public static final String APP_DETAIL_MENU_ID = "100018";
-  public static final Long FLINK_SAMPLE_APP_ID = 100000L;
 }
diff --git a/...src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java b/...src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -34,7 +34,6 @@
 import org.apache.streampark.common.util.ThreadUtils;
 import org.apache.streampark.common.util.Utils;
 import org.apache.streampark.common.util.YarnUtils;
-import org.apache.streampark.console.base.domain.Constant;
 import org.apache.streampark.console.base.domain.RestRequest;
 import org.apache.streampark.console.base.exception.ApiAlertException;
 import org.apache.streampark.console.base.exception.ApiDetailException;
@@ -459,12 +458,6 @@ private void removeApp(Application application) {
       application
           .getFsOperator()
           .delete(application.getWorkspace().APP_WORKSPACE().concat("/").concat(appId.toString()));
-    } catch (Exception e) {
-      if (!application.getId().equals(Constant.FLINK_SAMPLE_APP_ID)) {
-        throw e;
-      }
-    }
-    try {
       // try to delete yarn-application, and leave no trouble.
       String path =
           Workspace.of(StorageType.HDFS).APP_WORKSPACE().concat("/").concat(appId.toString());