Redis等外部存储),则会导致重复计算,中间状态可能因为无法幂等的操作而被破坏,最终导致正确性出现问题flink 有状态udf 引起血案一这个Flink社区已有对应的讨论,但是已知没有具体的后续,详见:FLINK
UDF表达式重用(FLINK-21573) UDF重复调用的问题在某些情况下可能会对Flink SQL用户造成困扰,例如下面的SQL语句: SELECT mp['eventType'] AS eventType