Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Nov 29, 2024
1 parent 0f18510 commit dc8be0e
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,16 +50,13 @@ public class LoadProcessor extends AbstractJobProcessor {
// this latch is used to wait finish for load, for example, insert into statement
// MarkedCountDownLatch:
// key: fragmentId, value: backendId
private volatile Optional<PipelineExecutionTask> executionTask;
private volatile Optional<MarkedCountDownLatch<Integer, Long>> latch;
private volatile Optional<Map<BackendFragmentId, SingleFragmentPipelineTask>> backendFragmentTasks;
private volatile List<SingleFragmentPipelineTask> topFragmentTasks;

public LoadProcessor(CoordinatorContext coordinatorContext, long jobId) {
super(coordinatorContext);

this.loadContext = new LoadContext();
this.executionTask = Optional.empty();
this.latch = Optional.empty();
this.backendFragmentTasks = Optional.empty();

Expand Down

0 comments on commit dc8be0e

Please sign in to comment.