flink-cdc

flink-cdc copied to clipboard

herunkang2018

[FLINK-36052][docs][elasticsearch] Add flink cdc elasticsearch pipeline sink to docs

2

@proletarians @leonardBang PTAL, thanks. Or we can continue previous pr(https://github.com/apache/flink-cdc/pull/3539).

beryllw

[FLINK-36309][pipeline-connector/paimon] Paimon Sink commit failed should log stackTrace

3

Flink CDC Paimon Sink Commit failed should log StackTrace, not just a warning log. ``` 2024-09-18 11:15:07,984 WARN  org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonCommitter [] - Commit failed for 4 with 2 committable 2024-09-18 11:15:08,093...

beryllw

[FLINK-36524][pipeline-connector][paimon] bump version of Paimon to 0.9.0

2

1) bump version to 0.9.0. 2) Forcibly add cache-enabled = false in catalog option to avoid using previous table schema. Refer to https://paimon.apache.org/docs/master/maintenance/configurations/#catalogoptions, after bump version to 0.9.0, we can...

lvyanquan

herunkang2018

[FLINK-36560][pipeline-connector][paimon] fix the issue that timestamp_ltz field is not correctly converted.

1

This test case has already indicated this issue, but it was initially overlooked.

lvyanquan

upgrade ticdc's tikv.version from 3.2.0 to 3.3.0, so that It won't be a conflict with Flink's own Rocksdb , because tikv-client 3.3.0 without rocksdb。

zjl-bright

This fixes a invalid jumping link in Chinese docs by providing the correct chapter title in the hyperlink.

yuxiqian

PaimonSink now implements StatefulSink to store checkpointId in state, It has been verified through local testing that it is compatible with the state of 3.2.0. I will try to add...

lvyanquan

This closes FLINK-36461. Currently, such transform configuration will fail for any schema change events from tables except `foo.bar.baz`: ```yaml transform:   - source-table: foo.bar.baz     projection: \* ``` The exception message is...

yuxiqian