flink-cdc

flink-cdc copied to clipboard

PONYLEE

[FLINK-35325][cdc-connector][paimon]Support for specifying column order.

1

Refer to jira: https://issues.apache.org/jira/browse/FLINK-35325 Adding support for specifying column order when adding new columns to a table.

joyCurry30

[FLINK-35592] Fix MysqlDebeziumTimeConverter miss timezone convert to timestamp

4

Fix [FLINK-35173](https://issues.apache.org/jira/browse/FLINK-35173) MysqlDebeziumTimeConverter miss timezone convert to timestamp.

czy006

[FLINK-35373][cdc-connector][paimon] Simplify Flink CDC Paimon Sink web ui

1

fix [#FLINK-35373](https://issues.apache.org/jira/browse/FLINK-35373) And example code. https://github.com/apache/paimon/blob/3b006fe1bb8d70b640f3c4c8033133698a7f668e/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcMultiplexRecordChannelComputer.java#L97-L99

beryllw

Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)'

1

### Please don't check the box below - [X] I'm aware that bugs and new features should be reported on Apache Jira or Flink mailing list instead of here ###...

lixiang8103

Optimize markdown formats in doris quickstart doc

Jiabao-Sun

Optimize markdown formats in doris quickstart doc

Jiabao-Sun


Jiabao-Sun

[FLINK-35354] Support host mapping in Flink tikv cdc

5

In tidb production environment deployment, there are usually two kinds of network: internal network and public network. When we use pd mode in tikv, we need to do network mapping,...

Mrart

https://issues.apache.org/jira/browse/FLINK-35129 - Adds option for checkpoint cycle parameter - Commits PG offsets on every multiple of checkpoint cycle - Updates docs with new parameter definition - [TODO] Adds unit &...

morazow