checkpointCK-X
----
??:
"user-zh"
??flink on
yarnflink??1.7.2??on
yarntaskmanager.heap.sizecontainer??container??kill??taskmanager.heap.size
= xmx+maxDirectMemorySizexmx = taskmanager.heap.size - cutoff
-
Hi, 在Datastream api之中我们可以控制shuffle的模式[1]，但是在Table api 似乎暂时还不提供控制shuffle
mode的接口。
我对join算子的实现不太熟悉，这个需要shuffle吗？对于agg操作，它的partition模式是由group by的key控制的。
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/#physical-partitioning
忝忝向仧 <153488...@qq.com> 于2020年10月6日周二
Hi,all:
debugflink 1.10.0??join.
??StreamNode,shufflemodeundefinedflink??shuffle??undefined?
shuffleMode=UNDEFINED
.
Hi,
有个rocksdb增量checkpoint的问题不明白，如果state.checkpoints.num-retained默认设置为1，意味着checkpoint默认只保留1个，那么在增量checkpoint的时候，它是无法引用上一个checkpoint的备份的sst文件的，其实还是相当于全量备份了，对不对？
| |
熊云昆
|
|
邮箱：xiongyun...@163.com
|
签名由 网易邮箱大师 定制
