当前位置:网站首页>Flink Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic
Flink Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic
2022-08-08 08:13:00 【Allen-1】
1.flink流式处理
解决方案:修改滑动处理时间的时间间隔
.window(TumblingProcessingTimeWindows.of(Time.seconds(2)
2.修改后的代码
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.assigners.{
TumblingEventTimeWindows, TumblingProcessingTimeWindows}
import org.apache.flink.streaming.api.windowing.time.Time
//flink的watermark字段处理
object Streaming_job {
def main(args: Array[String]): Unit = {
// 创建环境
val env = StreamExecutionEnvironment.getExecutionEnvironment
// 获取本地数据
val text = env.socketTextStream("127.0.0.1", 7777)
// val text = "aaa"
import org.apache.flink.api.scala._
// 开发业务的逻辑
text.flatMap(_.split(" "))
.map((_,1))
.keyBy(0)
.window(TumblingProcessingTimeWindows.of(Time.seconds(2)))
.sum(1)
.print()
.setParallelism(1)
env.execute("Flink Streaming WordCount")
}
}
3.结果展示
参考博客:
https://blog.csdn.net/u010002184/article/details/115726664
http://t.zoukankan.com/-courage-p-14804510.html
边栏推荐
猜你喜欢

IIC通讯协议与EEPROM简介

要写脚本,编程不好不要紧--浅谈CTF中脚本的编写方法

蓝牙Mesh的基本概念

【项目问题】Ionic开发移动端app,手把手教你如何打包生成apk

CesiumJS 更新日志 1.96 与 1.97 - 新构建工具 esbuild 体验及 Model API 更替完成

DVWA full level detailed customs clearance tutorial

文献学习(part33)--Clustering by fast search and find of density peaks

音视频入门知识-- --相关名词、术语、概念

Nacos是如何实现心跳机制和服务续约以及超时剔除服务机制的?

【优化调度】基于粒子群实现并网模型下微电网的经济调度优化附matlab代码
随机推荐
js中call、bind、apply的区别?
JLink Commander调试方法
anormly detection资料汇总
物联网安全 - 对称加密算法
关于 QtCreator使用msvc2017x64编译器编译项目报错”编译器的堆空间不足“错误 的解决方法
蓝牙5.2新特性 LE Audio - Isochronous channel
物联网安全 - 密码学概述
蓝牙5.2新特性 - Enhance ATT
【树莓派】vim编辑器
我的MySQL安装这样了怎么解决也
ES8 | async和await
VSCode代码格式化快捷键及保存时自动格式化
oracle如何删除表并且释放表空间
mockserver使用
数学基础(一)矩阵对角化、SVD分解以及应用
最强分布式锁工具:Redisson
mysql三种安装方式 你知道了哪种
Today share how to submit a bug
看顶级测工怎么玩转Apifox接口测试工具
想用sql实现两日数据对比后,对新增数据单加一列标签