flink-cdc

flink-cdc copied to clipboard

The goal is to extend flink-cdc with the capability to invoke AI models during the data stream processing workflow, with a particular focus on supporting array data structures. This feature...

proletarians

fix Unsupported bucket mode: GLOBAL_DYNAMIC error.

lvyanquan

[FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey.

3

Avoid EOFException for table with a large amount of data.

lvyanquan

This PR cleans up `SchemaChangeEventVisitor` class by: * Using templated `VisitorHandler` to replace individual `XXXEventVisitor` classes * Introduce `voidVisit` method for visitors that don't yield a returning value

yuxiqian

This closes FLINK-36514. If schema evolution behavior is set to LENIENT, Truncate / Drop table events will be ignored by default. However, there's currently no way for users to override...

yuxiqian

This closes FLINK-36221. [FLINK-34877](https://issues.apache.org/jira/browse/FLINK-34877) adds `CAST ... AS ...` syntax in transform expressions, but there's no corresponding documentations yet. Adding it would make it easier for users to write expressions.

yuxiqian

The MySQL source already supports embedding observability metrics, but this feature cannot be reused by other source types. Therefore, we hope to port this feature to the base for easy...

liuxiao2shf

[FLINK-36442](https://issues.apache.org/jira/browse/FLINK-36442) Adds the option to do an insert-only stream for connectors that support specifying a changelog mode. This allows debezium connectors to be imported into flink as stream tables to...

nandorsoma

[FLINK-36375][cdc-runtime] fix missing default value in AddColumnEvent/RenameColunEvent

2

SchemaOperator receives an AddColumnEvent, the default value will be lost when sent downstream. JIRA: [https://issues.apache.org/jira/browse/FLINK-36375](url)

qg-lin

I created a version that fixes itself automatically, but I can't verify it because I don't know how.

911432