Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168490322
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@ -482,40 +480,40 @@ public void
testSharedIncrementalStateDeRegistration() throws Exception {
@Test
public void testLocalRecoveryConfigurationForwarding() throws Exception
{
- RocksDBStateBackend stateBackend = getStateBackend();
-
Assert.assertEquals(RocksDBStateBackend.LocalRecoveryMode.DISABLED,
stateBackend.getLocalRecoveryMode());
-
stateBackend.setLocalRecoveryMode(RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED);
-
Assert.assertEquals(RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED,
stateBackend.getLocalRecoveryMode());
-
- DummyEnvironment environment = new DummyEnvironment();
- File tmpDir = tempFolder.newFolder();
- TestTaskStateManager taskStateManager = new
TestTaskStateManager();
- taskStateManager.setSubtaskLocalStateBaseDirectory(tmpDir);
- environment.setTaskStateManager(taskStateManager);
-
- RocksDBKeyedStateBackend<Integer> keyedBackend =
- (RocksDBKeyedStateBackend<Integer>)
stateBackend.createKeyedStateBackend(
- environment,
- new JobID(),
- "test",
- IntSerializer.INSTANCE,
- 1,
- new KeyGroupRange(0, 0),
- null);
-
- try {
- RocksDBStateBackend.LocalRecoveryConfig
localRecoveryConfig = keyedBackend.getLocalRecoveryConfig();
- Assert.assertEquals(
-
RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED,
- localRecoveryConfig.getLocalRecoveryMode());
-
- Assert.assertEquals(
- tmpDir,
- localRecoveryConfig.getLocalStateDirectory());
- } finally {
- IOUtils.closeQuietly(keyedBackend);
- keyedBackend.dispose();
- }
+// RocksDBStateBackend stateBackend = getStateBackend();
+//
Assert.assertEquals(RocksDBStateBackend.LocalRecoveryMode.DISABLED,
stateBackend.getLocalRecoveryMode());
+//
stateBackend.setLocalRecoveryMode(RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED);
+//
Assert.assertEquals(RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED,
stateBackend.getLocalRecoveryMode());
+//
+// DummyEnvironment environment = new DummyEnvironment();
+// File tmpDir = tempFolder.newFolder();
+// TestTaskStateManager taskStateManager = new
TestTaskStateManager();
+// taskStateManager.setLocalRecoveryDirectoryProvider(tmpDir);
+// environment.setTaskStateManager(taskStateManager);
+//
+// RocksDBKeyedStateBackend<Integer> keyedBackend =
+// (RocksDBKeyedStateBackend<Integer>)
stateBackend.createKeyedStateBackend(
+// environment,
+// new JobID(),
+// "test",
+// IntSerializer.INSTANCE,
+// 1,
+// new KeyGroupRange(0, 0),
+// null);
+//
+// try {
+// RocksDBStateBackend.LocalRecoveryConfig
localRecoveryConfig = keyedBackend.getLocalRecoveryConfig();
+// Assert.assertEquals(
+//
RocksDBStateBackend.LocalRecoveryMode.ENABLE_FILE_BASED,
+// localRecoveryConfig.getLocalRecoveryMode());
+//
+// Assert.assertEquals(
+// tmpDir,
+// localRecoveryConfig.getLocalStateDirectory());
+// } finally {
+// IOUtils.closeQuietly(keyedBackend);
+// keyedBackend.dispose();
+// }
--- End diff --
ð
---
