添加RocksDB状态后端相关
This commit is contained in:
parent
045454f380
commit
2a73aca5c7
@ -175,10 +175,6 @@ private final HashMap<String, InternalKvState<K, ?, ?>> keyValueStatesByName;
|
|||||||
|
|
||||||
建议同时将 [managed memory](https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/deployment/memory/mem_setup_tm/#managed-memory) 设为0,以保证将最大限度的内存分配给 JVM 上的用户代码。
|
建议同时将 [managed memory](https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/deployment/memory/mem_setup_tm/#managed-memory) 设为0,以保证将最大限度的内存分配给 JVM 上的用户代码。
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
## EmbeddedRocksDBStateBackend
|
## EmbeddedRocksDBStateBackend
|
||||||
|
|
||||||
将正在于行的作业的状态保存到RocksDb里面。
|
将正在于行的作业的状态保存到RocksDb里面。
|
||||||
|
Loading…
Reference in New Issue
Block a user