[flink] branch master updated: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

[srichter]

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);