Re: Consuming data from dynamoDB streams to flink

2018-07-06 Thread Ying Xu
Hi Gordon: Cool. Thanks for the thumb-up! We will include some test cases around the behavior of re-sharding. If needed we can double check the behavior with AWS, and see if additional changes are needed. Will keep you posted. - Ying On Wed, Jul 4, 2018 at 7:22 PM, Tzu-Li (Gordon) Tai wrote:

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

2018-07-06 Thread Ted Yu
+1 Checked signatures of artifacts Ran test suite On Fri, Jul 6, 2018 at 11:42 AM Yaz Sh wrote: > +1 > > Tests have been done on OS X > > - Ran in cluster mode ./bin/start-cluster.sh > - Checked that *.out files are empty > - Stopped cluster ./bin/stop-cluster.sh > - Checked for No Exceptions

Re: AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread Chesnay Schepler
I've commented in the PR. On 06.07.2018 19:07, NEKRASSOV, ALEXEI wrote: lamber-ken has an open PR (https://github.com/apache/flink/pull/6247) that touches AsyncIOExample.java Do we need a new JIRA for the code cleanup that Chesnay recommends, or it can be done as part of the open PR and [FLINK

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

2018-07-06 Thread Yaz Sh
+1 Tests have been done on OS X - Ran in cluster mode ./bin/start-cluster.sh - Checked that *.out files are empty - Stopped cluster ./bin/stop-cluster.sh - Checked for No Exceptions on log output - Test Examples via WebUI - Test Example via CLI with different flags (-d, -c, -q, -p) - Added mor

RE: AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread NEKRASSOV, ALEXEI
lamber-ken has an open PR (https://github.com/apache/flink/pull/6247) that touches AsyncIOExample.java Do we need a new JIRA for the code cleanup that Chesnay recommends, or it can be done as part of the open PR and [FLINK-9730]? -Original Message- From: Chesnay Schepler [mailto:ches...@

[VOTE] Release 1.5.1, release candidate #2

2018-07-06 Thread Chesnay Schepler
Hi everyone, Please review and vote on the release candidate #2 for the version 1.5.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

Re: AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread Chesnay Schepler
Correct, either counter must be made static, or both the executorService and random non-static (which makes the counter unnecessary). For an example I would regard the latter as preferable to ensure that instances don't interfere with each other. As for your question, for a given instance ope

AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread NEKRASSOV, ALEXEI
Hi, I'm confused by lines 119-122 in https://github.com/lamber-ken/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java Why is counter non-static, but executorService and random - static? It's not clear to me wheth

[jira] [Created] (FLINK-9776) Interrupt TaskThread only while in User/Operator code

2018-07-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9776: --- Summary: Interrupt TaskThread only while in User/Operator code Key: FLINK-9776 URL: https://issues.apache.org/jira/browse/FLINK-9776 Project: Flink Issue Type:

[jira] [Created] (FLINK-9775) BucketingSink E2E test fails in certain environments

2018-07-06 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9775: --- Summary: BucketingSink E2E test fails in certain environments Key: FLINK-9775 URL: https://issues.apache.org/jira/browse/FLINK-9775 Project: Flink Issue Type:

Re: [CANCEL][VOTE] Release 1.5.1, release candidate #1

2018-07-06 Thread Chesnay Schepler
Both issues have been resolved, kicking of rc2 now. On 05.07.2018 23:37, Chesnay Schepler wrote: I've identified 2 issues related to the WebUI job submission and opened a PR for each of them: FLINK-9770: https://github.com/apache/flink/pull/6269 FLINK-9769: https://github.com/apache/flink/pull

[jira] [Created] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

2018-07-06 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9774: --- Summary: Allow to pass a string-based cluster identifier to command line Key: FLINK-9774 URL: https://issues.apache.org/jira/browse/FLINK-9774 Project: Flink

[jira] [Created] (FLINK-9773) Break down CEP documentation into subsections

2018-07-06 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9773: --- Summary: Break down CEP documentation into subsections Key: FLINK-9773 URL: https://issues.apache.org/jira/browse/FLINK-9773 Project: Flink Issue Type: