从1.4.2迁移到1.14.2时的Flink接收时间实施

wztqucjr 于 2022-12-09 发布在 Apache

关注(0)|答案(1)|浏览(94)

We have stream processing pipeline to ingest Kafka messages. And we were using Flink v1.4.2. and now planning to migrate to 1.14.2.
Timestamps are based on ingest-time. As env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime) is depcreated since 1.12 , how to set this ??
Which watermark strategy should be used ?
timeWinow() is also deprecated. I Couldn't find way to use: window(SlidingIngestionTimeWindows.of()) only SlidingProcessingTimeWindows/SlidingEventTimeWindows available.
Thanks.

apache-flink

来源：https://stackoverflow.com/questions/74569213/flink-ingestiontime-implementation-while-migrating-from-1-4-2-to-1-14-2

1条答案

按热度按时间

km0tfn4u1#

What you can do is to use a watermark strategy like this one

WatermarkStrategy<Event> wmStrategy =
    WatermarkStrategy
        .<Event>forMonotonousTimestamps()
        .withTimestampAssigner((event, timestamp) -> System.currentTimeMillis());

in combination with SlidingEventTimeWindows.

赞(0）回复(0）举报 2022-12-09

我来回答

从1.4.2迁移到1.14.2时的Flink接收时间实施

1条答案

相关问题

热门标签

最新问答