Only update job status of files for non-splitting jobs

kr565370 · kr565370 · commit 23f6459bd2ea · 2024-01-16T15:04:08.000Z
diff --git a/java/compaction/compaction-job-creation/src/main/java/sleeper/compaction/job/creation/CreateJobs.java b/java/compaction/compaction-job-creation/src/main/java/sleeper/compaction/job/creation/CreateJobs.java
@@ -156,7 +156,9 @@ public void createJobsForTable(TableProperties tableProperties) throws StateStor
                     }
                 }
             }
-            stateStore.atomicallyUpdateJobStatusOfFiles(compactionJob.getId(), fileReferences1);
+            if (!compactionJob.isSplittingJob()) {
+                stateStore.atomicallyUpdateJobStatusOfFiles(compactionJob.getId(), fileReferences1);
+            }
             jobStatusStore.jobCreated(compactionJob);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -156,7 +156,9 @@ public void createJobsForTable(TableProperties tableProperties) throws StateStor`
`156`	`156`	`}`
`157`	`157`	`}`
`158`	`158`	`}`
`159`		`- stateStore.atomicallyUpdateJobStatusOfFiles(compactionJob.getId(), fileReferences1);`
	`159`	`+ if (!compactionJob.isSplittingJob()) {`
	`160`	`+ stateStore.atomicallyUpdateJobStatusOfFiles(compactionJob.getId(), fileReferences1);`
	`161`	`+ }`
`160`	`162`	`jobStatusStore.jobCreated(compactionJob);`
`161`	`163`	`}`
`162`	`164`	`}`