flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [5/5] flink git commit: [FLINK-8415] Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()
Date Wed, 28 Mar 2018 06:12:28 GMT
[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/dcec0820
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dcec0820
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dcec0820

Branch: refs/heads/release-1.5
Commit: dcec0820d56670b302835331f63efc81e537dc9e
Parents: 1bb9567
Author: yanghua <yanghua1127@gmail.com>
Authored: Tue Mar 20 11:21:42 2018 +0800
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Wed Mar 28 08:12:06 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/dcec0820/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);
 	}


Mime
View raw message