[jira] [Created] (FLINK-22409) Rename ResourceProfile class throwUnsupportedOperationExecptionIfUnknown method

2021-04-22 Thread simenliuxing (Jira)
simenliuxing created FLINK-22409: Summary: Rename ResourceProfile class throwUnsupportedOperationExecptionIfUnknown method Key: FLINK-22409 URL: https://issues.apache.org/jira/browse/FLINK-22409

[jira] [Created] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

2021-04-22 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-22405: --- Summary: Support fixed-lengh chars in the LeadLag built-in function Key: FLINK-22405 URL: https://issues.apache.org/jira/browse/FLINK-22405 Project: Flink

[jira] [Created] (FLINK-22406) ReactiveModeITCase.testScaleDownOnTaskManagerLoss()

2021-04-22 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22406: Summary: ReactiveModeITCase.testScaleDownOnTaskManagerLoss() Key: FLINK-22406 URL: https://issues.apache.org/jira/browse/FLINK-22406 Project: Flink Issue

[jira] [Created] (FLINK-22407) upgrade log4j to 2.14

2021-04-22 Thread Svend Vanderveken (Jira)
Svend Vanderveken created FLINK-22407: - Summary: upgrade log4j to 2.14 Key: FLINK-22407 URL: https://issues.apache.org/jira/browse/FLINK-22407 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22410) "Resuming Savepoint (rocks, scale up, heap timers)" fails with BindException

2021-04-22 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22410: Summary: "Resuming Savepoint (rocks, scale up, heap timers)" fails with BindException Key: FLINK-22410 URL: https://issues.apache.org/jira/browse/FLINK-22410

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Shengkai Fang
Congratulations Rui! =-= Best, Shengkai Leonard Xu 于2021年4月22日周四 下午3:09写道: > Congratulations Rui Li ! > > Best, > Leonard > > > 在 2021年4月22日,14:43,Benchao Li 写道: > > > > Congratulations Rui! > > > > Jingsong Li 于2021年4月22日周四 下午2:33写道: > > > >> Congratulations Rui! > >> > >> Best, > >>

[jira] [Created] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira)
Ma Jun created FLINK-22408: -- Summary: Flink Table Parsr Hive Drop Partitions Syntax unparse is Error Key: FLINK-22408 URL: https://issues.apache.org/jira/browse/FLINK-22408 Project: Flink Issue

[jira] [Created] (FLINK-22403) Update Chinese version of JDBC sink docs

2021-04-22 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-22403: Summary: Update Chinese version of JDBC sink docs Key: FLINK-22403 URL: https://issues.apache.org/jira/browse/FLINK-22403 Project: Flink Issue Type: Task

[ANNOUNCE] Flink Jira Bot fully live (& Useful Filters to Work with the Bot)

2021-04-22 Thread Konstantin Knauf
Hi everyone, all of the Jira Bot rules are live now. Particularly in the beginning the Jira Bot will be very active, because the rules apply to a lot of old, stale tickets. So, if you get a huge amount of emails from the Flink Jira Bot right now, this will get better. In any case, the Flink Jira

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Rui Li
Thanks everyone! Looking forward to making more contributions~ On Thu, Apr 22, 2021 at 6:23 PM Shengkai Fang wrote: > Congratulations Rui! =-= > > Best, > Shengkai > > Leonard Xu 于2021年4月22日周四 下午3:09写道: > > > Congratulations Rui Li ! > > > > Best, > > Leonard > > > > > 在

[jira] [Created] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

2021-04-22 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22413: -- Summary: Hide Checkpointing page in the UI for batch jobs Key: FLINK-22413 URL: https://issues.apache.org/jira/browse/FLINK-22413 Project: Flink Issue

[jira] [Created] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse

2021-04-22 Thread tartarus (Jira)
tartarus created FLINK-22412: Summary: SplitAggregateRule support optimization of aggregate function reuse Key: FLINK-22412 URL: https://issues.apache.org/jira/browse/FLINK-22412 Project: Flink

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread 刘大龙
Congratulations Rui! Best > -原始邮件- > 发件人: "Benchao Li" > 发送时间: 2021-04-22 14:43:33 (星期四) > 收件人: dev > 抄送: > 主题: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li > > Congratulations Rui! > > Jingsong Li 于2021年4月22日周四 下午2:33写道: > > > Congratulations Rui! > > > > Best, > >

[jira] [Created] (FLINK-22415) JsonBatchFileSystemITCase fails on Azure

2021-04-22 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22415: Summary: JsonBatchFileSystemITCase fails on Azure Key: FLINK-22415 URL: https://issues.apache.org/jira/browse/FLINK-22415 Project: Flink Issue Type:

[jira] [Created] (FLINK-22414) Consider {{env.hadoop.conf.dir}} when looking for the hadoop configuration

2021-04-22 Thread Matthias (Jira)
Matthias created FLINK-22414: Summary: Consider {{env.hadoop.conf.dir}} when looking for the hadoop configuration Key: FLINK-22414 URL: https://issues.apache.org/jira/browse/FLINK-22414 Project: Flink

[jira] [Created] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-04-22 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22416: Summary: UpsertKafkaTableITCase hangs when collecting results Key: FLINK-22416 URL: https://issues.apache.org/jira/browse/FLINK-22416 Project: Flink

Flink SQL ordering issues ?

2021-04-22 Thread Etienne Chauchot
Hi all, I've been running TPCDS benchmarks lately and I noticed something: as global sorted output is not supported (1), if we run a SQL query that specifies an ORDER clause, then the output of such query is ordered per partition only which makes the output incorrect. WDYT ? Should I open a

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Till Rohrmann
Congratulations Rui! Cheers, Till On Thu, Apr 22, 2021 at 4:10 PM 刘大龙 wrote: > Congratulations Rui! > > Best > > > -原始邮件- > > 发件人: "Benchao Li" > > 发送时间: 2021-04-22 14:43:33 (星期四) > > 收件人: dev > > 抄送: > > 主题: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li > > > >

[jira] [Created] (FLINK-22417) OrcFileSystemITCase.testOrcFilterPushDown fails on AZP

2021-04-22 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22417: - Summary: OrcFileSystemITCase.testOrcFilterPushDown fails on AZP Key: FLINK-22417 URL: https://issues.apache.org/jira/browse/FLINK-22417 Project: Flink

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Matthias Pohl
Congratulations, Rui! On Thu, Apr 22, 2021 at 4:58 PM Till Rohrmann wrote: > Congratulations Rui! > > Cheers, > Till > > On Thu, Apr 22, 2021 at 4:10 PM 刘大龙 wrote: > > > Congratulations Rui! > > > > Best > > > > > -原始邮件- > > > 发件人: "Benchao Li" > > > 发送时间: 2021-04-22 14:43:33 (星期四) >

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-22 Thread Chen Qin
Hi there, Quick dial back here, we have been running load testing and so far haven't seen suspended state cause job restarts. Some findings, instead of curator framework capture suspended state and active notify leader lost, we have seen task manager propagate unhandled errors from zk client,

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-22 Thread tison
> Unfortunately, we do not have any progress on this ticket. Here is a PR[1]. Here is the base PR[2] I made about one year ago without following review. qinnc...@gmail.com: It requires further investigation about the impact involved by FLINK-18677[3]. I do have some comments[4] but so far

[jira] [Created] (FLINK-22420) UnalignedCheckpointITCase failed

2021-04-22 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22420: - Summary: UnalignedCheckpointITCase failed Key: FLINK-22420 URL: https://issues.apache.org/jira/browse/FLINK-22420 Project: Flink Issue Type: Bug

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Yun Tang
Congratulations, Rui! Best, Yun Tang From: Xuannan Su Sent: Friday, April 23, 2021 10:01 To: dev@flink.apache.org ; matth...@ververica.com Subject: Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Congratulations Rui! Best, Xuannan On Apr 22, 2021,

Re: Flink SQL ordering issues ?

2021-04-22 Thread Jark Wu
Hi Etienne, AFAIK, only blink planner (and batch mode) support TPCDS benchmarks and blink planner does support global ORDER BY. The docs link you mentioned above refers to the DataSet API, blink planner implements batch mode on DataStream (actually low-level StreamOperator) instead of DataSet

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-22 Thread tison
Could you show the log about which unhandled exception was thrown? Best, tison. Chen Qin 于2021年4月23日周五 下午1:06写道: > Hi Tison, > > Please read my latest comments in the thread. Using SessionErrorPolicy > mitigated the suspended state issue while it might trigger an unhandled zk > client

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Guowei Ma
Congratulations, Rui! Best, Guowei On Fri, Apr 23, 2021 at 10:38 AM Yun Tang wrote: > Congratulations, Rui! > > Best, > Yun Tang > > From: Xuannan Su > Sent: Friday, April 23, 2021 10:01 > To: dev@flink.apache.org ; matth...@ververica.com < >

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Xuannan Su
Congratulations Rui! Best, Xuannan On Apr 22, 2021, 6:23 PM +0800, M Shengkai Fang , wrote: > > Congratulations Rui!

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-22 Thread Chen Qin
Hi Tison, Please read my latest comments in the thread. Using SessionErrorPolicy mitigated the suspended state issue while it might trigger an unhandled zk client exception in some situations. We would like to get some idea of the root cause of that issue to avoid introducing another issue in the

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

2021-04-22 Thread tison
The original log (section) is preferred over rephrasing. Best, tison. tison 于2021年4月23日周五 下午1:15写道: > Could you show the log about which unhandled exception was thrown? > > Best, > tison. > > > Chen Qin 于2021年4月23日周五 下午1:06写道: > >> Hi Tison, >> >> Please read my latest comments in the thread.

[jira] [Created] (FLINK-22421) Does flink support multi cluster deployment with HA on multi kubernetes clusters

2021-04-22 Thread Bhagi (Jira)
Bhagi created FLINK-22421: - Summary: Does flink support multi cluster deployment with HA on multi kubernetes clusters Key: FLINK-22421 URL: https://issues.apache.org/jira/browse/FLINK-22421 Project: Flink

[jira] [Created] (FLINK-22402) Add hive dialect test in sql-client

2021-04-22 Thread Rui Li (Jira)
Rui Li created FLINK-22402: -- Summary: Add hive dialect test in sql-client Key: FLINK-22402 URL: https://issues.apache.org/jira/browse/FLINK-22402 Project: Flink Issue Type: Sub-task

Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Benchao Li
Congratulations Rui! Jingsong Li 于2021年4月22日周四 下午2:33写道: > Congratulations Rui! > > Best, > Jingsong > > On Thu, Apr 22, 2021 at 11:52 AM Yun Gao > wrote: > > > Congratulations Rui! > > > > Best, > > Yun > > > > > > -- > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Xingbo Huang
Congratulations Rui~! Best, Xingbo Xintong Song 于2021年4月22日周四 下午1:58写道: > Congrats, Rui~! > > Thank you~ > > Xintong Song > > > > On Thu, Apr 22, 2021 at 11:52 AM Yun Gao > wrote: > > > Congratulations Rui! > > > > Best, > > Yun > > > > > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Kurt Young
Congratulations Rui! Best, Kurt On Thu, Apr 22, 2021 at 2:10 PM Arvid Heise wrote: > Congrats! > > Best, > > Arvid > > On Thu, Apr 22, 2021 at 8:07 AM Xingbo Huang wrote: > > > Congratulations Rui~! > > > > Best, > > Xingbo > > > > Xintong Song 于2021年4月22日周四 下午1:58写道: > > > > > Congrats,

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Leonard Xu
Congratulations Rui Li ! Best, Leonard > 在 2021年4月22日,14:43,Benchao Li 写道: > > Congratulations Rui! > > Jingsong Li 于2021年4月22日周四 下午2:33写道: > >> Congratulations Rui! >> >> Best, >> Jingsong >> >> On Thu, Apr 22, 2021 at 11:52 AM Yun Gao >> wrote: >> >>> Congratulations Rui! >>> >>>