【Flink】设置了watermark,没有使用watermark触发窗口计算
创始人
2024-03-20 11:04:01
0

Flink的watermark和窗口计算在flink应用中很常用,但是有时候会出现由于第一次用导致出错的情况,下面这种情况就是设置了watermark,但是最后窗口计算没有使用watermark触发。

下面的代码就是经典的单词切分,Flink数据源为socket,socket输入数据格式

hello 10 1669964401000
hello 11 1669964402000
hello 12 1669964403000
hello 13 1669964404000
hello 13 1669964409000

 在此基础上添加watermark以及窗口,但是测试时发现就算设置了事件TimeCharacteristic.EventTime(Flink1.13版本默认事件就是事件事件),设置了watermark,最后窗口计算仍然不是watermark触发

package com.demo;import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;
import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
im

相关内容

热门资讯

中信证券:反内卷”政策强度不断... 每经AI快讯,中信证券研报表示,“反内卷”政策强度不断升级,有望成为持续投资主线。长期看,反内卷需要...
推进检察公益诉讼有何经验 检察公益诉讼制度是习近平法治思想在公益保护领域的生动实践和原创性成果。检察公益诉讼制度取得的成效,是...
龙岗所有青年驿站均已设法律服务... 深圳新闻网2025年7月25日讯(深圳晚报记者 伊宵鸿) 近日,深圳市龙岗区司法局联合共青团深圳市龙...
王传君谈《南京照相馆》演汉奸:... 搜狐娱乐讯 (哈麦/文 马森/图/视频)7月24日,电影《南京照相馆》在北京首映,导演申奥,主演刘昊...
官方:王霄出任青岛红狮俱乐部体... 直播吧7月25日讯 青岛红狮俱乐部官方宣布,王霄正式出任俱乐部体育总监兼中方教练组组长。 青岛红狮俱...
航发控制:已制定市值管理制度强... 证券之星消息,航发控制(000738)07月25日在投资者关系平台上答复投资者关心的问题。 投资者提...
最高资助1500万!龙华发布人... 《大湾区产城速递》第767期 (1)最高资助1500万!龙华发布人才创业政策 日前,龙华区举行“龙舞...
原创 特... 据美国媒体报道,在短短3天内,马斯克在社交媒体上针对白宫相关事务,连续发布35条帖文。这一密集的发声...
欧洲云服务提供商组织起诉欧盟委... 欧洲云基础设施服务提供商协会(CISPE)7月24日宣布向欧洲普通法院正式提出上诉,质疑欧盟委员会此...
省人大常委会审议通过两件地方性... 昆明信息港讯(昆明日报 记者杜仲莹)7月23日,省十四届人大常委会第十八次会议审议通过《中国(云南)...