[Fix-596][admin] NPE on running yarn per-job app

dlink-admin/src/main/java/com/dlink/model/Task.java

@@ -108,8 +108,11 @@ public class Task extends SuperEntity {
                 map.put(item.get("key"), item.get("value"));
             }
         }
-        return new JobConfig(type, step, false, false, useRemote, clusterId, clusterConfigurationId, jarId, getId(),
-            alias, fragment, statementSet, batchModel, checkPoint, parallelism, savePointStrategy, savePointPath, map);
+        int jid = Asserts.isNull(jarId) ? 0 : jarId;
+        boolean fg = Asserts.isNull(fragment) ? false : fragment;
+        boolean sts = Asserts.isNull(statementSet) ? false : statementSet;
+        return new JobConfig(type, step, false, false, useRemote, clusterId, clusterConfigurationId,jid, getId(),
+            alias, fg, sts, batchModel, checkPoint, parallelism, savePointStrategy, savePointPath, map);
     }
 
 }

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

@@ -525,7 +525,7 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen
 
     private JobConfig buildJobConfig(Task task) {
         boolean isJarTask = Dialect.FLINKJAR.equalsVal(task.getDialect());
-        if (!isJarTask && task.getFragment()) {
+        if (!isJarTask && Asserts.isNotNull(task.getFragment())?task.getFragment():false) {
             String flinkWithSql = dataBaseService.getEnabledFlinkWithSql();
             if (Asserts.isNotNullString(flinkWithSql)) {
                 task.setStatement(flinkWithSql + "\r\n" + task.getStatement());