[jira] [Created] (FLINK-20101) Fix the wrong documentation of FROM_UNIXTIME function

2020-11-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-20101: --- Summary: Fix the wrong documentation of FROM_UNIXTIME function Key: FLINK-20101 URL: https://issues.apache.org/jira/browse/FLINK-20101 Project: Flink Issue Type: Bug

Re: Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread Benchao Li
+1 Danny Chan 于2020年11月12日周四 下午2:19写道: > +1 > > Jingsong Li 于2020年11月12日周四 下午2:18写道: > > > +1 > > > > On Thu, Nov 12, 2020 at 2:07 PM hailongwang <18868816...@163.com> wrote: > > > > > > > > > > > +1(no-binding) > > > > > > > > > > > > > > > 在 2020-11-11 19:44:40,"刘大龙" 写道: > > > > > > > >+1 >

Re: Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread Danny Chan
+1 Jingsong Li 于2020年11月12日周四 下午2:18写道: > +1 > > On Thu, Nov 12, 2020 at 2:07 PM hailongwang <18868816...@163.com> wrote: > > > > > > > +1(no-binding) > > > > > > > > > > 在 2020-11-11 19:44:40,"刘大龙" 写道: > > > > > >+1 > > > > > >> -原始邮件- > > >> 发件人: "Timo Walther" > > >> 发送时间:

Re: Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread Jingsong Li
+1 On Thu, Nov 12, 2020 at 2:07 PM hailongwang <18868816...@163.com> wrote: > > > +1(no-binding) > > > > > 在 2020-11-11 19:44:40,"刘大龙" 写道: > > > >+1 > > > >> -原始邮件- > >> 发件人: "Timo Walther" > >> 发送时间: 2020-11-11 18:55:06 (星期三) > >> 收件人: dev@flink.apache.org > >> 抄送: > >> 主题: Re: [VOTE]

Re:Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread hailongwang
+1(no-binding) 在 2020-11-11 19:44:40,"刘大龙" 写道: > >+1 > >> -原始邮件- >> 发件人: "Timo Walther" >> 发送时间: 2020-11-11 18:55:06 (星期三) >> 收件人: dev@flink.apache.org >> 抄送: >> 主题: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd) >> >> +1 (binding) >> >> Thanks, >> Timo

[jira] [Created] (FLINK-20100) Lag aggregate function does not return lag, but current row

2020-11-11 Thread Thilo Schneider (Jira)
Thilo Schneider created FLINK-20100: --- Summary: Lag aggregate function does not return lag, but current row Key: FLINK-20100 URL: https://issues.apache.org/jira/browse/FLINK-20100 Project: Flink

Re: [DISCUSS] Releasing Apache Flink 1.11.3

2020-11-11 Thread Xintong Song
Thanks for the notice and fix, Roman. Thank you~ Xintong Song On Wed, Nov 11, 2020 at 5:53 PM Khachatryan Roman < khachatryan.ro...@gmail.com> wrote: > Hi, > > I'd like FLINK-20079 [1] to be merged into 1.11 and included in 1.11.3. > > [1] https://issues.apache.org/jira/browse/FLINK-20079 >

[jira] [Created] (FLINK-20099) HeapStateBackend checkpoint error hidden under cryptic message

2020-11-11 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-20099: --- Summary: HeapStateBackend checkpoint error hidden under cryptic message Key: FLINK-20099 URL: https://issues.apache.org/jira/browse/FLINK-20099 Project: Flink

Re: Register processing time timers when Operator.close() is called

2020-11-11 Thread Boyuan Zhang
Thanks, Aljoscha! Manually draining processing time timers during operator.close() is my current workaround as well. It's just not efficient for me since I may set the processing time timer for the callback after 5 mins but now I need to fire them immediately.

[jira] [Created] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-11 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-20098: Summary: Don't add flink-connector-files to flink-dist Key: FLINK-20098 URL: https://issues.apache.org/jira/browse/FLINK-20098 Project: Flink Issue

[jira] [Created] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20097: - Summary: Race conditions in InputChannel.ChannelStatePersister Key: FLINK-20097 URL: https://issues.apache.org/jira/browse/FLINK-20097 Project: Flink

[jira] [Created] (FLINK-20096) Clean up PyFlink documentation

2020-11-11 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-20096: Summary: Clean up PyFlink documentation Key: FLINK-20096 URL: https://issues.apache.org/jira/browse/FLINK-20096 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20095) SchedulerBase.stopWithSavepoint schedules operation after ExecutionGraph terminates

2020-11-11 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20095: - Summary: SchedulerBase.stopWithSavepoint schedules operation after ExecutionGraph terminates Key: FLINK-20095 URL: https://issues.apache.org/jira/browse/FLINK-20095

[jira] [Created] (FLINK-20094) Make JobMaster.jobStatusChanged directly called by JobManagerJobStatusListener

2020-11-11 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20094: - Summary: Make JobMaster.jobStatusChanged directly called by JobManagerJobStatusListener Key: FLINK-20094 URL: https://issues.apache.org/jira/browse/FLINK-20094

[jira] [Created] (FLINK-20093) Create a download page for all optional sql client components

2020-11-11 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20093: Summary: Create a download page for all optional sql client components Key: FLINK-20093 URL: https://issues.apache.org/jira/browse/FLINK-20093 Project: Flink

Re: Register processing time timers when Operator.close() is called

2020-11-11 Thread Aljoscha Krettek
Hi! This is an interesting topic and we recently created a Jira issue about this: https://issues.apache.org/jira/browse/FLINK-18647. In Beam we even have a workaround for this:

[jira] [Created] (FLINK-20092) Multi-thread Flink compilation

2020-11-11 Thread Jira
Maciej Bryński created FLINK-20092: -- Summary: Multi-thread Flink compilation Key: FLINK-20092 URL: https://issues.apache.org/jira/browse/FLINK-20092 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2020-11-11 Thread hailong wang (Jira)
hailong wang created FLINK-20091: Summary: Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema Key: FLINK-20091 URL: https://issues.apache.org/jira/browse/FLINK-20091 Project:

[jira] [Created] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

2020-11-11 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-20090: -- Summary: Expose SlotId / SlotSharingGroup in Rest API Key: FLINK-20090 URL: https://issues.apache.org/jira/browse/FLINK-20090 Project: Flink

[jira] [Created] (FLINK-20089) Avro format fails to serialize map value with null keys

2020-11-11 Thread hailong wang (Jira)
hailong wang created FLINK-20089: Summary: Avro format fails to serialize map value with null keys Key: FLINK-20089 URL: https://issues.apache.org/jira/browse/FLINK-20089 Project: Flink

[ANNOUNCE] Weekly Community Update 2020/44-45

2020-11-11 Thread Konstantin Knauf
Dear community, two weeks have passed again and I am happy two share another update with news on Flink 1.12, Flink 1.11.3 and the release of Stateful Functions 2.2.1. As everyone has been finishing the last bit and pieces of Flink 1.12, there are only a handful of new initiatives to cover this

[jira] [Created] (FLINK-20088) [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard

2020-11-11 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-20088: - Summary: [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard Key: FLINK-20088 URL: https://issues.apache.org/jira/browse/FLINK-20088

Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread 刘大龙
+1 > -原始邮件- > 发件人: "Timo Walther" > 发送时间: 2020-11-11 18:55:06 (星期三) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd) > > +1 (binding) > > Thanks, > Timo > > On 11.11.20 07:14, Pengcheng Liu wrote: > > +1 (binding) > > >

[jira] [Created] (FLINK-20087) CheckpointCoordinator waits until all tasks finish initialization of states to trigger checkpoint

2020-11-11 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-20087: -- Summary: CheckpointCoordinator waits until all tasks finish initialization of states to trigger checkpoint Key: FLINK-20087 URL: https://issues.apache.org/jira/browse/FLINK-20087

Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread Timo Walther
+1 (binding) Thanks, Timo On 11.11.20 07:14, Pengcheng Liu wrote: +1 (binding) Jark Wu 于2020年11月11日周三 上午10:13写道: +1 (binding) On Tue, 10 Nov 2020 at 14:59, Jark Wu wrote: Hi all, There is new feedback on the FLIP-145. So I would like to start a new vote for FLIP-145 [1], which has

Re: [DISCUSS] Releasing Apache Flink 1.11.3

2020-11-11 Thread Khachatryan Roman
Hi, I'd like FLINK-20079 [1] to be merged into 1.11 and included in 1.11.3. [1] https://issues.apache.org/jira/browse/FLINK-20079 Regards, Roman On Tue, Nov 10, 2020 at 8:21 AM Xintong Song wrote: > Thanks for the notice, Dian. > > Thank you~ > > Xintong Song > > > > On Tue, Nov 10, 2020 at

[jira] [Created] (FLINK-20086) Add documentation for the open method in UserDefinedFunction

2020-11-11 Thread Dian Fu (Jira)
Dian Fu created FLINK-20086: --- Summary: Add documentation for the open method in UserDefinedFunction Key: FLINK-20086 URL: https://issues.apache.org/jira/browse/FLINK-20086 Project: Flink Issue

[ANNOUNCE] Apache Flink Stateful Functions 2.2.1 released

2020-11-11 Thread Tzu-Li (Gordon) Tai
The Apache Flink community released the first bugfix release of the Stateful Functions (StateFun) 2.2 series, version 2.2.1. This release fixes a critical bug that causes restoring a Stateful Functions cluster from snapshots (checkpoints or savepoints) to fail under certain conditions. *We