Ted Yu created FLINK-8394: ----------------------------- Summary: Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown Key: FLINK-8394 URL: https://issues.apache.org/jira/browse/FLINK-8394 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
{code} public void shutdown() { running = false; interrupt(); expectedRecord.complete(0L); {code} Access to expectedRecord should be protected by synchronization, as done on other methods. -- This message was sent by Atlassian JIRA (v6.4.14#64029)