fix bug.when run jdbc connector task,registerReader will error.

apache · Sep 27, 2022 · d0537da · d0537da
1 parent 4d4b5dd
commit d0537da
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ranslation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelSource.java b/...ranslation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelSource.java
@@ -101,13 +101,13 @@ public ParallelSource(SeaTunnelSource<T, SplitT, StateT> source,
 
     @Override
     public void open() throws Exception {
+        parallelEnumeratorContext.register();
         executorService = ThreadPoolExecutorFactory.createScheduledThreadPoolExecutor(1, String.format("parallel-split-enumerator-executor-%s", subtaskId));
         splitEnumerator.open();
         if (restoredSplitState.size() > 0) {
             splitEnumerator.addSplitsBack(restoredSplitState, subtaskId);
         }
         reader.open();
-        parallelEnumeratorContext.register();
         splitEnumerator.registerReader(subtaskId);
     }