[jira] [Created] (FLINK-10386) Remove legacy class TaskExecutionStateListener

2018-09-20 Thread JIRA
陈梓立 created FLINK-10386: --- Summary: Remove legacy class TaskExecutionStateListener Key: FLINK-10386 URL: https://issues.apache.org/jira/browse/FLINK-10386 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
陈梓立 created FLINK-10385: --- Summary: Implement a waitUntilCondition utils Key: FLINK-10385 URL: https://issues.apache.org/jira/browse/FLINK-10385 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10384) Add Sinh math function supported in Table API and SQL

2018-09-20 Thread vinoyang (JIRA)
vinoyang created FLINK-10384: Summary: Add Sinh math function supported in Table API and SQL Key: FLINK-10384 URL: https://issues.apache.org/jira/browse/FLINK-10384 Project: Flink Issue Type:

[DISCUSS] [Contributing] (3) - Review Tooling

2018-09-20 Thread Stephan Ewen
Hi all! This thread is dedicated to discuss the tooling we want to use for the reviews. It is spun out of the proposal *"A more structured approach to reviews and contributions".* *Suggestions brought up so far* *Use comments / template with checklist* - Easy to do - Manual, a bit of

[DISCUSS] [Contributing] (2) - Review Steps

2018-09-20 Thread Stephan Ewen
Hi all! This thread is dedicated to discuss the specific review steps and answers we want to have during reviews. It is spun out of the proposal *"A more structured approach to reviews and contributions".* Please keep this thread focused on the review steps, NOT on the tooling (bot,

Re: [PROPOSAL] [community] A more structured approach to reviews and contributions

2018-09-20 Thread Stephan Ewen
Hi all! Thank you for the interest and lively discussion. I think we are starting to mix different things into one discussion, so I would like to close this thread and start three separate dedicated threads: (1) Contributing Guide and Pull Request Template (2) Review Process (steps, questions,

[DISCUSS] [Contributing] (1) - Pull Request Template

2018-09-20 Thread Stephan Ewen
Hi all! This thread is dedicated to discuss improvements to the way we encourage contributions. It is spun out of the proposal *"A more structured approach to reviews and contributions".* Please keep this thread focused on the contribution side, there are separate discussions about the reviews!

[jira] [Created] (FLINK-10383) Hadoop configurations on the classpath seep into the S3 file system configs

2018-09-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-10383: Summary: Hadoop configurations on the classpath seep into the S3 file system configs Key: FLINK-10383 URL: https://issues.apache.org/jira/browse/FLINK-10383 Project:

[jira] [Created] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

2018-09-20 Thread Chengzhi Zhao (JIRA)
Chengzhi Zhao created FLINK-10382: - Summary: Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink Key: FLINK-10382 URL: https://issues.apache.org/jira/browse/FLINK-10382

[jira] [Created] (FLINK-10381) concurrent submit job get ProgramAbortException

2018-09-20 Thread Youjun Yuan (JIRA)
Youjun Yuan created FLINK-10381: --- Summary: concurrent submit job get ProgramAbortException Key: FLINK-10381 URL: https://issues.apache.org/jira/browse/FLINK-10381 Project: Flink Issue Type:

[ANNOUNCE] Apache Flink 1.6.1 released

2018-09-20 Thread Till Rohrmann
The Apache Flink community is very happy to announce the release of Apache Flink 1.6.1, which is the first bug fix release for the Apache Flink 1.6 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[ANNOUNCE] Apache Flink 1.5.4 released

2018-09-20 Thread Till Rohrmann
The Apache Flink community is very happy to announce the release of Apache Flink 1.5.4, which is the fourth bug fix release for the Apache Flink 1.5 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[jira] [Created] (FLINK-10379) Can not use Table Functions in Java Table API

2018-09-20 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10379: -- Summary: Can not use Table Functions in Java Table API Key: FLINK-10379 URL: https://issues.apache.org/jira/browse/FLINK-10379 Project: Flink Issue

[jira] [Created] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

2018-09-20 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-10380: -- Summary: Check if key is not nul before assign to group in KeyedStream Key: FLINK-10380 URL: https://issues.apache.org/jira/browse/FLINK-10380 Project:

Re: [PROPOSAL] [community] A more structured approach to reviews and contributions

2018-09-20 Thread 陈梓立
Hi Fabian, I see a bot "project-bot" active on pull requests. It is some progress of this thread? Best, tison. Thomas Weise 于2018年9月19日周三 下午10:02写道: > Follow-up regarding the PR template that pops up when opening a PR: > > I think what we have now is a fairly big blob of text that jumps up a

[jira] [Created] (FLINK-10378) Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE

2018-09-20 Thread JIRA
陈梓立 created FLINK-10378: --- Summary: Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE Key: FLINK-10378 URL: https://issues.apache.org/jira/browse/FLINK-10378 Project: Flink Issue Type:

Re: [RESULT] [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Till Rohrmann
I forgot to add myself to the list of binding votes. There are 5 approving votes, 4 of which are binding: * Fabian Hueske (binding) * Gary Yao (non-binding) * Tzu-Li Tai (binding) * Timo Walther (binding) * Till Rohrmann (binding) Cheers, Till On Thu, Sep 20, 2018 at 3:38 PM Till Rohrmann

[RESULT] [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Till Rohrmann
I'm happy to announce that we have approved this release. There are 6 approving votes, 4 of which are binding: * Gary Yao (non-binding) * Fabian Hueske (binding) * Vino Yang (non-binding) * Till Rohrmann (binding) * Tzu-Li Tai (binding) * Timo Walther (binding) There is one disapproving vote: *

[RESULT] [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Till Rohrmann
I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 4 of which are binding: * Fabian Hueske (binding) * Gary Yao (non-binding) * Tzu-Li Tai (binding) * Timo Walther (binding) There are no disapproving votes. Thanks everyone! Cheers, Till

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Till Rohrmann
Thanks everyone for testing and voting on this RC. Hereby I close the vote. The result will be announced in a separate thread. Cheers, Till On Thu, Sep 20, 2018 at 2:34 PM Till Rohrmann wrote: > +1 (binding) > > - Verified checksums and signatures > - Ran all end-to-end tests > - Executed

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Till Rohrmann
Thanks everyone for testing and voting on this RC. Hereby I close the vote. The result will be announced in a separate thread. Cheers, Till On Thu, Sep 20, 2018 at 3:26 PM Timo Walther wrote: > +1 (binding) > > - Checked all issues that went into the release (I found two JIRA issue > that have

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Timo Walther
+1 (binding) - Checked all issues that went into the release (I found two JIRA issue that have been incorrectly marked) - Built the source and verify locally successfully - Run a couple of end-to-end tests successfully Regards, Timo Am 20.09.18 um 11:13 schrieb Tzu-Li (Gordon) Tai: +1

[jira] [Created] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

2018-09-20 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10377: -- Summary: Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete Key: FLINK-10377 URL: https://issues.apache.org/jira/browse/FLINK-10377

[jira] [Created] (FLINK-10376) BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis

2018-09-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10376: - Summary: BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis Key: FLINK-10376 URL: https://issues.apache.org/jira/browse/FLINK-10376 Project: Flink

Re: [Possible Bug] Savepoints Akka Timeout

2018-09-20 Thread Till Rohrmann
Hi Sayat, I think your problem might be caused by https://issues.apache.org/jira/browse/FLINK-10193. This will be fixed with the next bug fix release which will happen in the next days. In the future, please post these kind of questions to u...@flink.apache.org. The dev mailing list is intended

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Till Rohrmann
+1 (binding) - Verified checksums and signatures - Ran all end-to-end tests - Executed Jepsen test suite (including test for standby JobManager) - Build Flink from sources - Verified that no new dependencies were added Cheers, Till On Thu, Sep 20, 2018 at 1:54 PM Timo Walther wrote: > +1

[Possible Bug] Savepoints Akka Timeout

2018-09-20 Thread Sayat Satybaldiyev
Dear Flink Community! I've initially posted my question on SO: https://stackoverflow.com/questions/52422499/flink-savepoints-akka-pattern-asktimeoutexception-ask-timed-out-on-actorakka However, after further investigation, I think it's the issue with Flink 1.6.0 cluster rather me doing something

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Timo Walther
+1 (binding) - Checked all issues that went into the release (I found one JIRA issue that has been incorrectly marked) - Built from source (On my machine SelfJoinDeadlockITCase is failing due to a timeout, in the IDE it works correctly. I guess my machine was just too busy.) - Run some

[jira] [Created] (FLINK-10375) ExceptionInChainedStubException hides wrapped exception in cause

2018-09-20 Thread Mike Pedersen (JIRA)
Mike Pedersen created FLINK-10375: - Summary: ExceptionInChainedStubException hides wrapped exception in cause Key: FLINK-10375 URL: https://issues.apache.org/jira/browse/FLINK-10375 Project: Flink

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Tzu-Li (Gordon) Tai
+1 (binding) - Verified checksums / signatures - Checked announcement PR in flink-web - No new / changed dependencies - Built from source (Hadoop-free, Scala 2.11) - Run end-to-end tests locally, passes On Thu, Sep 20, 2018 at 5:03 AM Fabian Hueske wrote: > +1 binding > > * I checked the diffs

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Gary Yao
+1 (non-binding) Ran test suite from the flink-jepsen project on AWS EC2 without issues. Best, Gary On Wed, Sep 19, 2018 at 11:02 PM, Fabian Hueske wrote: > +1 binding > > * I checked the diffs and did not find any added dependencies or updated > dependency versions. > * I checked the sha

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Tzu-Li (Gordon) Tai
+1 (binding) - Verified checksums / signatures - Checked announcement PR in flink-web - Built Flink from sources, test + build passes (Hadoop-free, Scala 2.11) - Ran Elasticsearch 6 sink, using quickstart POM. - Ran end-to-end tests locally, passes On Thu, Sep 20, 2018 at 4:31 PM Till Rohrmann

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Till Rohrmann
+1 (binding) - Verified checksums and signatures - Ran all end-to-end tests - Executed Jepsen test suite (including test for standby JobManager) - Build Flink from sources - Verified that no new dependencies were added Cheers, Till On Thu, Sep 20, 2018 at 9:23 AM Till Rohrmann wrote: > I

[jira] [Created] (FLINK-10374) [Map State] Let user value serializer handle null values

2018-09-20 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10374: --- Summary: [Map State] Let user value serializer handle null values Key: FLINK-10374 URL: https://issues.apache.org/jira/browse/FLINK-10374 Project: Flink

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread Till Rohrmann
I would not block the release on FLINK-10243 since you can always deactivate the latency metrics. Instead we should discuss whether to back port this scalability improvement and include it in a next bug fix release. For that, I suggest to write on the JIRA thread. Cheers, Till On Thu, Sep 20,

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread shimin yang
-1 Could you merge the FLINK-10243 into release 1.6.1. I think the configurable latency metrics will be quite useful and not much work to merge. Best, Shimin vino yang 于2018年9月20日周四 下午2:08写道: > +1 > > I checked the new Flink version in the root pom file. > I checked the announcement blog

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-20 Thread vino yang
+1 I checked the new Flink version in the root pom file. I checked the announcement blog post and make sure the version number is right. I checked out the source code and ran mvn package (without test) Thanks, vino. Fabian Hueske 于2018年9月20日周四 上午4:54写道: > +1 binding > > * I checked the diffs