flink-cdc

flink-cdc copied to clipboard

[FLINK-35600] Add timestamp for low and high watermark

6

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

JNSimba

lvyanquan

use lazy initialization to resolve circular dependency between the `DataFieldSerializer`, `DataTypeSerializer`, and `RowTypeSerializer` classes that causes NPE for certain RowTypes like nested row type

5

There is a circular dependency between the `DataFieldSerializer`, `DataTypeSerializer`, and `RowTypeSerializer` classes. This circular dependency can lead to incomplete initialization of the serializers, causing a `NullPointerException` when you attempt to...

umeshdangat

[FLINK-35544][minor][docs] Add deployment documentations for Kubernetes Operator.

4

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

qg-lin

Code optimization extracts constants

ChengJie1053

Hive metastore Require column names to be lowercase, but field names from upstream tables may not meet the requirements. I've transferred the columnname into lowercase and tested the case with...

kyzheng196

[FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax.

4

Support parsing SQL like following and emit new SchemaChangeEvent to downstream. ``` CREATE TABLE `user_log_copy` LIKE `user_log` ``` and ``` CREATE TABLE `user_log_copy` AS SELECT * FROM `user_log` ```

lvyanquan

[FLINK-36174][hotfix] CDC yaml without pipeline should not throw exception.

1

CDC yaml without pipeline should not throw exception.

loserwang1024

[hotfix][transform] Fix transform operator swallows schema changes from tables not present in transform rules

1

Currently, tables that are not present in transform blocks should be treated as if there's such a dummy fallback block: ```yaml transform: - source-table: "\.*.\.*" # capture all unmentioned tables...

yuxiqian

[tests] Reorganize test cases to accelerate CI workflow

1

Currently, CDC runs (pipeline and source) E2e cases on various Flink versions sequentially. A complete workflow would need almost 80 minutes to finish. This PR runs E2e test cases in...

yuxiqian