Repository: flink
Updated Branches:
  refs/heads/master c38589766 -> cd610a99e


[hotfix] Don't Swallow Exception in RocksDBAsyncSnapshotTest


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

Branch: refs/heads/master
Commit: cd610a99e59846dfa9dfa66df7d2e264bcbe95d8
Parents: c385897
Author: Aljoscha Krettek <[email protected]>
Authored: Fri Nov 4 11:41:34 2016 +0100
Committer: Aljoscha Krettek <[email protected]>
Committed: Fri Nov 4 11:41:34 2016 +0100

----------------------------------------------------------------------
 .../flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/cd610a99/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
----------------------------------------------------------------------
diff --git 
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
 
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
index 98d46bb..09979b8 100644
--- 
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
+++ 
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
@@ -148,7 +148,7 @@ public class RocksDBAsyncSnapshotTest {
                                try {
                                        delayCheckpointLatch.await();
                                } catch (InterruptedException e) {
-                                       e.printStackTrace();
+                                       throw new RuntimeException(e);
                                }
 
                                // should be one k/v state

Reply via email to