You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2017/05/22 08:30:39 UTC
flink git commit: [FLINK-6651] Add synchronization to
SharedStateRegistry::clear
Repository: flink
Updated Branches:
refs/heads/master 654d0ede9 -> 392bc7130
[FLINK-6651] Add synchronization to SharedStateRegistry::clear
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/392bc713
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/392bc713
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/392bc713
Branch: refs/heads/master
Commit: 392bc713014d59e661fe1f39217762d6438ffd89
Parents: 654d0ed
Author: Stefan Richter <s....@data-artisans.com>
Authored: Mon May 22 10:27:56 2017 +0200
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Mon May 22 10:30:00 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/392bc713/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();
+ }
}
}