[FLINK-8415] Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()
This closes #5724. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc0f344f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc0f344f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dc0f344f Branch: refs/heads/master Commit: dc0f344f3c345765a59fcce60841fa565fde1047 Parents: a148492 Author: yanghua <yanghua1...@gmail.com> Authored: Tue Mar 20 11:21:42 2018 +0800 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Wed Mar 28 08:11:05 2018 +0200 ---------------------------------------------------------------------- .../streaming/runtime/io/benchmark/LongRecordWriterThread.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/dc0f344f/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/LongRecordWriterThread.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/LongRecordWriterThread.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/LongRecordWriterThread.java index b93b867..05ae276 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/LongRecordWriterThread.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/LongRecordWriterThread.java @@ -47,7 +47,7 @@ public class LongRecordWriterThread extends CheckedThread { this.recordWriter = checkNotNull(recordWriter); } - public void shutdown() { + public synchronized void shutdown() { running = false; recordsToSend.complete(0L); }
