[jira] [Created] (FLINK-36150) tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true.

2024-08-25 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-36150: - Summary: tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true. Key: FLINK-36150 URL: https://issues.apache.org/jira/browse/FLINK-36150 Proje

Re: Flink CDC insert-only changelog mode

2024-08-25 Thread Hongshun Wang
Hi Daniel, > The changelog type needs to be insert-only to invoke the correct streaming planner rules. I mean that we can read all kind of data from mysql(insert, upsert, delete) as +I[optype, xxx] in flink (such as +I[insert, 1, 'a'], +I[delete, 2, null]). If downstream only needs +[insert, xx

[jira] [Created] (FLINK-36151) Add documentations for Schema Evolution related options

2024-08-25 Thread yux (Jira)
yux created FLINK-36151: --- Summary: Add documentations for Schema Evolution related options Key: FLINK-36151 URL: https://issues.apache.org/jira/browse/FLINK-36151 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36152) Traverse through the superclass hierarchy to extract generic type.

2024-08-25 Thread Xinglong Wang (Jira)
Xinglong Wang created FLINK-36152: - Summary: Traverse through the superclass hierarchy to extract generic type. Key: FLINK-36152 URL: https://issues.apache.org/jira/browse/FLINK-36152 Project: Flink

[jira] [Created] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode

2024-08-25 Thread yux (Jira)
yux created FLINK-36153: --- Summary: MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode Key: FLINK-36153 URL: https://issues.apache.org/jira/browse/FLINK-36153 Project: Flink