flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
This closes FLINK-35647, inspired by #2908 and #2947. Credit goes to @icchux and @WholeWorld-Timothy. --- Currently, we must provide explicit sink-table in pipeline route rules, which means if we'd like...
Refer to: https://issues.apache.org/jira/browse/FLINK-35589 Support MemorySize type in FlinkCDC ConfigOptions.
This closes FLINK-35633. > This requires #3428 being merged first. Currently, transform & route rules will be passed to Flink operators as strings, and any malformed configurations will not be...
https://issues.apache.org/jira/browse/FLINK-35490 Junit4 to Junit5 migration of `flink-cdc-connect/flink-cdc-source-connectors` module. Reference document: [Junit5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4xm5uiuXOooOJTtXqS_Jqk9KJitU). - All the unit and integration tests should work as expected
[FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector.
https://issues.apache.org/jira/browse/FLINK-35143
After #3489 got merged, a regular E2e CI run requires approximately 1h 15min to run, and JUnit will not execute pipeline E2e cases until all source E2e cases complete successfully....
Current, inJdbcConnectionPools is static instance, so the datasource pools in it won't be recycle when reader close. It will cause memory leak. ```java public class JdbcConnectionPools implements ConnectionPools { private...
Flink CDC 3.1.1 has been released in public. Migration tests could be added to ensure its compatibility with any future versions.
Fix some words error
https://issues.apache.org/jira/browse/FLINK-35237
