nzw921rx opened a new pull request, #11747: URL: https://github.com/apache/seatunnel/pull/11747
## Purpose - Register Hudi's existing synchronized flush path for Zeta timer flush signals. - Keep the registered action bound to the current record writer after multi-table resource initialization replaces the original writer. - Document the Zeta-only, at-least-once behavior in English and Chinese. ## Tests - `./mvnw spotless:apply` - `./mvnw -pl seatunnel-connectors-v2/connector-hudi -DskipIT -Dtest=HudiSinkWriterTest -DargLine=-Djdk.attach.allowAttachSelf=true test` - `TEST_IN_PR=true RUN_ALL_CONTAINER=false RUN_ZETA_CONTAINER=true ./mvnw -pl seatunnel-connectors-v2/connector-hudi,seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hudi-e2e -DskipUT -DskipIT=false -Dit.test=HudiSinkCDCIT#testHudiTimerFlush -DfailIfNoTests=false integration-test` The E2E test verifies that two MySQL CDC records become visible in Hudi through separate timer flushes while the streaming job is still running. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
