Refactor MigrateTableUpdater (#29221)

apache · Nov 27, 2023 · 2422d4b · 2422d4b
1 parent 0df0325
commit 2422d4b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/.../java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java b/.../java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
@@ -32,12 +32,11 @@
  */
 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));
     }