[FLINK-9784] Inconsistent use of 'static' in AsyncIOExample.java

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.4.2, 1.5.0
• Fix Version/s: 1.5.2, 1.6.0
• Component/s: Examples
• Labels: pull-request-available
• Assignee: Alexei Nekrassov
• Reporter: Alexei Nekrassov
• Created: 09/Jul/18 14:06
• Updated: 12/Jul/18 11:45
• Resolved: 12/Jul/18 11:45

Description

In SampleAsyncFunction having executorService and random as static, but counter as instance-specific will not work when someone creates a second instance of SampleAsyncFunction. In second SampleAsyncFunction the counter will be 0 and we will re-intialize static executorService and random, thus interfering with the first SampleAsyncFunction object.

To fix this example and make it clearer, make executorService and random instance-specific. That will make counter redundant; also synchronization on class will no longer be needed.

Issue Links

• links to: GitHub Pull Request #6298