[incubator-seatunnel] branch dev updated: [Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)

[ic4y]

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

ic4y pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 40d67ab90 [Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)
40d67ab90 is described below

commit 40d67ab902c69494f9803c0859ed8f7f84657380
Author: liugddx <804167...@qq.com>
AuthorDate: Mon Oct 31 17:26:50 2022 +0800

    [Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)
    
    * fix jdbc split bug
    
    * add changelog
    
    * Update docs/en/connector-v2/source/Jdbc.md
---
 docs/en/connector-v2/source/Jdbc.md                                    | 3 +++
 .../connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java    | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/docs/en/connector-v2/source/Jdbc.md 
b/docs/en/connector-v2/source/Jdbc.md
index 33cd324be..3e8d91806 100644
--- a/docs/en/connector-v2/source/Jdbc.md
+++ b/docs/en/connector-v2/source/Jdbc.md
@@ -145,3 +145,6 @@ parallel:
 - [Feature] Support StarRocks JDBC Source 
([3060](https://github.com/apache/incubator-seatunnel/pull/3060))
 - [Feature] Support GBase8a JDBC Source 
([3026](https://github.com/apache/incubator-seatunnel/pull/3026))
 - [Feature] Support DB2 JDBC Source 
([2410](https://github.com/apache/incubator-seatunnel/pull/2410))
+### next version
+
+- [BugFix] Fix jdbc split bug 
([3220](https://github.com/apache/incubator-seatunnel/pull/3220))
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
index 0f1be63cb..0a10fe125 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
@@ -98,8 +98,8 @@ public class JdbcSourceSplitEnumerator implements 
SourceSplitEnumerator<JdbcSour
                 // Assign pending splits to reader
                 LOG.info("Assigning splits to readers {}", 
pendingAssignmentForReader);
                 enumeratorContext.assignSplit(pendingReader, new 
ArrayList<>(pendingAssignmentForReader));
-                enumeratorContext.signalNoMoreSplits(pendingReader);
             }
+            enumeratorContext.signalNoMoreSplits(pendingReader);
         }
     }