You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2019/01/30 14:44:54 UTC
[flink] branch release-1.6 updated: [FLINK-11469][docs] Update
documentation for `Tuning Checkpoints and Large State`
This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.6 by this push:
new de3772b [FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
de3772b is described below
commit de3772bfd2e61ba0afca269cfbb03103d32d2ce1
Author: junsheng.wu <a>
AuthorDate: Wed Jan 30 14:34:45 2019 +0100
[FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
This closes #7603.
(cherry picked from commit 3abb3de79e36b04cf5a5012fc1062f4418b3597a)
---
docs/ops/state/large_state_tuning.md | 22 +++++++++-------------
1 file changed, 9 insertions(+), 13 deletions(-)
diff --git a/docs/ops/state/large_state_tuning.md b/docs/ops/state/large_state_tuning.md
index 50c5a53..ade4025 100644
--- a/docs/ops/state/large_state_tuning.md
+++ b/docs/ops/state/large_state_tuning.md
@@ -161,21 +161,17 @@ RocksDBStateBackend.setOptions(new MyOptions());
public class MyOptions implements OptionsFactory {
@Override
- public DBOptions createDBOptions() {
- return new DBOptions()
- .setIncreaseParallelism(4)
- .setUseFsync(false)
- .setDisableDataSync(true);
+ public DBOptions createDBOptions(DBOptions currentOptions) {
+ return currentOptions.setIncreaseParallelism(4)
+ .setUseFsync(false);
}
-
+
@Override
- public ColumnFamilyOptions createColumnOptions() {
-
- return new ColumnFamilyOptions()
- .setTableFormatConfig(
- new BlockBasedTableConfig()
- .setBlockCacheSize(256 * 1024 * 1024) // 256 MB
- .setBlockSize(128 * 1024)); // 128 KB
+ public ColumnFamilyOptions createColumnOptions(ColumnFamilyOptions currentOptions) {
+ return currentOptions.setTableFormatConfig(
+ new BlockBasedTableConfig()
+ .setBlockCacheSize(256 * 1024 * 1024) // 256 MB
+ .setBlockSize(128 * 1024)); // 128 KB
}
}
{% endhighlight %}