[flink] branch release-1.6 updated: [hotfix] Correct compilation error from rebase

[srichter]

This is an automated email from the ASF dual-hosted git repository.

srichter pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.6 by this push:
     new 6006f93  [hotfix] Correct compilation error from rebase
6006f93 is described below

commit 6006f935874281df50ba99d8f78f0af25bbe4095
Author: Stefan Richter <s.rich...@data-artisans.com>
AuthorDate: Thu Aug 2 17:15:19 2018 +0200

    [hotfix] Correct compilation error from rebase
---
 .../contrib/streaming/state/RocksDBStateBackendConfigTest.java      | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java
 
b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java
index d39ec83..71382b8 100644
--- 
a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java
+++ 
b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java
@@ -131,8 +131,6 @@ public class RocksDBStateBackendConfigTest {
        @Test
        public void testConfigureTimerService() throws Exception {
 
-               final Environment env = 
getMockEnvironment(tempFolder.newFolder());
-
                // Fix the option key string
                
Assert.assertEquals("state.backend.rocksdb.timer-service.factory", 
RocksDBOptions.TIMER_SERVICE_FACTORY.key());
 
@@ -148,7 +146,7 @@ public class RocksDBStateBackendConfigTest {
 
                RocksDBStateBackend rocksDbBackend = new 
RocksDBStateBackend(tempFolder.newFolder().toURI().toString());
 
-               RocksDBKeyedStateBackend<Integer> keyedBackend = 
createKeyedStateBackend(rocksDbBackend, env);
+               RocksDBKeyedStateBackend<Integer> keyedBackend = 
createKeyedStateBackend(rocksDbBackend);
                keyedBackend.restore(Collections.emptyList());
                Assert.assertEquals(HeapPriorityQueueSetFactory.class, 
keyedBackend.getPriorityQueueFactory().getClass());
                keyedBackend.dispose();
@@ -159,7 +157,7 @@ public class RocksDBStateBackendConfigTest {
                        
RocksDBStateBackend.PriorityQueueStateType.ROCKSDB.toString());
 
                rocksDbBackend = rocksDbBackend.configure(conf);
-               keyedBackend = createKeyedStateBackend(rocksDbBackend, env);
+               keyedBackend = createKeyedStateBackend(rocksDbBackend);
                keyedBackend.restore(Collections.emptyList());
                Assert.assertEquals(
                        
RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory.class,