我比较奇怪的是再慢的磁盘,对于几十KB的状态也不至于“慢”吧。
Jacob <[email protected]> 于2021年3月2日周二 上午10:34写道: > 谢谢回复 > > 我用的是filesystem, > 相关配置如下: > > > state.backend: filesystem > state.checkpoints.dir: hdfs://nameservice1/datafeed/prd/flink_checkpoint > state.savepoints.dir: hdfs://nameservice1/datafeed/prd/flink_checkpoint > state.backend.incremental: false > state.backend.fs.memory-threshold: 1024 > state.checkpoints.num-retained: 3 > restart-strategy: fixed-delay > restart-strategy.fixed-delay.attempts: 1000 > restart-strategy.fixed-delay.delay: 30 s > > > > 后面把上面配置注释掉,然后在代码中指定了checkpoint类型为内存,但速度还是很慢。 > > > > ----- > Thanks! > Jacob > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
