[jira] [Created] (FLINK-31652) Flink should handle the delete event if the pod was deleted while pending

xingbe created FLINK-31652: -- Summary: Flink should handle the delete event if the pod was deleted while pending Key: FLINK-31652 URL: https://issues.apache.org/jira/browse/FLINK-31652 Project: Flink

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Yangze Guo On Wed, Mar 29, 2023 at 1:57 PM Sergey Nuyanzin wrote: > > Congratulations! > > On Wed, Mar 29, 2023 at 4:11 AM Zhu Zhu wrote: > > > Congratulations! > > > > Cheers, > > Zhu > > > > Jing Zhang 于2023年3月28日周二 23:56写道： > > > > > > Congratulations! > > > > > > Bes

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! On Wed, Mar 29, 2023 at 4:11 AM Zhu Zhu wrote: > Congratulations! > > Cheers, > Zhu > > Jing Zhang 于2023年3月28日周二 23:56写道： > > > > Congratulations! > > > > Best, > > Jing Zhang > > > > Rui Fan <1996fan...@gmail.com> 于2023年3月28日周二 22:25写道： > > > > > Congratulations! > > > > > > B

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

Thanks Jane driving this flip! And very glad to see the lively discussion which has inspired me a lot! I'd like to share some thoughts: as many of you mentioned, FLIP-113[1] formally introduced the Calcite's hints syntax and supported the dynamic table option(i.e., table hints), and then FLIP-229

[jira] [Created] (FLINK-31651) Improve logging of granting/revoking leadership in JobMasterServiceLeadershipRunner to INFO level

Lijie Wang created FLINK-31651: -- Summary: Improve logging of granting/revoking leadership in JobMasterServiceLeadershipRunner to INFO level Key: FLINK-31651 URL: https://issues.apache.org/jira/browse/FLINK-31651

[jira] [Created] (FLINK-31650) Incorrect busyMsTimePerSecond metric value for FINISHED task

Lijie Wang created FLINK-31650: -- Summary: Incorrect busyMsTimePerSecond metric value for FINISHED task Key: FLINK-31650 URL: https://issues.apache.org/jira/browse/FLINK-31650 Project: Flink Iss

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Cheers, Zhu Jing Zhang 于2023年3月28日周二 23:56写道： > > Congratulations! > > Best, > Jing Zhang > > Rui Fan <1996fan...@gmail.com> 于2023年3月28日周二 22:25写道： > > > Congratulations! > > > > Best, > > Rui Fan > > > > On Tue, Mar 28, 2023 at 15:37 Guowei Ma wrote: > > > > > Congratulations!

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Jing Zhang Rui Fan <1996fan...@gmail.com> 于2023年3月28日周二 22:25写道： > Congratulations! > > Best, > Rui Fan > > On Tue, Mar 28, 2023 at 15:37 Guowei Ma wrote: > > > Congratulations! > > > > Best, > > Guowei > > > > > > On Tue, Mar 28, 2023 at 12:02 PM Yuxin Tan > wrote: > >

[jira] [Created] (FLINK-31649) [Connectors / JDBC] Fix archunit violations

João Boto created FLINK-31649: - Summary: [Connectors / JDBC] Fix archunit violations Key: FLINK-31649 URL: https://issues.apache.org/jira/browse/FLINK-31649 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

Hi Jane, Thanks for creating the FLIP. In general I'm not a fan of using the query plan for enabling these kinds of use cases. It introduces a different way of submitting SQL jobs in our already extensive list of possibilities, making things complicated. I would have a preference for using hints,

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Rui Fan On Tue, Mar 28, 2023 at 15:37 Guowei Ma wrote: > Congratulations! > > Best, > Guowei > > > On Tue, Mar 28, 2023 at 12:02 PM Yuxin Tan wrote: > >> Congratulations！ >> >> Best, >> Yuxin >> >> >> Guanghui Zhang 于2023年3月28日周二 11:06写道： >> >>> Congratulations！ >>> >>>

Re: [VOTE] Release flink-connector-mongodb, release candidate #1

+1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 28 Mar 2023, at 12:56, Samrat Deb wrote: > > CAUTION: This e

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi Panagiotis, How about to introduce a config option to control which error handling plugins should be used? It is more flexible for deployments. Additionally, it can also enable users to explicitly specify the order that the plugins take effects. Thanks, Zhu Gen Luo 于2023年3月27日周一 15:02写道： > >

Re: [VOTE] Release flink-connector-mongodb, release candidate #1

+1 (non-binding) - checked Source archive builds using maven - verified Hashes and Signatures - verified Tag is present in Github - checked dist.apache.org, required files present - verified source archive Bests, Samrat On Mon, Mar 20, 2023 at 2:08 PM Leonard Xu wrote: > > > + 1 (non-

Re: [VOTE] Release flink-connector-aws 4.1.0, release candidate #1

+1 (non-binding) - checked Source archive builds using maven - verified Hashes and Signatures - verified Tag is present in Github - checked dist.apache.org, required files present - verified source archive Bests, Samrat On Tue, Mar 28, 2023 at 5:12 PM Teoh, Hong wrote: > +1 (non-binding) >

Re: [VOTE] FLIP-284: Making AsyncSinkWriter Flush triggers adjustable

Thank you Ahmed for driving the change. This new feature will help flink developers with more control on their job in SinkWriter. +1 (non binding) Bests, Samrat On Mon, Mar 27, 2023 at 12:34 PM Danny Cranmer wrote: > Thanks for driving this Ahmed. This change will benefit future and current

Re: [VOTE] Release flink-connector-aws 4.1.0, release candidate #1

+1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 22 Mar 2023, at 07:21, Robert Metzger wrote: > > CAUTION: Thi

[jira] [Created] (FLINK-31648) Elasticsearch supports retrying writes when concurrency issues occur

陈磊 created FLINK-31648: -- Summary: Elasticsearch supports retrying writes when concurrency issues occur Key: FLINK-31648 URL: https://issues.apache.org/jira/browse/FLINK-31648 Project: Flink Issue Type:

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Guowei On Tue, Mar 28, 2023 at 12:02 PM Yuxin Tan wrote: > Congratulations！ > > Best, > Yuxin > > > Guanghui Zhang 于2023年3月28日周二 11:06写道： > >> Congratulations！ >> >> Best, >> Zhang Guanghui >> >> Hang Ruan 于2023年3月28日周二 10:29写道： >> >> > Congratulations! >> > >> > Best,

[jira] [Created] (FLINK-31647) Introduce remote storage tier reader

Yuxin Tan created FLINK-31647: - Summary: Introduce remote storage tier reader Key: FLINK-31647 URL: https://issues.apache.org/jira/browse/FLINK-31647 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31646) Introduce remote storage tier

Yuxin Tan created FLINK-31646: - Summary: Introduce remote storage tier Key: FLINK-31646 URL: https://issues.apache.org/jira/browse/FLINK-31646 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-31644) Introduce disk tier

Yuxin Tan created FLINK-31644: - Summary: Introduce disk tier Key: FLINK-31644 URL: https://issues.apache.org/jira/browse/FLINK-31644 Project: Flink Issue Type: Sub-task Components: Runt

[jira] [Created] (FLINK-31645) Introduce disk tier reader

Yuxin Tan created FLINK-31645: - Summary: Introduce disk tier reader Key: FLINK-31645 URL: https://issues.apache.org/jira/browse/FLINK-31645 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-31643) Introduce a temporary switch to enable the new shuffle implementation

Yuxin Tan created FLINK-31643: - Summary: Introduce a temporary switch to enable the new shuffle implementation Key: FLINK-31643 URL: https://issues.apache.org/jira/browse/FLINK-31643 Project: Flink

[jira] [Created] (FLINK-31641) Introduce memory tier

Yuxin Tan created FLINK-31641: - Summary: Introduce memory tier Key: FLINK-31641 URL: https://issues.apache.org/jira/browse/FLINK-31641 Project: Flink Issue Type: Sub-task Components: Ru

[jira] [Created] (FLINK-31642) Introduce memory tier reader

Yuxin Tan created FLINK-31642: - Summary: Introduce memory tier reader Key: FLINK-31642 URL: https://issues.apache.org/jira/browse/FLINK-31642 Project: Flink Issue Type: Sub-task Compone

[jira] [Created] (FLINK-31640) Introduce segment index tracker

Yuxin Tan created FLINK-31640: - Summary: Introduce segment index tracker Key: FLINK-31640 URL: https://issues.apache.org/jira/browse/FLINK-31640 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-31639) Introduce tiered store memory manager

Yuxin Tan created FLINK-31639: - Summary: Introduce tiered store memory manager Key: FLINK-31639 URL: https://issues.apache.org/jira/browse/FLINK-31639 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31638) Downstream supports reading buffers from tiered store

Yuxin Tan created FLINK-31638: - Summary: Downstream supports reading buffers from tiered store Key: FLINK-31638 URL: https://issues.apache.org/jira/browse/FLINK-31638 Project: Flink Issue Type: S

[jira] [Created] (FLINK-31637) Introduce buffer accumulator tier

Yuxin Tan created FLINK-31637: - Summary: Introduce buffer accumulator tier Key: FLINK-31637 URL: https://issues.apache.org/jira/browse/FLINK-31637 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-31636) Upstream supports reading buffers from tiered store

Yuxin Tan created FLINK-31636: - Summary: Upstream supports reading buffers from tiered store Key: FLINK-31636 URL: https://issues.apache.org/jira/browse/FLINK-31636 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-31635) Support writing records to the new tiered store architecture

Yuxin Tan created FLINK-31635: - Summary: Support writing records to the new tiered store architecture Key: FLINK-31635 URL: https://issues.apache.org/jira/browse/FLINK-31635 Project: Flink Issue