You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ic...@apache.org on 2022/10/31 09:26:56 UTC
[incubator-seatunnel] branch dev updated: [Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)
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 <80...@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);
}
}