Skip to content

Commit 85ac022

Browse files
authored
Add CDCJobTest and remove unreach codes for CDCJob (#37416)
1 parent 6ca1a79 commit 85ac022

2 files changed

Lines changed: 430 additions & 4 deletions

File tree

  • kernel/data-pipeline/scenario/cdc/core/src
    • main/java/org/apache/shardingsphere/data/pipeline/cdc
    • test/java/org/apache/shardingsphere/data/pipeline/cdc

kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJob.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -212,10 +212,6 @@ private void executeInventoryTasks(final Collection<CDCJobItemContext> jobItemCo
212212
private void executeIncrementalTasks(final Collection<CDCJobItemContext> jobItemContexts, final PipelineJobItemManager<TransmissionJobItemProgress> jobItemManager) {
213213
Collection<CompletableFuture<?>> futures = new LinkedList<>();
214214
for (CDCJobItemContext each : jobItemContexts) {
215-
if (JobStatus.EXECUTE_INCREMENTAL_TASK == each.getStatus()) {
216-
log.info("Job status has already EXECUTE_INCREMENTAL_TASK, ignore.");
217-
return;
218-
}
219215
updateJobItemStatus(each, JobStatus.EXECUTE_INCREMENTAL_TASK, jobItemManager);
220216
for (PipelineTask task : each.getIncrementalTasks()) {
221217
if (task.getTaskProgress().getPosition() instanceof IngestFinishedPosition) {

0 commit comments

Comments
 (0)