flink-cdc

flink-cdc copied to clipboard

[Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka"

1

Desc: [FLINK-36980](https://issues.apache.org/jira/browse/FLINK-36980)

Sukang1002

[FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution

3

# Description This PR addresses the issue identified in FLINK-37677, where setting `exclude.schema.changes: [create.table]` in the YAML configuration causes Flink CDC to throw an `IllegalStateException`. ``` java.lang.IllegalStateException: Unable to coerce...

beryllw

[FLINK-37203] Alter table comment or column comment

5

https://issues.apache.org/jira/browse/FLINK-37203

ChaomingZhangCN

[FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist

3

The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink

aiwenmo

[FLINK-37199][doc] Update configuration in quickstart.

2

Update configuration file for Flink 1.19+.

lvyanquan

[FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions.

4

wangqinghuan

[FLINK-37209][transform] Add built-in Qwen model for transform.

1

Add built-in [Qwen](https://github.com/QwenLM/Qwen2.5) model for transform.

lvyanquan

pipeline cdc connector support multiple data sources The relevant design and verification documents are as follows: https://www.yuque.com/oniucium/lfk1te/ocp6m13kpgh1x9pg?singleDoc#

linjianchang

docs: updated StarRocks documentation link

1

zhuxt2015

[FLINK-35599] Introduce JDBC pipeline sink connector

9

This closes FLINK-35599 by implementing the long-awaited JDBC pipeline sink connector, largely based on @kissycn's work in #3433. --- Compared to Zhou's original PR, some changes have been made to...

yuxiqian