[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 "".
tongcheng-elong · Jul 16, 2018 · 6bba0e7 · 6bba0e7
1 parent 8db5ca6
commit 6bba0e7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
@@ -271,7 +271,7 @@ private RocksDBStateBackend(RocksDBStateBackend original, Configuration config)
  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;