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:34:21 UTC
[flink] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 3abb3de [FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
3abb3de is described below
commit 3abb3de79e36b04cf5a5012fc1062f4418b3597a
Author: junsheng.wu <a>
AuthorDate: Wed Jan 30 21:34:45 2019 +0800
[FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
This closes #7603.
---
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 81d3606..0e81890 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 %}