You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2024/08/15 03:13:29 UTC
(shardingsphere) branch revert-32514-dev created (now 6c0ac301b1b)
This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a change to branch revert-32514-dev
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
at 6c0ac301b1b Revert "Remove useless CreateIncrementalDumperParameter.dataSourceManager (#3…"
This branch includes the following new commits:
new 6c0ac301b1b Revert "Remove useless CreateIncrementalDumperParameter.dataSourceManager (#3…"
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(shardingsphere) 01/01: Revert "Remove useless CreateIncrementalDumperParameter.dataSourceManager (#3…"
Posted by zh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch revert-32514-dev
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
commit 6c0ac301b1b53001b7ddf581a2e61a8f1effa022
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Thu Aug 15 11:13:24 2024 +0800
Revert "Remove useless CreateIncrementalDumperParameter.dataSourceManager (#3…"
This reverts commit dcb5393cea50bf12b52009be35353c9cd75037e1.
---
.../ingest/dumper/incremental/CreateIncrementalDumperParameter.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/incremental/CreateIncrementalDumperParameter.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/incremental/CreateIncrementalDumperParameter.java
index f5170a88f7a..8e0eb3f2f57 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/incremental/CreateIncrementalDumperParameter.java
+++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/incremental/CreateIncrementalDumperParameter.java
@@ -20,6 +20,7 @@ package org.apache.shardingsphere.data.pipeline.core.ingest.dumper.incremental;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.data.pipeline.core.channel.PipelineChannel;
+import org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager;
import org.apache.shardingsphere.data.pipeline.core.ingest.position.IngestPosition;
import org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
@@ -37,4 +38,6 @@ public final class CreateIncrementalDumperParameter {
private final PipelineChannel channel;
private final PipelineTableMetaDataLoader metaDataLoader;
+
+ private final PipelineDataSourceManager dataSourceManager;
}