补充 fix #393

570eeb1c · DESKTOP-BKQSEII\Calvin · 4c8d9896 · 570eeb1c
Commit 570eeb1c authored Apr 16, 2022 by $DESKTOP-BKQSEII\Calvin's avatar$ DESKTOP-BKQSEII\Calvin
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 0 deletions

FlinkAPI.java dlink-core/src/main/java/com/dlink/api/FlinkAPI.java +2 -0

No files found.
--- a/dlink-core/src/main/java/com/dlink/api/FlinkAPI.java
+++ b/dlink-core/src/main/java/com/dlink/api/FlinkAPI.java
@@ -97,6 +97,8 @@ public class FlinkAPI {
        Map<String, Object> paramMap = new HashMap<>();
        switch (type) {
            case CANCEL:
+                paramMap.put("cancel-job", true);
+                paramType = FlinkRestAPIConstant.SAVEPOINTS;
                jobInfo.setStatus(JobInfo.JobStatus.CANCEL);
                break;
            case STOP: