lvyanquan opened a new pull request, #4605:
URL: https://github.com/apache/flink-cdc/pull/4605
## What is the purpose of this pull request?
Allow pipelines to explicitly control whether sink-table replacement can
change table ID levels. Existing routing behavior remains the default.
## Brief change log
- Add the per-route `table-id-level-change.enabled` option, defaulting to
`true`.
- When disabled, preserve the component boundaries defined by the sink-table
template.
- Apply the option to both symbol and capture-group replacements.
- Wire the option through regular, batch, and distributed topologies.
- Update the English and Chinese route documentation.
## Verifying this change
- Add unit tests for configuration parsing, replacement semantics,
structured table IDs, and compatibility with existing behavior.
- Add MiniCluster tests covering schema and data events in all three
topologies.
- Verify 149 related tests on each of Flink 1.20.3 / JDK11
and Flink 2.2.0 / JDK17.
- Spotless and Checkstyle checks pass.
## Documentation
- Does this pull request introduce a new feature? Yes.
- If yes, how is the feature documented? English and Chinese route
documentation.
##### Was generative AI tooling used to co-author this PR?
- [X] Yes — Qoder
Generated-by: Qoder
--
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]
