我们试图迁移到Flink 1.11,从1.10中的保存点恢复作业。作业代码没有更改,只将依赖项的Flink版本更新为1.11 (在SBT中,我们使用Scala)并重新构建jar。谢谢保存点来自使用状态处理器API处理的保存点,KeyedStateBootstrapFunction中的状态由以下内容组成:
var mapToDetector: MapState[String, Map[String, Det
在我的flink作业中,我将数据保存在mapstate中几分钟,以便进一步处理,在process元素中,我需要在mapstate值的帮助下执行一组操作,所以我在mapstate内容的帮助下使用多个线程进行处理线程没有修改状态,它只获取导致CocurrentModification异常的键值,这个TTL异常也出现在COnfigured TTL时间之前,日志如下。:470)
at org.<em
我正在编写一个Flink应用程序,它使用kafka主题中的时间序列数据。时间序列数据包含指标名称、标记键值对、时间戳和值等组件。我正在考虑使用flink的"allowedLateness“功能将延迟指标发送到不同的流。我计划在主"Aggregate the data“操作符中添加一个"MapState”,它将键作为度量关键字,将值作为到达主窗口的度量计数。,“收集延迟指标并找到延迟指标的百分比”操作员能否访问主流更新<em
Streaming non window left outer join是flink1.6中的一个新特性。当我在两个动态表之间执行此操作时。join结果顺序错误。如何正确使用此功能?NonWindowJoin左表的状态和右表的状态都使用flink托管状态MapState。当我查看flink的non window join代码时。我搞混了:(1) MapState的关键字是Row object。Ro