当前位置:网站首页>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
边栏推荐
猜你喜欢
随机推荐
【vulhub】PostGresql高权限命令执行漏洞复现(CVE-2019-9193)
数学基础(二)逆矩阵、伪逆矩阵、最小二乘解、最小范数解
数控机床工作平台位置伺服系统的的数学建模与仿真
CesiumJS 更新日志 1.96 与 1.97 - 新构建工具 esbuild 体验及 Model API 更替完成
物联网安全 - 密码学概述
spark2 sql struct处理
VSCode代码格式化快捷键及保存时自动格式化
攻防世界——fakebook
antdv4 升级指北
超强的企业建站系统介绍:功能模块
你真的了解IP地址吗?
音视频入门知识-- --相关名词、术语、概念
anormly detection资料汇总
【项目问题】Ionic开发移动端app,手把手教你如何打包生成apk
SSRF漏洞
At the time of data intelligence, Jiuzhang Yunji DataCanvas won the "Most Investment Value Company"
小程序 数据监听(observers),避免赋值死循环
数据治理(三):数据质量管理
vscode格式化代码快捷键
六十分之七——焦虑路上的涅槃