You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/12/16 13:51:32 UTC
flink git commit: [FLINK-5352] [rocksdb] Restore 1.1.3 RocksDB
DBOptions
Repository: flink
Updated Branches:
refs/heads/release-1.1 d31c9fac7 -> a874ad890
[FLINK-5352] [rocksdb] Restore 1.1.3 RocksDB DBOptions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a874ad89
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a874ad89
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a874ad89
Branch: refs/heads/release-1.1
Commit: a874ad89039c8f499b69dbedc02efa925927b4f5
Parents: d31c9fa
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Dec 16 14:49:07 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Dec 16 14:51:09 2016 +0100
----------------------------------------------------------------------
.../apache/flink/contrib/streaming/state/PredefinedOptions.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a874ad89/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java
index af85fa7..3e3fd68 100644
--- a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java
+++ b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java
@@ -71,7 +71,8 @@ public enum PredefinedOptions {
public DBOptions createDBOptions() {
return new DBOptions()
.setUseFsync(false)
- .setDisableDataSync(true);
+ .setDisableDataSync(true)
+ .setTableCacheNumshardbits(4);
}
@Override