fix #393

dlink-admin/src/main/java/com/dlink/service/impl/TaskServiceImpl.java

@@ -463,7 +463,7 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen
             return jobManager.cancel(jobId);
         }
         SavePointResult savePointResult = jobManager.savepoint(jobId, savePointType, null);
-        if (Asserts.isNotNull(savePointResult)) {
+        if (Asserts.isNotNull(savePointResult.getJobInfos())) {
             for (JobInfo item : savePointResult.getJobInfos()) {
                 if (Asserts.isEqualsIgnoreCase(jobId, item.getJobId()) && Asserts.isNotNull(jobConfig.getTaskId())) {
                     Savepoints savepoints = new Savepoints();

dlink-core/src/main/java/com/dlink/api/FlinkAPI.java

@@ -98,6 +98,7 @@ public class FlinkAPI {
         switch (type) {
             case CANCEL:
                 jobInfo.setStatus(JobInfo.JobStatus.CANCEL);
+                break;
             case STOP:
                 paramMap.put("drain", false);
                 paramType = FlinkRestAPIConstant.STOP;
@@ -127,7 +128,7 @@ public class FlinkAPI {
                     continue;
                 }
                 if (node.get("operation").has("failure-cause")) {
-                    String failureCause = node.get("operation").get("failure-cause").asText();
+                    String failureCause = node.get("operation").get("failure-cause").toString();
                     if (Asserts.isNotNullString(failureCause)) {
                         result.fail(failureCause);
                         break;