Refactor CDCJobOption

apache · Dec 2, 2023 · 788965f · 788965f
1 parent 373a607
commit 788965f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java b/...ario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/CDCJobOption.java
@@ -21,6 +21,7 @@
 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 PipelineJobInfo getJobInfo(final String jobId) {
 
     @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