You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2023/12/02 04:01:04 UTC
(shardingsphere) branch master updated: Refactor CDCJobOption (#29260)
This is an automated email from the ASF dual-hosted git repository.
panjuan 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 34e8601f4d9 Refactor CDCJobOption (#29260)
34e8601f4d9 is described below
commit 34e8601f4d97f6faa4eadb5548338cce82e2027c
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Sat Dec 2 12:00:58 2023 +0800
Refactor CDCJobOption (#29260)
---
.../org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java
index 496bb97b2dd..fe6a30238d6 100644
--- a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java
+++ b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java
@@ -21,6 +21,7 @@ import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.cdc.config.job.CDCJobConfiguration;
import org.apache.shardingsphere.data.pipeline.cdc.config.yaml.YamlCDCJobConfigurationSwapper;
import org.apache.shardingsphere.data.pipeline.common.config.job.PipelineJobConfiguration;
+import org.apache.shardingsphere.data.pipeline.common.config.process.PipelineProcessConfiguration;
import org.apache.shardingsphere.data.pipeline.common.context.TransmissionProcessContext;
import org.apache.shardingsphere.data.pipeline.common.pojo.PipelineJobInfo;
import org.apache.shardingsphere.data.pipeline.common.pojo.PipelineJobMetaData;
@@ -62,8 +63,8 @@ public final class CDCJobOption implements TransmissionJobOption {
@Override
public TransmissionProcessContext buildProcessContext(final PipelineJobConfiguration jobConfig) {
- TransmissionJobManager jobManager = new TransmissionJobManager(this);
- return new TransmissionProcessContext(jobConfig.getJobId(), jobManager.showProcessConfiguration(PipelineJobIdUtils.parseContextKey(jobConfig.getJobId())));
+ PipelineProcessConfiguration processConfig = new TransmissionJobManager(this).showProcessConfiguration(PipelineJobIdUtils.parseContextKey(jobConfig.getJobId()));
+ return new TransmissionProcessContext(jobConfig.getJobId(), processConfig);
}
@Override