Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-28 Thread Shengkai Fang
Hi, HongShun. Thanks a lot for your response! > I wonder what is the scope of this FLIP, only aim for k8s, not including yarn? This FLIP also works for the yarn-application mode. But the yarn deployment doesn't support to ship the artifacts into the remote side. Please correct me if I'm wrong. >

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-28 Thread Shengkai Fang
Hi, Feng. Thanks for your response. > Will FLIP-316 merge into Flink 2.0 too ? I don't have time to finish the FLIP-316. So it depends on whether anyone else can help to continue the discussion. > Will SqlDriver use the same one? Yes. We should reuse the same driver. I think the driver is the

[jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

2024-10-28 Thread linqigeng (Jira)
linqigeng created FLINK-36619: - Summary: Downstream lost the CreateTableEvent when tables were removed and then re-added Key: FLINK-36619 URL: https://issues.apache.org/jira/browse/FLINK-36619 Project: Fl

[jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC

2024-10-28 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-36618: - Summary: Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC Key: FLINK-36618 URL: https://issues.apache.org/jira/browse/FLINK-36618

[jira] [Created] (FLINK-36617) Migrate kryo package

2024-10-28 Thread Siddharth R (Jira)
Siddharth R created FLINK-36617: --- Summary: Migrate kryo package Key: FLINK-36617 URL: https://issues.apache.org/jira/browse/FLINK-36617 Project: Flink Issue Type: Improvement Report

[jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig

2024-10-28 Thread Jira
Radosław Stankiewicz created FLINK-36616: Summary: Null pointer in PubSub's GcpPublisherConfig Key: FLINK-36616 URL: https://issues.apache.org/jira/browse/FLINK-36616 Project: Flink

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

2024-10-28 Thread Ferenc Csaky
Hi, Based on this discussion I would like to suggest to move on with the originally planned release with the HBase connector 4.0, that will support 1.18, and 1.19. I volunteer to be the release manager. Thanks, Ferenc On Wednesday, October 23rd, 2024 at 13:19, Ferenc Csaky wrote: > > > H

[jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API

2024-10-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-36615: Summary: Support LEAD/LAG functions in Table API Key: FLINK-36615 URL: https://issues.apache.org/jira/browse/FLINK-36615 Project: Flink Issue Type: I

[jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase

2024-10-28 Thread Youle (Jira)
Youle created FLINK-36614: - Summary: mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase Key: FLINK-36614 URL: https://issues.apache.org/jira/browse/FLINK-36614 Project: Flink

[jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

2024-10-28 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36613: --- Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP Key: FLINK-36613 URL: https://issues.apache.org/jira/browse/FLINK-36613

[jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok

2024-10-28 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36612: --- Summary: Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok Key: FLINK-36612 URL: https://issues.apache.org/jira/browse/FLINK-36612

[jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink

2024-10-28 Thread LvYanquan (Jira)
LvYanquan created FLINK-36611: - Summary: Add schema info to output of Kafka sink Key: FLINK-36611 URL: https://issues.apache.org/jira/browse/FLINK-36611 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes

2024-10-28 Thread yux (Jira)
yux created FLINK-36610: --- Summary: MySQL CDC supports parsing gh-ost generated schema changes Key: FLINK-36610 URL: https://issues.apache.org/jira/browse/FLINK-36610 Project: Flink Issue Type: Improvem

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-28 Thread Hang Ruan
Hi, Yanquan. +1 for supporting two minor flink version. Supporting too many Flink versions is a hard work. We could support two last minor flink version like the external connectors did[1]. Best, Hang [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=231116690#ExternalizedConn

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-28 Thread Leonard Xu
+1 from my side, supporting two minor flink version(1.19.* & 1.120.*) makes sense to me. Best, Leonard > 2024年10月17日 下午1:58,ConradJam 写道: > > I am currently working on the Iceberg CDC Pipeline Connector, and support > for it would be ideal, as the Iceberg Flink Connector already supports > Sin