时间戳

Question

我有一个Flink程序，它接受两个流，即数据/传感器读数流和警报规则流。我正在广播规则流，并将其连接到数据流以生成动态警报。ProcessingTime的一切都很好，但EventTime却不行。我已经分配了时间戳

>

当两个流（即带有时间戳的流）同时出现时，如何使用“EventTime”生成警报

我是否也必须为我的规则流分配时间戳和水印？

因为我的规则流只有在有任何添加/修改时才会有记录。是否有任何解决方法或黑客来避免/克服这种情况？

任何帮助/建议将不胜感激。

-我试过了！我只尝试了一个流，即数据流，通过硬编码的窗口规则生成警报。它运行良好。但是当我将它与规则流连接时，它无法生成任何警报/输出。

处理时间一切正常，但事件时间则不然。

--我所期望的！我希望我的程序在将连续数据流与非连续规则流连接时能够正常工作，以使用“EventTime”生成动态警报。

Answer 1

Flink培训中的这个练习正好涵盖了这种情况：https://training.ververica.com/exercises/taxiQuery.html.有关详细信息，请参阅提示和解决方案，但所采取的方法是在流上使用这个时间戳提取器/水印生成器，规则如下：

// Once the two streams are connected, the Watermark of the KeyedBroadcastProcessFunction operator
// will be the minimum of the Watermarks of the two connected streams. Our query stream has a default
// Watermark at Long.MIN_VALUE, and this will hold back the event time clock of the
// KeyedBroadcastProcessFunction, unless we do something about it.
public static class QueryStreamAssigner implements AssignerWithPeriodicWatermarks<String> {
    @Nullable
    @Override
    public Watermark getCurrentWatermark() {
        return Watermark.MAX_WATERMARK;
    }

    @Override
    public long extractTimestamp(String element, long previousElementTimestamp) {
        return 0;
    }
}

这具有使另一个流完全负责水印的效果，这是在这种情况下想要的。