This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 29df45855c [Fix][Connector-V2] Fail the ClickHouse stream reader on
interrupt instead of polling forever (#12727)
add 67941ddefa [Fix][Connector-CDC] Resolve stop.mode=latest stop offset
at binlog phase start (#11885)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/MySQL-CDC.md | 22 ++-
docs/zh/connectors/source/MySQL-CDC.md | 21 ++-
.../enumerator/IncrementalSplitAssigner.java | 92 +++++++++++-
.../enumerator/state/IncrementalPhaseState.java | 15 +-
.../source/enumerator/HybridSplitAssignerTest.java | 15 +-
.../enumerator/IncrementalSplitAssignerTest.java | 83 +++++++++++
.../state/IncrementalPhaseStateTest.java | 91 ++++++++++++
.../cdc/mysql/MysqlCDCStopModeSpecificIT.java | 162 +++++++++++++++++++++
..._offset.conf => mysqlcdc_stop_mode_latest.conf} | 15 +-
...onf => mysqlcdc_stop_mode_latest_specific.conf} | 4 +-
...nf => mysqlcdc_stop_mode_latest_timestamp.conf} | 8 +-
11 files changed, 508 insertions(+), 20 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/test/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/state/IncrementalPhaseStateTest.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/{mysqlcdc_specific_gtid_offset.conf
=> mysqlcdc_stop_mode_latest.conf} (71%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/{mysqlcdc_specific_offset.conf
=> mysqlcdc_stop_mode_latest_specific.conf} (98%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/{mysqlcdc_timestamp_offset.conf
=> mysqlcdc_stop_mode_latest_timestamp.conf} (93%)
