flink流具有多个数据流,然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。然后,我得到了问题,数据流是混乱的,我不能设置窗口来对数据流中的数据进行排序。Sorting union of streams to identify user sessions in ApacheFlink 我得到了答案
我目前在流应用程序中使用Apache 1.13.2和Java。我使用的是没有窗口功能的键控函数。我已经实现了一个水印策略和每个文档的autoWatermarkInterval配置,虽然我的水印没有前进。通过使用Flink web UI并在我的EventProcessor KeyedProcessFunction中打印当前的水印,我已经对此进行了二次检查,但是水印经常被设置为非常大的负数-9223372036854775808(最低可能的水印</