This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 596e3194a7f Remove push FinishedRecord at MySQL increment dumper
(#25897)
596e3194a7f is described below
commit 596e3194a7f663c5ca3641bdabaadbf56d807ded
Author: Xinze Guo <[email protected]>
AuthorDate: Thu May 25 22:08:18 2023 +0800
Remove push FinishedRecord at MySQL increment dumper (#25897)
---
.../data/pipeline/mysql/ingest/MySQLIncrementalDumper.java | 3 ---
1 file changed, 3 deletions(-)
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumper.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumper.java
index 71f7c8f0f55..793de1271ae 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumper.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumper.java
@@ -25,11 +25,9 @@ import
org.apache.shardingsphere.data.pipeline.api.datasource.config.yaml.YamlJd
import
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor;
import
org.apache.shardingsphere.data.pipeline.api.ingest.channel.PipelineChannel;
import
org.apache.shardingsphere.data.pipeline.api.ingest.dumper.IncrementalDumper;
-import
org.apache.shardingsphere.data.pipeline.api.ingest.position.FinishedPosition;
import
org.apache.shardingsphere.data.pipeline.api.ingest.position.IngestPosition;
import org.apache.shardingsphere.data.pipeline.api.ingest.record.Column;
import org.apache.shardingsphere.data.pipeline.api.ingest.record.DataRecord;
-import
org.apache.shardingsphere.data.pipeline.api.ingest.record.FinishedRecord;
import
org.apache.shardingsphere.data.pipeline.api.ingest.record.PlaceholderRecord;
import org.apache.shardingsphere.data.pipeline.api.ingest.record.Record;
import org.apache.shardingsphere.data.pipeline.api.metadata.ActualTableName;
@@ -107,7 +105,6 @@ public final class MySQLIncrementalDumper extends
AbstractLifecycleExecutor impl
}
handleEvents(events);
}
- channel.pushRecords(Collections.singletonList(new FinishedRecord(new
FinishedPosition())));
}
private void handleEvents(final List<AbstractBinlogEvent> events) {
