dybyte opened a new pull request, #11537:
URL: https://github.com/apache/seatunnel/pull/11537
### Purpose of this pull request
Honor `multi_table.failure_policy` when an aggregated timer flush fails for
a specific table.
Previously, `MultiTableSinkWriter.aggregatedFlush()` propagated the first
sub-writer flush exception immediately. Under `CONTINUE_OTHER_TABLES`, this
could fail the sink task and prevent remaining healthy tables from being
flushed.
This patch applies the existing table retry and isolation handling to timer
flushes. A failed table is quarantined after its retries are exhausted, while
healthy tables continue to be flushed. The existing `FAIL_FAST` behavior
remains unchanged.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
- Added unit tests verifying:
- retry and table isolation under `CONTINUE_OTHER_TABLES`
- healthy tables continue to be flushed
- quarantined tables are skipped by subsequent timer flushes
- flush exceptions are immediately propagated under `FAIL_FAST`
### Check list
* [ ] If any new Jar binary package adding in your PR, please add License
Notice according
[New License
Guide](https://github.com/apache/seatunnel/blob/dev/docs/en/developer/new-license.md)
* [ ] If necessary, please update the documentation to describe the new
feature. https://github.com/apache/seatunnel/tree/dev/docs
* [ ] If necessary, please update `incompatible-changes.md` to describe the
incompatibility caused by this PR.
* [ ] If you are contributing the connector code, please check that the
following files are updated:
1. Update
[plugin-mapping.properties](https://github.com/apache/seatunnel/blob/dev/plugin-mapping.properties)
and add new connector information in it
2. Update the pom file of
[seatunnel-dist](https://github.com/apache/seatunnel/blob/dev/seatunnel-dist/pom.xml)
3. Add ci label in
[label-scope-conf](https://github.com/apache/seatunnel/blob/dev/.github/workflows/labeler/label-scope-conf.yml)
4. Add e2e testcase in
[seatunnel-e2e](https://github.com/apache/seatunnel/tree/dev/seatunnel-e2e/seatunnel-connector-v2-e2e/)
5. Update connector
[plugin_config](https://github.com/apache/seatunnel/blob/dev/config/plugin_config)
--
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]
