Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations Dong! On Thu, Feb 16, 2023 at 8:47 AM zhouenning wrote: > Congratulations, Dong! Best, Eming > > > 在 2023年2月16日 15:30，Geng Biao 写道： > > > Congrats, Dong! Best, Biao Geng 获取 Outlook for iOS<">https://aka.ms/o0ukef> > 发件人: Rui Fan <1996fan...@gmail.

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congrats, Dong! Best, Biao Geng 获取 Outlook for iOS 发件人: Rui Fan <1996fan...@gmail.com> 发送时间: Thursday, February 16, 2023 3:29:17 PM 收件人: dev@flink.apache.org 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin Congratulations Dong! We

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations Dong! Well deserved~ Best, Rui Fan On Thu, Feb 16, 2023 at 3:27 PM Weihua Hu wrote: > Congratulations Dong! > > Best, > Weihua > > > On Thu, Feb 16, 2023 at 3:24 PM yuxia wrote: > > > Congratulations, Dong! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Junr

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations, Dong! Best, Hang yuxia 于2023年2月16日周四 15:24写道： > Congratulations, Dong! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Junrui Lee" > 收件人: "dev" > 发送时间: 星期四, 2023年 2 月 16日 下午 2:40:39 > 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin > > Congratulations, Dong!

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations Dong! Best, Weihua On Thu, Feb 16, 2023 at 3:24 PM yuxia wrote: > Congratulations, Dong! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Junrui Lee" > 收件人: "dev" > 发送时间: 星期四, 2023年 2 月 16日 下午 2:40:39 > 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin > > Congr

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations, Dong! Best regards, Yuxia - 原始邮件 - 发件人: "Junrui Lee" 收件人: "dev" 发送时间: 星期四, 2023年 2 月 16日 下午 2:40:39 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin Congratulations, Dong! Best, Junrui Guowei Ma 于2023年2月16日周四 14:21写道： > Hi, everyone > > On behalf of th

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations, Dong! Best regards, Juntao Leonard Xu 于2023年2月16日周四 15:16写道： > Congratulations, Dong! > > Best, > Leonard > > > On Feb 16, 2023, at 3:03 PM, Dian Fu wrote: > > > > Congratulations Dong! > > > > Regards, > > Dian > > > > On Thu, Feb 16, 2023 at 2:41 PM Junrui Lee wrote: > > >

[jira] [Created] (FLINK-31099) Chained WindowOperator throws NPE in PyFlink ThreadMode

Huang Xingbo created FLINK-31099: Summary: Chained WindowOperator throws NPE in PyFlink ThreadMode Key: FLINK-31099 URL: https://issues.apache.org/jira/browse/FLINK-31099 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations, Dong! Best, Leonard > On Feb 16, 2023, at 3:03 PM, Dian Fu wrote: > > Congratulations Dong! > > Regards, > Dian > > On Thu, Feb 16, 2023 at 2:41 PM Junrui Lee wrote: > >> Congratulations, Dong! >> >> Best, >> Junrui >> >> Guowei Ma 于2023年2月16日周四 14:21写道： >> >>> Hi, ever

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations Dong! Regards, Dian On Thu, Feb 16, 2023 at 2:41 PM Junrui Lee wrote: > Congratulations, Dong! > > Best, > Junrui > > Guowei Ma 于2023年2月16日周四 14:21写道： > > > Hi, everyone > > > > On behalf of the PMC, I'm very happy to announce Dong Lin as a new > > Flink PMC. > > > > Do

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations, Dong! Best, Junrui Guowei Ma 于2023年2月16日周四 14:21写道： > Hi, everyone > > On behalf of the PMC, I'm very happy to announce Dong Lin as a new > Flink PMC. > > Dong is currently the main driver of Flink ML. He reviewed a large > number of Flink ML related PRs and also partic

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations, Jing! Best, Feng On Thu, Feb 16, 2023 at 2:24 PM Weihua Hu wrote: > > Congratulations, Jing! > > Best, > Weihua > > > On Thu, Feb 16, 2023 at 2:03 PM Dian Fu wrote: > > > Congratulations Jing! > > > > Regards, > > Dian > > > > On Wed, Feb 15, 2023 at 8:04 PM Yun Tang wrote: >

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations, Jing! Best, Weihua On Thu, Feb 16, 2023 at 2:03 PM Dian Fu wrote: > Congratulations Jing! > > Regards, > Dian > > On Wed, Feb 15, 2023 at 8:04 PM Yun Tang wrote: > > > Congratulations, Jing! > > > > Best > > Yun Tang > > > > From: Dong Lin >

[ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Hi, everyone On behalf of the PMC, I'm very happy to announce Dong Lin as a new Flink PMC. Dong is currently the main driver of Flink ML. He reviewed a large number of Flink ML related PRs and also participated in many Flink ML improvements, such as "FLIP-173","FLIP-174" etc. At the same

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations Jing! Regards, Dian On Wed, Feb 15, 2023 at 8:04 PM Yun Tang wrote: > Congratulations, Jing! > > Best > Yun Tang > > From: Dong Lin > Sent: Wednesday, February 15, 2023 19:40 > To: dev@flink.apache.org > Subject: Re: [ANNOUNCE] New Apache Flink

[jira] [Created] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

jackylau created FLINK-31098: Summary: Add ARRAY_SIZE supported in SQL & Table API Key: FLINK-31098 URL: https://issues.apache.org/jira/browse/FLINK-31098 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Release Flink 1.15.4

+1 to release 1.15.4 and Danny as release manager. > On Feb 16, 2023, at 11:31 AM, Rui Fan <1996fan...@gmail.com> wrote: > > +1 > > On Thu, Feb 16, 2023 at 6:51 AM Jing Ge wrote: > >> +1 >> >> On Wed, Feb 15, 2023 at 4:03 PM Konstantin Knauf >> wrote: >> >>> +1 >>> >>> Am Mi., 15. Feb. 202

Re: [DISCUSS] Release Flink 1.15.4

+1 On Thu, Feb 16, 2023 at 6:51 AM Jing Ge wrote: > +1 > > On Wed, Feb 15, 2023 at 4:03 PM Konstantin Knauf > wrote: > > > +1 > > > > Am Mi., 15. Feb. 2023 um 15:21 Uhr schrieb Maximilian Michels < > > m...@apache.org>: > > > > > +1 > > > > > > On Wed, Feb 15, 2023 at 12:32 PM Danny Cranmer < >

[jira] [Created] (FLINK-31097) mysql catalog datatype mapping error tinyint mapping boolean

谢波 created FLINK-31097: -- Summary: mysql catalog datatype mapping error tinyint mapping boolean Key: FLINK-31097 URL: https://issues.apache.org/jira/browse/FLINK-31097 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31096) Unify versions in pom of table store

Shammon created FLINK-31096: --- Summary: Unify versions in pom of table store Key: FLINK-31096 URL: https://issues.apache.org/jira/browse/FLINK-31096 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31095) FileSink doesn't work with s3a on EKS

Sylvia Lin created FLINK-31095: -- Summary: FileSink doesn't work with s3a on EKS Key: FLINK-31095 URL: https://issues.apache.org/jira/browse/FLINK-31095 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-31094) Add table name to write operator

DaiXinyu created FLINK-31094: Summary: Add table name to write operator Key: FLINK-31094 URL: https://issues.apache.org/jira/browse/FLINK-31094 Project: Flink Issue Type: Improvement C

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

Hi all Thanks for all the feedback. If there are no more questions related to this FLIP, we'd like to start the next work. After discussed with @JingsongLee, we will create some FLIPs to provide detailed design for `MetaService` and `Timestamp Barrier Mechanism`. Please feel free to comment in thi

Re: [DISCUSS] Release Flink 1.15.4

+1 On Wed, Feb 15, 2023 at 4:03 PM Konstantin Knauf wrote: > +1 > > Am Mi., 15. Feb. 2023 um 15:21 Uhr schrieb Maximilian Michels < > m...@apache.org>: > > > +1 > > > > On Wed, Feb 15, 2023 at 12:32 PM Danny Cranmer > > wrote: > > > > > > Hi all, > > > > > > I would like to discuss creating a n

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1

Yes, that is correct, thank you for catching that Jim! Everyone: Please check https://repository.apache.org/content/repositories/orgapacheflink-1583/ for the maven artifacts :) Gyula On Wed, Feb 15, 2023 at 7:02 PM Jim Busche wrote: > Hi Gyula, > I’m noticing that the link for “All artifacts f

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1

Hi Gyula, I’m noticing that the link for “All artifacts for c) can be found at the Apache Nexus Repository [2]” Might be https://repository.apache.org/content/repositories/orgapacheflink-1583/ And not https://repository.apache.org/content/repositories/orgapacheflink-1582/ Thanks, Jim

[jira] [Created] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint

Matthias Pohl created FLINK-31093: - Summary: NullpointerException when restoring a FlinkSQL job from a savepoint Key: FLINK-31093 URL: https://issues.apache.org/jira/browse/FLINK-31093 Project: Flink

[VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.4.0 of Apache Flink Kubernetes Operator, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of th

Re: [DISCUSS] Release Flink 1.15.4

+1 Am Mi., 15. Feb. 2023 um 15:21 Uhr schrieb Maximilian Michels < m...@apache.org>: > +1 > > On Wed, Feb 15, 2023 at 12:32 PM Danny Cranmer > wrote: > > > > Hi all, > > > > I would like to discuss creating a new 1.15 patch release (1.15.4). The > > last 1.15 release is over three months old, an

[jira] [Created] (FLINK-31092) Hive ITCases fail with OutOfMemoryError

Matthias Pohl created FLINK-31092: - Summary: Hive ITCases fail with OutOfMemoryError Key: FLINK-31092 URL: https://issues.apache.org/jira/browse/FLINK-31092 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31091) SQL interval related queries stop working via SQL client

Sergey Nuyanzin created FLINK-31091: --- Summary: SQL interval related queries stop working via SQL client Key: FLINK-31091 URL: https://issues.apache.org/jira/browse/FLINK-31091 Project: Flink

Re: [DISCUSS] FLIP-291: Externalized Declarative Resource Management

I missed that the FLIP states: > Currently, even though we’d expose the lower bound for clarity and API > completeness, we won’t allow setting it to any other value than one until we > have full support throughout the stack. How hard would it be to address this issue in the FLIP? There is not

Re: [DISCUSS] Release Flink 1.15.4

+1 On Wed, Feb 15, 2023 at 12:32 PM Danny Cranmer wrote: > > Hi all, > > I would like to discuss creating a new 1.15 patch release (1.15.4). The > last 1.15 release is over three months old, and since then, 43 tickets have > been closed [1], of which 13 are blocker/critical [2]. Given that Flink

[jira] [Created] (FLINK-31090) Flink fail to select INTERVAL

luoyuxia created FLINK-31090: Summary: Flink fail to select INTERVAL Key: FLINK-31090 URL: https://issues.apache.org/jira/browse/FLINK-31090 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-31089) pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit

xiaogang zhou created FLINK-31089: - Summary: pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit Key: FLINK-31089 URL: https://issues.apache.org/jira/browse/FLINK-31089

Re: Looking for a jira to get started with contributing

Yeah, or it's also easy to miss notifications for jira updates, therefore I followed some advice from a Flink committer to ask here on the dev list too. Anway, I now got FLINK-25325 assigned and I am getting started on it. Thanks @Chesnay for assigning! Best, Jörn On Wed, Feb 15, 2023 at 12:38

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations, Jing! Best Yun Tang From: Dong Lin Sent: Wednesday, February 15, 2023 19:40 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge Congratulations Jing! On Wed, Feb 15, 2023 at 12:48 PM Shiwei Wang wrote: > Cong

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations Weijie! On Mon, Feb 13, 2023 at 11:45 AM Xintong Song wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Weijie Guo as a new Flink > committer. > > Weijie has been consistently contributing to the project for over 1 year. > He mainly works on Flink runtime

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations Jing! On Wed, Feb 15, 2023 at 12:48 PM Shiwei Wang wrote: > Congratulations Jing! > > > > > 在 2023年2月14日，16:00，weijie guo 写道： > > > > Congratulations Jing! >

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations JingGe! Best Regards, Ran Tao Shiwei Wang 于2023年2月15日周三 12:48写道： > Congratulations Jing! > > > > > 在 2023年2月14日，16:00，weijie guo 写道： > > > > Congratulations Jing! >

Re: Looking for a jira to get started with contributing

Fair enough. Contributors might not be responsive right away (due to holiday or being occupied with other tasks) or might miss responding accidentally. But usually, if you're interested in working on a specific issue, commenting on it is the proper way to do it, I guess. Feel free to go through sta

[DISCUSS] Release Flink 1.15.4

Hi all, I would like to discuss creating a new 1.15 patch release (1.15.4). The last 1.15 release is over three months old, and since then, 43 tickets have been closed [1], of which 13 are blocker/critical [2]. Given that Flink 1.17 is on the horizon, it will be good to release critical bug fixes

[jira] [Created] (FLINK-31088) Flink free for flink-table-store-docs

Shammon created FLINK-31088: --- Summary: Flink free for flink-table-store-docs Key: FLINK-31088 URL: https://issues.apache.org/jira/browse/FLINK-31088 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-31087) Introduce InsertChangesAction.

yuzelin created FLINK-31087: --- Summary: Introduce InsertChangesAction. Key: FLINK-31087 URL: https://issues.apache.org/jira/browse/FLINK-31087 Project: Flink Issue Type: New Feature Compon

Re: Re: Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name

Hello Dawid, I created a pull request based on your suggestion. https://github.com/apache/flink/pull/21942 I'd appreciate it if you could have a look at it. Thanks in advance. Best regards, Fruzsina On Mon, Feb 6, 2023 at 11:34 AM Fruzsina Nagy wrote: > Hi Dawid, > Thanks for the suggestion, it’

[jira] [Created] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

hehuiyuan created FLINK-31086: - Summary: [DOC]update connector lable for blackhole and kafka Key: FLINK-31086 URL: https://issues.apache.org/jira/browse/FLINK-31086 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31085) Add schema option to confluent registry avro formats

Ferenc Csaky created FLINK-31085: Summary: Add schema option to confluent registry avro formats Key: FLINK-31085 URL: https://issues.apache.org/jira/browse/FLINK-31085 Project: Flink Issue Ty

[jira] [Created] (FLINK-31084) DataGen sequence generator requires the definition of start/end values

Matthias Pohl created FLINK-31084: - Summary: DataGen sequence generator requires the definition of start/end values Key: FLINK-31084 URL: https://issues.apache.org/jira/browse/FLINK-31084 Project: Fli

[jira] [Created] (FLINK-31083) Python ProcessFunction with OutputTag cannot be reused

Juntao Hu created FLINK-31083: - Summary: Python ProcessFunction with OutputTag cannot be reused Key: FLINK-31083 URL: https://issues.apache.org/jira/browse/FLINK-31083 Project: Flink Issue Type:

Re: Looking for a jira to get started with contributing

Hello, Thanks for the hint, I actually commented on that issue first and also on FLINK-25325. Maybe I should try to look for some issues labeled as "starter" and comment on one of those. Best, Jörn On Wed, Feb 15, 2023 at 9:17 AM Matthias Pohl wrote: > Hi Joern, > you might have more luck wit

[jira] [Created] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

Yunhong Zheng created FLINK-31082: - Summary: Setting maven property 'flink.resueForks' to false in table planner module Key: FLINK-31082 URL: https://issues.apache.org/jira/browse/FLINK-31082 Project

Re: Looking for a jira to get started with contributing

Hi Joern, you might have more luck with getting responses to specific tickets by commenting in the corresponding Jira issue. If you haven't created an Apache Jira account, yet: There's documentation on how to gain access in the community docs [1]. Best, Matthias [1] https://flink.apache.org/commu

[jira] [Created] (FLINK-31081) Update Jira links in How To Contribute guide

Matthias Pohl created FLINK-31081: - Summary: Update Jira links in How To Contribute guide Key: FLINK-31081 URL: https://issues.apache.org/jira/browse/FLINK-31081 Project: Flink Issue Type: Bu