nzw921rx opened a new pull request, #11527: URL: https://github.com/apache/seatunnel/pull/11527
## Purpose Support timer-driven flushing for the MongoDB sink on the Zeta engine so pending bulk requests can be written without waiting for the batch threshold, a new input record, or the next checkpoint. ## Changes - Register the existing MongoDB bulk-write path with `SinkWriter.Context` for non-transaction writers. - Keep timer flush disabled when `transaction = true` to preserve the checkpoint transaction boundary. - Propagate MongoDB bulk-write failures through the timer flush action. - Add unit coverage for timer action registration, bulk execution, transaction guarding, and failure propagation. - Add an independent Zeta E2E test using a continuous MySQL CDC source, dynamic container port mapping, and a classpath-provided MySQL Connector/J. - Document Zeta timer flush behavior and at-least-once delivery semantics in English and Chinese. ## Validation - `./mvnw spotless:apply` - `./mvnw -pl seatunnel-connectors-v2/connector-mongodb -DskipIT -DskipUT=false -Dtest=MongodbWriterTest -DfailIfNoTests=false test` - `./mvnw -pl seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e -DskipUT -DskipIT -DskipTests test-compile` - `TEST_IN_PR=true RUN_ALL_CONTAINER=false RUN_ZETA_CONTAINER=true ./mvnw -pl seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e -DskipUT -DskipIT=false -Dit.test=MongodbTimerFlushIT -DfailIfNoTests=false verify` -- 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]
