[jira] [Created] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20085: --- Summary: Remove RemoteFunctionStateMigrator code paths from StateFun Key: FLINK-20085 URL: https://issues.apache.org/jira/browse/FLINK-20085 Project:

[jira] [Created] (FLINK-20084) Fix NPE when generating watermark for record whose rowtime field is null after watermark push down

2020-11-10 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20084: - Summary: Fix NPE when generating watermark for record whose rowtime field is null after watermark push down Key: FLINK-20084 URL:

[jira] [Created] (FLINK-20083) OrcFsStreamingSinkITCase times out

2020-11-10 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20083: -- Summary: OrcFsStreamingSinkITCase times out Key: FLINK-20083 URL: https://issues.apache.org/jira/browse/FLINK-20083 Project: Flink Issue Type:

[jira] [Created] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-10 Thread 陳昌倬
(陳昌倬) Attachments: image-20201110-060934.png Hi, * Our Flink application (Java 11 + Scala 2.12) has the following problem when executing it. It cannot be run in Flink cluster. * The problem is similar to https://issues.apache.org/jira/browse/SPARK-25047, so maybe the same fix shall be implemented in

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

2020-11-10 Thread Pengcheng Liu
+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 been discussed and reached consensus in the

[jira] [Created] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20081: Summary: ExecutorNotifier should run handler in the main thread when receive an exception from the callable. Key: FLINK-20081 URL:

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

2020-11-10 Thread Jark Wu
+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 been discussed and reached consensus in the discussion thread > [2]. > > The vote will be open until 15:00 (UTC+8)

[jira] [Created] (FLINK-20080) Exceeded checkpoint tolerable failure threshold

2020-11-10 Thread Alex Z (Jira)
Alex Z created FLINK-20080: -- Summary: Exceeded checkpoint tolerable failure threshold Key: FLINK-20080 URL: https://issues.apache.org/jira/browse/FLINK-20080 Project: Flink Issue Type: Bug

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

2020-11-10 Thread Boyuan Zhang
Hi team, I'm writing my custom Operator as a high fan-out operation and I use processing time timers to defer processing some inputs When timers are firing, the operator will continue to process the deferred elements. One typical use case for my Operator is like: ImpulseOperator -> my Operator ->

[jira] [Created] (FLINK-20079) Modified UnalignedCheckpointITCase...MassivelyParallel fails

2020-11-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20079: - Summary: Modified UnalignedCheckpointITCase...MassivelyParallel fails Key: FLINK-20079 URL: https://issues.apache.org/jira/browse/FLINK-20079 Project:

Re: [DISCUSS] Planning the 1.12 release testing

2020-11-10 Thread Robert Metzger
This is a fair point. I would recommend people to put instructions into the Wiki, or ask here if something is unclear! On Tue, Nov 10, 2020 at 2:23 PM Aljoscha Krettek wrote: > On 04.11.20 20:05, Robert Metzger wrote: > > For testing Flink in a coordinated way, and to allow the broader >

[jira] [Created] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-11-10 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-20078: --- Summary: Factor out an ExecutionGraph factory method for DefaultExecutionTopology Key: FLINK-20078 URL: https://issues.apache.org/jira/browse/FLINK-20078

Re: [DISCUSS] Planning the 1.12 release testing

2020-11-10 Thread Aljoscha Krettek
On 04.11.20 20:05, Robert Metzger wrote: For testing Flink in a coordinated way, and to allow the broader community to participate in the testing more easily, I've created a wiki page to collect testing tasks: https://cwiki.apache.org/confluence/display/FLINK/1.12+Release+-+Community+Testing

[jira] [Created] (FLINK-20077) Cannot register a view with MATCH_RECOGNIZE clause

2020-11-10 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20077: Summary: Cannot register a view with MATCH_RECOGNIZE clause Key: FLINK-20077 URL: https://issues.apache.org/jira/browse/FLINK-20077 Project: Flink

[jira] [Created] (FLINK-20076) DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality

2020-11-10 Thread Matthias (Jira)
Matthias created FLINK-20076: Summary: DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality Key: FLINK-20076 URL: https://issues.apache.org/jira/browse/FLINK-20076

[RESULT] [VOTE] Apache Flink Stateful Functions 2.2.1, release candidate #1

2020-11-10 Thread Tzu-Li (Gordon) Tai
Thanks for testing and voting everyone! The vote has passed with 4 +1 votes, 3 of which are binding: +1: - Robert Metzger (binding) - Tzu-Li (Gordon) Tai (binding) - Igal Shilman - Stephan Ewen (binding) There are no 0 or -1 votes. I'll announce the release in a separate email once the

[jira] [Created] (FLINK-20075) When the JobMaster is initialized, the JobID of the JobGraph is retrieved again in the createlotpool method

2020-11-10 Thread ZhangAiping (Jira)
ZhangAiping created FLINK-20075: --- Summary: When the JobMaster is initialized, the JobID of the JobGraph is retrieved again in the createlotpool method Key: FLINK-20075 URL:

[jira] [Created] (FLINK-20074) ChangelogSourceITCase.testRegularJoin fail

2020-11-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20074: Summary: ChangelogSourceITCase.testRegularJoin fail Key: FLINK-20074 URL: https://issues.apache.org/jira/browse/FLINK-20074 Project: Flink Issue Type: Bug

Re: [VOTE] Apache Flink Stateful Functions 2.2.1, release candidate #1

2020-11-10 Thread Stephan Ewen
+1 (binding) Compiled source and ran all tests (JDK 8) Ran example (greeter) with a docker compose setup Release contains no binaries. Checked LICENSE and NOTICE for source release Checked LICENSE and NOTICE for flink-statefun-distribution binary release On Fri, Nov 6, 2020 at 11:46 PM Igal

[jira] [Created] (FLINK-20073) Add kerberos setup documentation for native k8s integration

2020-11-10 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20073: -- Summary: Add kerberos setup documentation for native k8s integration Key: FLINK-20073 URL: https://issues.apache.org/jira/browse/FLINK-20073 Project: Flink

[jira] [Created] (FLINK-20072) Add documentation for FLIP-107

2020-11-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-20072: Summary: Add documentation for FLIP-107 Key: FLINK-20072 URL: https://issues.apache.org/jira/browse/FLINK-20072 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20071) Add a dedicated stage to build the PyFlink wheel packges in azure-pipelines.yml

2020-11-10 Thread Dian Fu (Jira)
Dian Fu created FLINK-20071: --- Summary: Add a dedicated stage to build the PyFlink wheel packges in azure-pipelines.yml Key: FLINK-20071 URL: https://issues.apache.org/jira/browse/FLINK-20071 Project: Flink