(shardingsphere) branch master updated: Refactor MigrateTableUpdater (#29221)

[jianglongtao]

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

jianglongtao 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 2422d4b0edd Refactor MigrateTableUpdater (#29221)
2422d4b0edd is described below

commit 2422d4b0edd418179414535d7234a154dbbcedc9
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Mon Nov 27 23:47:41 2023 +0800

    Refactor MigrateTableUpdater (#29221)
---
 .../migration/distsql/handler/update/MigrateTableUpdater.java          | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
 
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
index 3d0214752d2..cb16f8625a7 100644
--- 
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
+++ 
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
@@ -32,12 +32,11 @@ import 
org.apache.shardingsphere.migration.distsql.statement.MigrateTableStateme
  */
 public final class MigrateTableUpdater implements 
RALUpdater<MigrateTableStatement> {
     
-    private final MigrationJobAPI jobAPI = (MigrationJobAPI) 
TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
-    
     @Override
     public void executeUpdate(final String databaseName, final 
MigrateTableStatement sqlStatement) {
         String targetDatabaseName = null == 
sqlStatement.getTargetDatabaseName() ? databaseName : 
sqlStatement.getTargetDatabaseName();
         ShardingSpherePreconditions.checkNotNull(targetDatabaseName, 
MissingRequiredTargetDatabaseException::new);
+        MigrationJobAPI jobAPI = (MigrationJobAPI) 
TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
         jobAPI.start(new PipelineContextKey(InstanceType.PROXY), new 
MigrateTableStatement(sqlStatement.getSourceTargetEntries(), 
targetDatabaseName));
     }