Repository: flink Updated Branches: refs/heads/master 546e2ad73 -> f369f8640
[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/f369f864 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f369f864 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f369f864 Branch: refs/heads/master Commit: f369f86400bcd52d1521eebbc7f1af1148a5a17e Parents: 546e2ad Author: Till Rohrmann <[email protected]> Authored: Tue May 23 13:38:18 2017 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue May 23 13:38:18 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/f369f864/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
