| commit | f144237f56326dbe3635150958a238d9385c39a5 | [log] [tgz] |
|---|---|---|
| author | benjobs <benjobs@apache.org> | Sun Feb 05 13:00:04 2023 +0800 |
| committer | GitHub <noreply@github.com> | Sun Feb 05 13:00:04 2023 +0800 |
| tree | d003733553c384eab26913afa3c047f8fc35a7b8 | |
| parent | 5c0dca9f8920b29b5a1f0cdaf2d57f529ada5b09 [diff] |
[Improve] delete job improvement (#2297)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java index 09d37ae..f1d7f6b 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java
@@ -30,5 +30,4 @@ 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/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java index cc9d04b..f553e72 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java +++ b/streampark-console/streampark-console-service/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 @@ 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());