Skip to content

Commit

Permalink
clean
Browse files Browse the repository at this point in the history
Signed-off-by: xxchan <[email protected]>
  • Loading branch information
xxchan committed Apr 20, 2024
1 parent 8e3a558 commit fba663f
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions src/stream/src/executor/source/source_executor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -458,8 +458,6 @@ impl<S: StateStore> SourceExecutor<S> {
boot_state.clone_from(splits);
}
}
// XXX: When the source executor is newly created, the first barrier must be Add or Update (created during scaling).
// But when restarting the cluster, is it possible that the first barrier is an Add adding dispatchers?
_ => {}
}
}
Expand Down

0 comments on commit fba663f

Please sign in to comment.