[jira] [Created] (FLINK-34634) Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed

2024-03-08 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-34634: - Summary: Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed Key: FLINK-34634

[jira] [Created] (FLINK-34633) Support unnesting array constants

2024-03-08 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-34633: --- Summary: Support unnesting array constants Key: FLINK-34633 URL: https://issues.apache.org/jira/browse/FLINK-34633 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-08 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34632: - Summary: Log checkpoint Id when logging checkpoint processing delay Key: FLINK-34632 URL: https://issues.apache.org/jira/browse/FLINK-34632 Project: Flink

Re: [DISCUSS] FLIP Suggestion: Externalize Kudu Connector from Bahir

2024-03-08 Thread Ferenc Csaky
Thank you Jeyhun, Leonard, and Hang for your comments! Let me address them from earliest to latest. > How do you plan the review process in this case (e.g. incremental over existing codebase or cumulative all at once) ? I think incremental would be less time consuming and complex for reviewers

[jira] [Created] (FLINK-34631) Memory leak in pyflink when using state with RocksDB

2024-03-08 Thread Mark Lidenberg (Jira)
Mark Lidenberg created FLINK-34631: -- Summary: Memory leak in pyflink when using state with RocksDB Key: FLINK-34631 URL: https://issues.apache.org/jira/browse/FLINK-34631 Project: Flink

[jira] [Created] (FLINK-34630) Pulsar source lost topic subscribe

2024-03-08 Thread WangMinChao (Jira)
WangMinChao created FLINK-34630: --- Summary: Pulsar source lost topic subscribe Key: FLINK-34630 URL: https://issues.apache.org/jira/browse/FLINK-34630 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34629) Pulsar source lost topic subscribe

2024-03-08 Thread WangMinChao (Jira)
WangMinChao created FLINK-34629: --- Summary: Pulsar source lost topic subscribe Key: FLINK-34629 URL: https://issues.apache.org/jira/browse/FLINK-34629 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34628) Pulsar source lost topic subscribe

2024-03-08 Thread WangMinChao (Jira)
WangMinChao created FLINK-34628: --- Summary: Pulsar source lost topic subscribe Key: FLINK-34628 URL: https://issues.apache.org/jira/browse/FLINK-34628 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34626) Pulsar source lost topic subscribe

2024-03-08 Thread WangMinChao (Jira)
WangMinChao created FLINK-34626: --- Summary: Pulsar source lost topic subscribe Key: FLINK-34626 URL: https://issues.apache.org/jira/browse/FLINK-34626 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34627) Pulsar source lost topic subscribe

2024-03-08 Thread WangMinChao (Jira)
WangMinChao created FLINK-34627: --- Summary: Pulsar source lost topic subscribe Key: FLINK-34627 URL: https://issues.apache.org/jira/browse/FLINK-34627 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34625) TTL doesn't seem to work in pyflink

2024-03-08 Thread Mark Lidenberg (Jira)
Mark Lidenberg created FLINK-34625: -- Summary: TTL doesn't seem to work in pyflink Key: FLINK-34625 URL: https://issues.apache.org/jira/browse/FLINK-34625 Project: Flink Issue Type: Bug

Re: [DISCUSS] Externalized Google Cloud Connectors

2024-03-08 Thread Martijn Visser
Hi Claire, I don't think it's a good idea to actually develop outside of Apache; contributions that have happened outside of the Apache realm do not play a role when evaluating potential new committers. I think the best course of action would be to create a FLIP to add these connectors to the

Re: [DISCUSS] FLIP-419: Optimize multi-sink query plan generation

2024-03-08 Thread Martijn Visser
Hi Jeyhun Karimov, I see that you've already opened up a VOTE thread, but since you're talking about having a prototype already and results, I wondered if you could include the POC and how you've tested these results in the FLIP? Best regards, Martijn On Tue, Jan 30, 2024 at 4:47 AM Jeyhun

Re: [DISCUSS] Add "Special Thanks" Page on the Flink Website

2024-03-08 Thread Martijn Visser
Hi all, I'm +1 on it. As long as we follow the ASF rules on this, we can thank those that are/have made contributions. Best regards, Martijn On Wed, Mar 6, 2024 at 7:45 AM Jark Wu wrote: > Hi Matthias, > > Thanks for your comments! Please see my reply inline. > > > What do we do if we have

Re: [DISCUSS] Support the Ozone Filesystem

2024-03-08 Thread Martijn Visser
Hi Ferenc, I'm +0: I have seen no demand for Ozone, but if the community is OK with it, why not. Best regards, Martijn On Mon, Feb 26, 2024 at 6:08 AM Ferenc Csaky wrote: > Hi, > > gentle reminder on this thread, any opinions or thoughts? > > Regards, > Ferenc > > > > > On Thursday, February

[jira] [Created] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

2024-03-08 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-34624: -- Summary: Enable local recovery in ChangelogRescalingITCase Key: FLINK-34624 URL: https://issues.apache.org/jira/browse/FLINK-34624 Project: Flink Issue Type:

Re: [DISCUSS] FLIP Suggestion: Externalize Kudu Connector from Bahir

2024-03-08 Thread Hang Ruan
Hi, Ferenc. Thanks for the FLIP discussion. +1 for the proposal. I think that how to state this code originally lived in Bahir may be in the FLIP. Best, Hang Leonard Xu 于2024年3月7日周四 14:14写道: > Thanks Ferenc for kicking off this discussion, I left some comments here: > > (1) About the release

[jira] [Created] (FLINK-34623) Flink creating main.jar files in jobmanager jars upload folder

2024-03-08 Thread Nikhil_D (Jira)
Nikhil_D created FLINK-34623: Summary: Flink creating main.jar files in jobmanager jars upload folder Key: FLINK-34623 URL: https://issues.apache.org/jira/browse/FLINK-34623 Project: Flink