[BugFix]fix job id is null exception in query model (#3869)

Co-authored-by: zhuxt2015 <zhuxt2015@users.noreply.github.com>
DataLinkDC · Oct 17, 2024 · ea1d900 · ea1d900
1 parent 846f3e0
commit ea1d900
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/job/handler/Job2MysqlHandler.java b/dinky-admin/src/main/java/org/dinky/job/handler/Job2MysqlHandler.java
@@ -180,17 +180,19 @@ public boolean success() {
         history.setClusterId(clusterId);
         historyService.updateById(history);
 
-        if (Asserts.isNullCollection(job.getJids()) || Asserts.isNullString(job.getJobManagerAddress())) {
+        if (job.getJobConfig().isStatementSet()
+                && (Asserts.isNullCollection(job.getJids()) || Asserts.isNullString(job.getJobManagerAddress()))) {
             throw new BusException("The JobID or JobManagerAddress is null. ");
         }
 
-        String jid = job.getJids().get(0);
         JobInstance jobInstance = history.buildJobInstance();
         jobInstance.setHistoryId(job.getId());
         jobInstance.setClusterId(clusterId);
         jobInstance.setTaskId(taskId);
         jobInstance.setName(job.getJobConfig().getJobName());
-        jobInstance.setJid(jid);
+        if (Asserts.isNotNullCollection(job.getJids())) {
+            jobInstance.setJid(job.getJids().get(0));
+        }
         jobInstance.setStep(job.getJobConfig().getStep());
         jobInstance.setStatus(JobStatus.INITIALIZING.getValue());
         jobInstanceService.save(jobInstance);