Re: AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread Chesnay Schepler
R and [FLINK-9730]? -Original Message- From: Chesnay Schepler [mailto:ches...@apache.org] Sent: Friday, July 06, 2018 9:48 AM To: dev@flink.apache.org; NEKRASSOV, ALEXEI Subject: Re: AsyncIOExample.SampleAsyncFunction Correct, either counter must be made static, or both the executorServic

RE: AsyncIOExample.SampleAsyncFunction

2018-07-06 Thread NEKRASSOV, ALEXEI
...@apache.org] Sent: Friday, July 06, 2018 9:48 AM To: dev@flink.apache.org; NEKRASSOV, ALEXEI Subject: Re: AsyncIOExample.SampleAsyncFunction Correct, either counter must be made static, or both the executorService and random non-static (which makes the counter unnecessary). For an example I

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