You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2025/05/15 05:13:31 UTC
(shardingsphere) branch master updated: Refactor ShowMigrationListExecutor (#35420)
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 c9977564315 Refactor ShowMigrationListExecutor (#35420)
c9977564315 is described below
commit c9977564315d2c253fd2b40c5e0e4a206459ea9b
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Thu May 15 13:13:25 2025 +0800
Refactor ShowMigrationListExecutor (#35420)
---
.../distsql/handler/migration/query/ShowMigrationListExecutor.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
index 536750800df..f6c29ef5c58 100644
--- a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
+++ b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
@@ -58,7 +58,6 @@ public final class ShowMigrationListExecutor implements DistSQLQueryExecutor<Sho
}
private String getJobShardingNodes(final PipelineContextKey contextKey, final String jobId) {
- // SPEX CHANGED: BEGIN
Collection<ShardingInfo> shardingInfos;
try {
shardingInfos = pipelineJobManager.getJobShardingInfos(contextKey, jobId);
@@ -67,7 +66,6 @@ public final class ShowMigrationListExecutor implements DistSQLQueryExecutor<Sho
// CHECKSTYLE:ON
return "";
}
- // SPEX CHANGED: END
return shardingInfos.isEmpty() ? "" : getJobShardingNodes(shardingInfos);
}