【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

相关内容

热门资讯

济南起步区“民生政策进社区”活...   鲁网12月26日讯深冬微寒,社区里却暖意融融。在起步区崔寨街道凤凰理想社区的小广场上,一排排政策...
振芯科技召开临时股东大会 三项... 围绕振芯科技(300101)的控制权纷争已延续数年之久,如今,双方又针对多项上市公司相关治理制度修订...
吉利威睿起诉欣旺达动力:因电芯... 据悉,吉利旗下威睿电动汽车技术(宁波)有限公司起诉欣旺达动力科技股份有限公司,索赔金额高达23亿元。...
央行:将实施更加积极有为的宏观... 近日,中国人民银行发布了《中国金融稳定报告(2025)》。下一步,金融系统将实施更加积极有为的宏观政...
阳西各镇妇联开展农村妇女法律讲... 12月以来,阳西县妇联联合阳西县司法局,组织各镇开展农村妇女法律讲座系列活动,旨在深入贯彻落实法治乡...
重构人才评价体系 成都东部新区... 封面新闻记者 柴枫桔 12月26日,成都东部新区产业人才政策发布会暨2025年四季度“双招双引”投资...
“鲜”人一步!自贸试验区昆明片... 目前,中国是全球最大的榴莲进口国,占全球市场份额90%以上,云南榴莲进口量已跃居全国第二、西部第一。...
废旧动力电池回收和综合利用管理... 记者在调研中了解到,动力电池回收产业在政策扶持与资本涌入下催生了庞大的产能;但另一方面,早期布局的产...
重庆建工(600939)披露涉... 截至2025年12月26日收盘,重庆建工(600939)报收于3.3元,较前一交易日下跌2.37%,...
欣旺达子公司被起诉,涉案金额2... 【大河财立方消息】12月26日,欣旺达发布公告称,公司子公司欣旺达动力科技股份有限公司作为被告,于2...