Repository: flink Updated Branches: refs/heads/release-1.3 39114e26b -> f112b56e2
[FLINK-6671] [tests] Make RocksDBStateBackendTest.testCancelRunningSnapshot stable Let first the snapshotting thread completely finish before checking the test condition. This prevents race conditions between the checkpointing thread and the verification. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f112b56e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f112b56e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f112b56e Branch: refs/heads/release-1.3 Commit: f112b56e2b3a3fdc7f8e91ee3390ea2fcfc5805f Parents: 39114e2 Author: Till Rohrmann <[email protected]> Authored: Tue May 23 13:38:18 2017 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue May 23 13:40:41 2017 +0200 ---------------------------------------------------------------------- .../flink/contrib/streaming/state/RocksDBStateBackendTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f112b56e/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java index 89eb1d5..8d0db69 100644 --- a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java +++ b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java @@ -327,8 +327,8 @@ public class RocksDBStateBackendTest extends StateBackendTestBase<RocksDBStateBa } catch (Exception ignored) { } - verifyRocksObjectsReleased(); asyncSnapshotThread.join(); + verifyRocksObjectsReleased(); } @Test
