[jira] [Created] (FLINK-8969) Move TimerService into state backend

Bowen Li created FLINK-8969: --- Summary: Move TimerService into state backend Key: FLINK-8969 URL: https://issues.apache.org/jira/browse/FLINK-8969 Project: Flink Issue Type: Improvement

[ANNOUNCE] Apache Flink 1.3.3 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.3.3, which is the third bugfix release for the Apache Flink 1.3 series.  Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

Re: Flip 6 mesos support

Hi Till, This is Shuyi :) Thanks a lot. In FLINK-8562, I already sent a PR to resolve the issue, your help to take a look will be great. Please let me know what I can help to test the Kerberos authentication, I am decently familiar with the Kerberos and YARN security part in Flink. As a

Re: [RESULT] [VOTE] Release 1.3.3, release candidate #2

The voting time has passed and I'm happy to announce that we've collected enough votes to release this RC as Flink 1.3.3. +1 votes: - Ted (non-binding) - Timo (binding) - Chesnay (binding) - Fabian (binding) - Gordon (binding) - Henry (binding) That's 6 votes, 5 binding. No 0 or -1

Re: [VOTE] Release 1.3.3, release candidate #2

Signature file looks good Hash files look good LICENSE file exists NOTICE file exists Source artifact build and local tests passed +1 On Wed, Mar 14, 2018 at 3:26 AM, Tzu-Li (Gordon) Tai wrote: > Hi everyone, > > Please review and vote on release candidate #2 for Flink

Re: [VOTE] Release 1.3.3, release candidate #2

+1 - checked hashes and signatures - built from staged source artifact - ran state machine job chaos monkey test on AWS EMR - ran quickstarts I also agree that we do not need to cancel the RC because of the unintended PythonPlanBinderTest commit. Cheers, Gordon On 15 March 2018 at 11:08:30

Re: Correct way to reference Hadoop dependencies in Flink 1.4.0

Hi, I believe for FileSystems to be correctly be picked up they have to be in the lib/ folder of Flink. Stephan (cc'ed), please correct me if I'm wrong here, you probably know that one best. Aljoscha > On 14. Mar 2018, at 18:26, l...@lyft.com wrote: > > Hi, > > I am running this on a

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

Nice, it seems we're in agreement. I'll batch-edit the existing issues to remove the 1.6.0 fixVersion. Aljoscha > On 15. Mar 2018, at 08:34, Thomas Weise wrote: > > +1 > > Since it is guaranteed that all pre 1.5.0 release patches also make it to > master, it would be

[jira] [Created] (FLINK-8968) Fix native resource leak caused by ReadOptions

Sihua Zhou created FLINK-8968: - Summary: Fix native resource leak caused by ReadOptions Key: FLINK-8968 URL: https://issues.apache.org/jira/browse/FLINK-8968 Project: Flink Issue Type: Bug

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 Since it is guaranteed that all pre 1.5.0 release patches also make it to master, it would be confusing to mark them resolved for 1.6.x. On Thu, Mar 15, 2018 at 8:25 AM, Stephan Ewen wrote: > +1 > > Important: Please still write in the notes (when closing the issue) the >

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 Important: Please still write in the notes (when closing the issue) the commit hashes for both 1.5 (release-1.5) and 1.6 (master). Otherwise it makes hind-sight digging into the fixed more complicated. On Thu, Mar 15, 2018 at 3:28 PM, Felix Cheung wrote: > +1 >

Re: [VOTE] Release 1.3.3, release candidate #2

+1 - checked hashes and signatures - build from src.tgz with unit tests (mvn clean package) - checked commits for dependency changes and didn't find any Thanks, Fabian 2018-03-15 14:06 GMT+01:00 Chesnay Schepler : > Given that the commit only affects a test I'd be in favor

[jira] [Created] (FLINK-8967) Port NetworkStackThroughputITCase to flip6

Chesnay Schepler created FLINK-8967: --- Summary: Port NetworkStackThroughputITCase to flip6 Key: FLINK-8967 URL: https://issues.apache.org/jira/browse/FLINK-8967 Project: Flink Issue Type:

[jira] [Created] (FLINK-8965) Port TimestampITCase to flip6

Chesnay Schepler created FLINK-8965: --- Summary: Port TimestampITCase to flip6 Key: FLINK-8965 URL: https://issues.apache.org/jira/browse/FLINK-8965 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

Chesnay Schepler created FLINK-8966: --- Summary: Port AvroExternalJarProgramITCase to flip6 Key: FLINK-8966 URL: https://issues.apache.org/jira/browse/FLINK-8966 Project: Flink Issue Type:

[jira] [Created] (FLINK-8959) Port AccumulatorLiveITCase to flip6

Chesnay Schepler created FLINK-8959: --- Summary: Port AccumulatorLiveITCase to flip6 Key: FLINK-8959 URL: https://issues.apache.org/jira/browse/FLINK-8959 Project: Flink Issue Type:

[jira] [Created] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6

Chesnay Schepler created FLINK-8963: --- Summary: Port BigUserProgramJobSubmitITCase to flip6 Key: FLINK-8963 URL: https://issues.apache.org/jira/browse/FLINK-8963 Project: Flink Issue Type:

[jira] [Created] (FLINK-8964) Port JobSubmissionFailsITCase to flip6

Chesnay Schepler created FLINK-8964: --- Summary: Port JobSubmissionFailsITCase to flip6 Key: FLINK-8964 URL: https://issues.apache.org/jira/browse/FLINK-8964 Project: Flink Issue Type:

[jira] [Created] (FLINK-8962) Port AccumulatorErrorITCase to flip6

Chesnay Schepler created FLINK-8962: --- Summary: Port AccumulatorErrorITCase to flip6 Key: FLINK-8962 URL: https://issues.apache.org/jira/browse/FLINK-8962 Project: Flink Issue Type:

[jira] [Created] (FLINK-8961) Port JobRetrievalITCase to flip6

Chesnay Schepler created FLINK-8961: --- Summary: Port JobRetrievalITCase to flip6 Key: FLINK-8961 URL: https://issues.apache.org/jira/browse/FLINK-8961 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8960) Port SavepointITCase to flip6

Chesnay Schepler created FLINK-8960: --- Summary: Port SavepointITCase to flip6 Key: FLINK-8960 URL: https://issues.apache.org/jira/browse/FLINK-8960 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8958) Port TaskCancelAsyncProducerConsumerITCase to flip6

Chesnay Schepler created FLINK-8958: --- Summary: Port TaskCancelAsyncProducerConsumerITCase to flip6 Key: FLINK-8958 URL: https://issues.apache.org/jira/browse/FLINK-8958 Project: Flink

[jira] [Created] (FLINK-8957) Port JMXJobManagerMetricTest to flip6

Chesnay Schepler created FLINK-8957: --- Summary: Port JMXJobManagerMetricTest to flip6 Key: FLINK-8957 URL: https://issues.apache.org/jira/browse/FLINK-8957 Project: Flink Issue Type:

[jira] [Created] (FLINK-8956) Port RescalingITCase to flip6

Chesnay Schepler created FLINK-8956: --- Summary: Port RescalingITCase to flip6 Key: FLINK-8956 URL: https://issues.apache.org/jira/browse/FLINK-8956 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8955) Port ClassLoaderITCase to flip6

Chesnay Schepler created FLINK-8955: --- Summary: Port ClassLoaderITCase to flip6 Key: FLINK-8955 URL: https://issues.apache.org/jira/browse/FLINK-8955 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 From: Till Rohrmann Sent: Thursday, March 15, 2018 5:45:14 AM To: dev@flink.apache.org Subject: Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0 +1 for marking bugs as fixed 1.5.0 only On Thu, Mar 15,

[jira] [Created] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

Timo Walther created FLINK-8954: --- Summary: Escape control characters when outputting on SQL Client CLI Key: FLINK-8954 URL: https://issues.apache.org/jira/browse/FLINK-8954 Project: Flink

Re: [VOTE] Release 1.3.3, release candidate #2

Given that the commit only affects a test I'd be in favor of continuing the release process and updating the release notes. On 15.03.2018 14:01, Timo Walther wrote: +1 - built and run tests locally - run some training exercises locally - looked over the commits I found one minor thing that

Re: [VOTE] Release 1.3.3, release candidate #2

+1 - built and run tests locally - run some training exercises locally - looked over the commits I found one minor thing that should be mentioned. It seems that there is one unintended commit in the release: 2455df962c76d20f1c07a57d6ed0118d1d1a067c [FLINK-7283][python] fix

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 for marking bugs as fixed 1.5.0 only On Thu, Mar 15, 2018 at 11:09 AM, Ted Yu wrote: > +1 on marking bugs as fixed for 1.5.0 only. > Original message From: Piotr Nowojski < > pi...@data-artisans.com> Date: 3/15/18 12:48 AM (GMT-08:00) To: >

Re: Flip 6 mesos support

Hi Renjie, thanks for the pointer with the YARNSessionFIFOSecuredITCase. You're right that we should fix this test. There is FLINK-8562 which seems to address the problem. Will take a look. Additionally, we want to test Kerberos authentication explicitly as part of the release testing for Flink

[jira] [Created] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

Timo Walther created FLINK-8953: --- Summary: Resolve unresolved field references in FieldComputer expressions Key: FLINK-8953 URL: https://issues.apache.org/jira/browse/FLINK-8953 Project: Flink

[jira] [Created] (FLINK-8952) Support setting the parallelism of individual operators of a query

Fabian Hueske created FLINK-8952: Summary: Support setting the parallelism of individual operators of a query Key: FLINK-8952 URL: https://issues.apache.org/jira/browse/FLINK-8952 Project: Flink

[jira] [Created] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

Fabian Hueske created FLINK-8951: Summary: Support OVER windows PARTITION BY (rounded) timestamp Key: FLINK-8951 URL: https://issues.apache.org/jira/browse/FLINK-8951 Project: Flink Issue

[jira] [Created] (FLINK-8950) "Materialize" Tables to avoid recomputation.

Fabian Hueske created FLINK-8950: Summary: "Materialize" Tables to avoid recomputation. Key: FLINK-8950 URL: https://issues.apache.org/jira/browse/FLINK-8950 Project: Flink Issue Type: New

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 on marking bugs as fixed for 1.5.0 only. Original message From: Piotr Nowojski Date: 3/15/18 12:48 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0 Same as Chesnay

[jira] [Created] (FLINK-8949) Rest API failure with long URL

Truong Duc Kien created FLINK-8949: -- Summary: Rest API failure with long URL Key: FLINK-8949 URL: https://issues.apache.org/jira/browse/FLINK-8949 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.3.3, release candidate #2

+1 * verified that compilation works * ran a few test examples against a local cluster * src artifact contains no binaries * verified signatures On 14.03.2018 21:49, Ted Yu wrote: +1 Ran the following command - passed: mvn clean package -Pjdk8 On Wed, Mar 14, 2018 at 3:26 AM, Tzu-Li

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

Same as Chesnay +1 for marking bugs as fixed 1.5.0 only > On 15 Mar 2018, at 07:57, Chesnay Schepler wrote: > > +1 to mark bugs as fixed in 1.5.0 only. > > On 15.03.2018 01:40, Aljoscha Krettek wrote: >> Hi, >> >> We currently have some issues that are marked as resolved

[jira] [Created] (FLINK-8948) RescalingITCase fails on Travis

Chesnay Schepler created FLINK-8948: --- Summary: RescalingITCase fails on Travis Key: FLINK-8948 URL: https://issues.apache.org/jira/browse/FLINK-8948 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8947) Timeout handler issue

dhiraj prajapati created FLINK-8947: --- Summary: Timeout handler issue Key: FLINK-8947 URL: https://issues.apache.org/jira/browse/FLINK-8947 Project: Flink Issue Type: Bug

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 to mark bugs as fixed in 1.5.0 only. On 15.03.2018 01:40, Aljoscha Krettek wrote: Hi, We currently have some issues that are marked as resolved for both 1.5.0 and 1.6.0 [1]. The reason is that we have the release-1.5 branch and the master branch, which will eventually become the branch

Re: Flip 6 mesos support

Thanks for the clarification On Thu, Mar 15, 2018 at 2:30 PM 周思华 wrote: > Hi Renjie, > if I am not misunderstand, you just need to start the cluster as normal as > before. The dispatcher and resourcemanager are spawned by ClusterEntryPoint > (you can have a look at