(shardingsphere) branch master updated: Refactor CDCJobOption (#29260)

[panjuan]

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 <zhangli...@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