当前位置:网站首页>Flink 实战问题(七):No Watermark(Watermarks are only available EventTime is used)
Flink 实战问题(七):No Watermark(Watermarks are only available EventTime is used)
2022-06-27 00:12:00 【码农_程序员】
实现窗口统计时,出现No Watermark(Watermarks are only available EventTime is used)
问题分析:
我们在推送数据时,有消费数据,但是一直提示No Watermark,查找官方网文档:
Flink 对于 Kafka 支持发送按分区的 watermark。Watermark 在 Kafka consumer 中生成。 按分区 watermark 的合并方式和在流 shuffle 时合并 Watermark 的方式一致。 Source 输出的 watermark 由读取的分区中最小的 watermark 决定。 如果 topic 中的某些分区闲置,watermark 生成器将不会向前推进。 你可以在表配置中设置 'table.exec.source.idle-timeout' 选项来避免上述问题
在StreamTableEnvironment设置table.exec.source.idle-timeout 参数就能正常显示
边栏推荐
猜你喜欢
自定义MVC(导成jar包)+与三层架构的区别+反射+面试题
[UVM actual battle== > episode_3] ~ assertion, sequence, property
墨者学院-SQL注入漏洞测试(报错盲注)
技术干货|极速、极智、极简的昇思MindSpore Lite:助力华为Watch更加智能
The most complete hybrid precision training principle in the whole network
Skills needing attention in selection and purchase of slip ring
Deep learning method for solving mean field game theory problems
07 | 工作流设计:如何设计合理的多人开发模式?
滑环安装有哪些技巧和方法
运用物理信息神经网络求解流体力学方程
随机推荐
当Transformer遇见偏微分方程求解
股票怎样在手机上开户安全吗 网上开户炒股安全吗
冲刺强基计划数学物理专题二
Com. Faster XML. Jackson. DataBind. Exc.mismatchedinputexception: tableau ou chaîne attendu. At [Source: X
玩转OLED,U8g2动画,增长数字和随机三角形等
The fourth bullet of redis interview eight part essay (end)
Oracle 数据库基本知识概念
How to control the quality of HD slip ring in the production process
How to easily describe the process of machine learning?
统计无向图中无法互相到达点对数[经典建邻接表+DFS统计 -> 并查集优化][并查集手册/写的详细]
How to write test cases and a brief introduction to go unit test tool testify
Big guys talk about the experience sharing of the operation of the cutting-edge mindspore open source community. Come up with a small notebook!
com.fasterxml.jackson.databind.exc.MismatchedInputException: Expected array or string. at [Source:x
【UVM实战 ===> Episode_3 】~ Assertion、Sequence、Property
In depth understanding of UDP in the transport layer and the use of UDP in sockets
CEC-I 中华学习机使用说明与问答
Technical dry goods | what is a big model? Oversized model? Foundation Model?
test
Is it reliable to speculate in stocks by mobile phone? Is it safe to open an account and speculate in stocks online
From bitmap to bloom filter, C # implementation