[jira] [Created] (FLINK-36879) CDC yaml transform supports to convert delete as insert

Ruan Hang created FLINK-36879: - Summary: CDC yaml transform supports to convert delete as insert Key: FLINK-36879 URL: https://issues.apache.org/jira/browse/FLINK-36879 Project: Flink Issue Type

[jira] [Created] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector

Ruan Hang created FLINK-36878: - Summary: Shade kafka dependency in cdc yaml with the same path as sql connector Key: FLINK-36878 URL: https://issues.apache.org/jira/browse/FLINK-36878 Project: Flink

[jira] [Created] (FLINK-36803) Use fixed format for splitId in all connectors

Ruan Hang created FLINK-36803: - Summary: Use fixed format for splitId in all connectors Key: FLINK-36803 URL: https://issues.apache.org/jira/browse/FLINK-36803 Project: Flink Issue Type

[jira] [Created] (FLINK-36784) Support to add metadata columns for data in the meta fields of DataChangeEvent at transform

Ruan Hang created FLINK-36784: - Summary: Support to add metadata columns for data in the meta fields of DataChangeEvent at transform Key: FLINK-36784 URL: https://issues.apache.org/jira/browse/FLINK-36784

回复: [DISCUSS] Reverting sink metric name changes made in 1.15

Thanks for raising the discussion, Qingsheng, +1 on reverting the breaking changes. +1 for making a unified and clearer metric definition in Flink 2.0 Best, Hang 发件人: Jing Ge 发送时间: 2022年10月12日 19:20 收件人: Qingsheng Ren 抄送: Chesnay Schepler ; dev ; user ; Martij