This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 9aeb4e5 [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path 9aeb4e5 is described below commit 9aeb4e5cb38079cdfbcc25f8c3966b368287825d Author: Yu Li <l...@apache.org> AuthorDate: Mon Apr 29 16:21:24 2019 +0800 [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path This closes #8297. --- .../flink/contrib/streaming/state/RocksDBStateBackendTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java index 819c864..ceb781c 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java @@ -217,7 +217,9 @@ public class RocksDBStateBackendTest extends StateBackendTestBase<RocksDBStateBa AbstractStateBackend.getCompressionDecorator(env.getExecutionConfig()), spy(db), defaultCFHandle, - new CloseableRegistry()).build(); + new CloseableRegistry()) + .setEnableIncrementalCheckpointing(enableIncrementalCheckpointing) + .build(); testState1 = keyedStateBackend.getPartitionedState( VoidNamespace.INSTANCE, @@ -294,7 +296,9 @@ public class RocksDBStateBackendTest extends StateBackendTestBase<RocksDBStateBa AbstractStateBackend.getCompressionDecorator(executionConfig), db, defaultCFHandle, - new CloseableRegistry()).build(); + new CloseableRegistry()) + .setEnableIncrementalCheckpointing(enableIncrementalCheckpointing) + .build(); ValueStateDescriptor<String> stubState1 = new ValueStateDescriptor<>("StubState-1", StringSerializer.INSTANCE); test.createInternalState(StringSerializer.INSTANCE, stubState1);