flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srich...@apache.org
Subject flink git commit: [FLINK-6651] Add synchronization to SharedStateRegistry::clear
Date Mon, 22 May 2017 08:32:01 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.3 fcf8466a5 -> 6e40223b5


[FLINK-6651] Add synchronization to SharedStateRegistry::clear

(cherry picked from commit 392bc71)


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e40223b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e40223b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6e40223b

Branch: refs/heads/release-1.3
Commit: 6e40223b5c512ba6e0bbf3a6cdcd2354dea1fbbf
Parents: fcf8466
Author: Stefan Richter <s.richter@data-artisans.com>
Authored: Mon May 22 10:27:56 2017 +0200
Committer: Stefan Richter <s.richter@data-artisans.com>
Committed: Mon May 22 10:31:44 2017 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/state/SharedStateRegistry.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/6e40223b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
index 949839b..af9ac9d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
@@ -255,6 +255,8 @@ public class SharedStateRegistry {
 	 * Clears the registry.
 	 */
 	public void clear() {
-		registeredStates.clear();
+		synchronized (registeredStates) {
+			registeredStates.clear();
+		}
 	}
 }


Mime
View raw message