[jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x

2024-10-22 Thread yux (Jira)
yux created FLINK-36590: --- Summary: Flink CDC does not Support MySQL > 8.0.x Key: FLINK-36590 URL: https://issues.apache.org/jira/browse/FLINK-36590 Project: Flink Issue Type: Improvement Comp

Re: [DISCUSS] Flink external connector bump version

2024-10-22 Thread Yanquan Lv
Hi, Hang. I think what you're actually trying to say is Kudu & HBase & RabbitMQ. 1. For Hbase, I see there is a pr to bump 1.18 and support 1.18/1.19, We are currently discussing in the community[2] whether to show support for adding 1.20. 2. For RabbitMQ, I see there is a pr to bump 1.19[3] and

[jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend

2024-10-22 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36589: --- Summary: Decouple the initialization of sync and async keyed statebackend Key: FLINK-36589 URL: https://issues.apache.org/jira/browse/FLINK-36589 Project: Flink

[jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml

2024-10-22 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-36588: --- Summary: flink catalog is supported in cdc yaml Key: FLINK-36588 URL: https://issues.apache.org/jira/browse/FLINK-36588 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Release HBase connector with partial JDK support

2024-10-22 Thread Yanquan Lv
> 2. Currently supporting Flink1.17 is difficult, but are there any plans to > support it in the future? Do we need to wait for Hadoop related repositories > to release specific versions. Flink1.17 => JDK17 > 2024年10月23日 11:19,Yanquan Lv 写道: > > Hi Feri, > Thank you for bringing up this discu

Re: [DISCUSS] Release HBase connector with partial JDK support

2024-10-22 Thread Yanquan Lv
Hi Feri, Thank you for bringing up this discussion. I agree to release a version to bump the newer version of Flink with partial JDK versions support. I have two points to be discussed. 1. I have heard many inquiries about supporting higher versions of Flink in Slack, Chinese communities, etc., a

[jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class

2024-10-22 Thread Anil Dasari (Jira)
Anil Dasari created FLINK-36587: --- Summary: Postgres-cdc: Add support to override connector.class Key: FLINK-36587 URL: https://issues.apache.org/jira/browse/FLINK-36587 Project: Flink Issue Ty

[jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+

2024-10-22 Thread ZhengYu Chen (Jira)
ZhengYu Chen created FLINK-36586: Summary: Upgrade Flink CDC dependency to Flink 1.19+ Key: FLINK-36586 URL: https://issues.apache.org/jira/browse/FLINK-36586 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.

2024-10-22 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-36585: Summary: The SplitFetcherManager.close() can chain the futures in a tight loop. Key: FLINK-36585 URL: https://issues.apache.org/jira/browse/FLINK-36585 Project: Flink

[jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

2024-10-22 Thread Anil Dasari (Jira)
Anil Dasari created FLINK-36584: --- Summary: PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots Key: FLINK-36584 URL: https://issues.apac

[jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics

2024-10-22 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-36583: - Summary: Add Slow Request Kube Client Metrics Key: FLINK-36583 URL: https://issues.apache.org/jira/browse/FLINK-36583 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-36582) sql client hang when querying a parquet table

2024-10-22 Thread Lu Niu (Jira)
Lu Niu created FLINK-36582: -- Summary: sql client hang when querying a parquet table Key: FLINK-36582 URL: https://issues.apache.org/jira/browse/FLINK-36582 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Release HBase connector with partial JDK support

2024-10-22 Thread Márton Balassi
Hi Feri, Thanks for carefully considering this situation. I agree with your proposal that it is best to provide an HBase connector release with partial JDK support for the time being, and list the limitations in the Java compatibility docs. On a partially related note this highlights that the com

[DISCUSS] Release HBase connector with partial JDK support

2024-10-22 Thread Ferenc Csaky
Hello devs, I would like to start a discussion regarding a new HBase connector release. Currently, the externalized HBase connector has only 1 release: 3.0.0 that supports Flink 1.16 and 1.17. By stating this, it is obvious that the connector is already outdated for quite a while. There is a l

[jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters

2024-10-22 Thread LvYanquan (Jira)
LvYanquan created FLINK-36581: - Summary: Allow passing Flink configuration by yaml job file or command line parameters Key: FLINK-36581 URL: https://issues.apache.org/jira/browse/FLINK-36581 Project: Flin

[jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure

2024-10-22 Thread MOBIN (Jira)
MOBIN created FLINK-36580: - Summary: Using debezium.column.exclude.list causes job failure Key: FLINK-36580 URL: https://issues.apache.org/jira/browse/FLINK-36580 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare.

2024-10-22 Thread LIU (Jira)
LIU created FLINK-36579: --- Summary: mysql cdc charset collation sort not equals java string compare. Key: FLINK-36579 URL: https://issues.apache.org/jira/browse/FLINK-36579 Project: Flink Issue Type: I