在广播模式的文档中,提到没有RocksDB状态后端:
No RocksDB state backend: Broadcast state is kept in-memory at runtime and如果应用程序使用rocksdb作为状态后端,这会如何影响savepoint行为?这是否意味着在保存点期间没有存储状态,因此也没有恢复状态?
我已经编写了一个使用Guava缓存的Flink作业。缓存对象是在main()函数中调用的run()函数中创建和使用的。main() {}
//create and use Guava cache object here如果我以某种程度的并行性运行这个Flink作业,那么所有的并行任务会使用相同的缓存对象吗?如果不是,我如何让它们都使用一个缓存?
缓存在流的process()函数中
为什么TumblingProcessingTimeWindows为每个到达的元素代码指定一个窗口,如下所示?例如,一个启动时间为1s和结束时间为5s的TimeWindow,那么时间之间的所有元素都需要一个窗口,但是从下面的代码中,每个元素都会得到一个新窗口,为什么呢? @Override
public Collection<TimeWindow> assignWindows(Obj