flink1.15.4以上版本，wartermark在flink webui显示和通过ctx.currentWatermark()获取的不一致的问题
2.主流关联广播流，广播流的wartermark设置Long.MAX_VALUE, 再进行keyby后通过KeyedBroadcastProcessFunction算子出来，在主流没数据的时候算子中wartermar从最小值直接变成最大值，但在flink1.13.2版本主流没数据时waterMark一直是最小值？
flink1.15.4以上版本获取的不一致的问题？[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！