You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/07/16 21:06:36 UTC
[7/8] flink git commit: [hotfix] Use default value of
RocksDBOptions#TIMER_SERVICE_IMPL
[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 "".
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6bba0e77
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6bba0e77
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6bba0e77
Branch: refs/heads/master
Commit: 6bba0e77ed0d98b8de24f457605b82c69980a0d4
Parents: 8db5ca6
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Jul 16 15:07:31 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Jul 16 22:11:57 2018 +0200
----------------------------------------------------------------------
.../apache/flink/contrib/streaming/state/RocksDBStateBackend.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6bba0e77/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
----------------------------------------------------------------------
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 c6b50cd..0564849 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;