azexcy commented on code in PR #25787:
URL: https://github.com/apache/shardingsphere/pull/25787#discussion_r1198792884
##########
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/IncrementalTask.java:
##########
@@ -65,24 +63,25 @@ public final class IncrementalTask implements PipelineTask,
AutoCloseable {
private final Dumper dumper;
- private final Collection<Importer> importers;
+ private final Importer importer;
@Getter
private final IncrementalTaskProgress taskProgress;
// TODO simplify parameters
- public IncrementalTask(final int concurrency, final DumperConfiguration
dumperConfig, final ImporterConfiguration importerConfig,
+ public IncrementalTask(final DumperConfiguration dumperConfig, final
ImporterConfiguration importerConfig,
Review Comment:
Rollback it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
