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.
>
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
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
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
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
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
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
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
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
Sergey Nuyanzin created FLINK-36613:
---
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP
Key: FLINK-36613
URL: https://issues.apache.org/jira/browse/FLINK-36613
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
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
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
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
+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
15 matches
Mail list logo