|
如下
Exception in thread "main" java.lang.UnsupportedOperationException:
Checkpointing is currently not supported by default for iterative jobs, as
we cannot guarantee exactly once semantics. State checkpoints happen
normally, but records in-transit during the snapshot will be lost upon
failure.
The user can force enable state checkpoints with the reduced guarantees by
calling: env.enableCheckpointing(interval,true)
。
Flink当前针对IterativeJob不支持检查点,但可以强制开启。
我需要知道的是,强制开启后,对状态影响多大?无法保证没问题的是哪部分状态,还是对普通流算子的状态也会受到影响呢?
or影响只是iterative的feedback部分?还是什么部分?
|