Ted Yu created FLINK-8415: ----------------------------- Summary: Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() Key: FLINK-8415 URL: https://issues.apache.org/jira/browse/FLINK-8415 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
{code} public void shutdown() { running = false; recordsToSend.complete(0L); {code} In other methods, access to recordsToSend is protected by synchronized keyword. shutdown() should do the same. -- This message was sent by Atlassian JIRA (v6.4.14#64029)