Split PipelineJobAPI to PipelineJobOption and PipelineJobAPI

apache · Nov 25, 2023 · b181cba · b181cba
1 parent 12d885e
commit b181cba
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...ain/java/org/apache/shardingsphere/data/pipeline/core/job/service/PipelineJobManager.java b/...ain/java/org/apache/shardingsphere/data/pipeline/core/job/service/PipelineJobManager.java
@@ -174,7 +174,7 @@ public void drop(final String jobId) {
      * @return jobs info
      */
     public List<PipelineJobInfo> getJobInfos(final PipelineContextKey contextKey) {
-        if (jobOption instanceof TransmissionJobAPI) {
+        if (jobOption instanceof TransmissionJobOption) {
             return PipelineAPIFactory.getJobStatisticsAPI(contextKey).getAllJobsBriefInfo().stream()
                     .filter(each -> !each.getJobName().startsWith("_") && jobOption.getType().equals(PipelineJobIdUtils.parseJobType(each.getJobName()).getType()))
                     .map(each -> ((TransmissionJobOption) jobOption).getJobInfo(each.getJobName())).collect(Collectors.toList());

diff --git a/...va/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java b/...va/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java
@@ -31,8 +31,7 @@ public final class CommitMigrationUpdater implements RALUpdater<CommitMigrationS
 
     @Override
     public void executeUpdate(final String databaseName, final CommitMigrationStatement sqlStatement) throws SQLException {
-        TransmissionJobAPI jobAPI = TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
-        jobAPI.commit(sqlStatement.getJobId());
+        TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION").commit(sqlStatement.getJobId());
     }
 
     @Override