(shardingsphere) branch master updated: Refactor MigrationJobType (#37110)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang 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 39c5b494b7d Refactor MigrationJobType (#37110)
39c5b494b7d is described below

commit 39c5b494b7da0fde009eed4e5b3c12637a27f2ed
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sat Nov 15 14:33:25 2025 +0800

    Refactor MigrationJobType (#37110)
---
 .../data/pipeline/scenario/migration/MigrationJobType.java            | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
 
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
index 6005b214b6e..966a299718c 100644
--- 
a/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
+++ 
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
@@ -47,9 +47,9 @@ public final class MigrationJobType implements 
PipelineJobType {
     
     @Override
     public PipelineJobInfo getJobInfo(final PipelineJobMetaData jobMetaData) {
+        MigrationJobConfiguration jobConfig = new 
PipelineJobConfigurationManager(getOption()).getJobConfiguration(jobMetaData.getJobId());
         Collection<String> sourceTables = new LinkedList<>();
-        new PipelineJobConfigurationManager(new 
MigrationJobType().getOption()).<MigrationJobConfiguration>getJobConfiguration(jobMetaData.getJobId()).getJobShardingDataNodes()
-                .forEach(each -> each.getEntries().forEach(entry -> 
entry.getDataNodes().forEach(dataNode -> sourceTables.add(dataNode.format()))));
+        jobConfig.getJobShardingDataNodes().forEach(each -> 
each.getEntries().forEach(entry -> entry.getDataNodes().forEach(dataNode -> 
sourceTables.add(dataNode.format()))));
         return new PipelineJobInfo(jobMetaData, null, String.join(",", 
sourceTables));
     }