From 6bba0e77ed0d98b8de24f457605b82c69980a0d4 Mon Sep 17 00:00:00 2001 From: Till Rohrmann Date: Mon, 16 Jul 2018 15:07:31 +0200 Subject: [PATCH] [hotfix] Use default value of RocksDBOptions#TIMER_SERVICE_IMPL In order to fully enable the RocksDBOptions#TIMER_SERVICE_IMPL we should use the default value of this config option instead of "". --- .../flink/contrib/streaming/state/RocksDBStateBackend.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java index c6b50cde926..056484939e7 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java @@ -271,7 +271,7 @@ public class RocksDBStateBackend extends AbstractStateBackend implements Configu this.enableIncrementalCheckpointing = original.enableIncrementalCheckpointing.resolveUndefined( config.getBoolean(CheckpointingOptions.INCREMENTAL_CHECKPOINTS)); - final String priorityQueueTypeString = config.getString(TIMER_SERVICE_IMPL.key(), ""); + final String priorityQueueTypeString = config.getString(TIMER_SERVICE_IMPL); this.priorityQueueStateType = priorityQueueTypeString.length() > 0 ? PriorityQueueStateType.valueOf(priorityQueueTypeString.toUpperCase()) : original.priorityQueueStateType; -- GitLab