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
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
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
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
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
Ruan Hang created FLINK-37905:
-
Summary: Transform will throw exceptions when handling chinese
characters
Key: FLINK-37905
URL: https://issues.apache.org/jira/browse/FLINK-37905
Project: Flink
Ruan Hang created FLINK-38057:
-
Summary: Connector emit time lag may be a wrong value
Key: FLINK-38057
URL: https://issues.apache.org/jira/browse/FLINK-38057
Project: Flink
Issue Type: Bug
