| commit | a874ad89039c8f499b69dbedc02efa925927b4f5 | [log] [tgz] |
|---|---|---|
| author | Ufuk Celebi <uce@apache.org> | Fri Dec 16 14:49:07 2016 +0100 |
| committer | Ufuk Celebi <uce@apache.org> | Fri Dec 16 14:51:09 2016 +0100 |
| tree | d15b878b694f57a3a71be985e6a7c0df205d2b31 | |
| parent | d31c9fac740fdede845cd83730ffc8089e62da17 [diff] |
[FLINK-5352] [rocksdb] Restore 1.1.3 RocksDB DBOptions
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 DBOptions createDBOptions() { return new DBOptions() .setUseFsync(false) - .setDisableDataSync(true); + .setDisableDataSync(true) + .setTableCacheNumshardbits(4); } @Override