当前位置:网站首页>Flink practical problems (VII): no watermark (watermarks are only available eventtime is used)
Flink practical problems (VII): no watermark (watermarks are only available eventtime is used)
2022-06-27 00:50:00 【Menon_ programmer】
When implementing window statistics , appear No Watermark(Watermarks are only available EventTime is used)

Problem analysis :
When we push data , Consumption data available , But it's always suggested that No Watermark, Find the official website documentation :
Flink about Kafka Support sending partition by partition watermark.Watermark stay Kafka consumer In the middle of . By zone watermark The merging method and in stream shuffle Time merging Watermark In the same way . Source Output watermark The smallest partition read by watermark decision . If topic Some partitions in are idle ,watermark The generator will not advance . You can set... In the table configuration 'table.exec.source.idle-timeout' Option to avoid the above problems
stay StreamTableEnvironment Set up table.exec.source.idle-timeout Parameters can be displayed normally
边栏推荐
- In depth understanding of UDP in the transport layer and the use of UDP in sockets
- [vscode] setting sync, a plug-in for synchronizing extensions and settings
- Simple and fast digital network (network dolls in the network)
- CPU exception handling
- 网络中的网络(套娃)
- These 10 copywriting artifacts help you speed up the code. Are you still worried that you can't write a copywriting for US media?
- 解决STC8G1K08程序不能运行的问题和端口配置
- 07 | 工作流设计:如何设计合理的多人开发模式?
- Interface test framework practice (I) | requests and interface request construction
- 国产框架MindSpore联合山水自然保护中心,寻找、保护「中华水塔」中的宝藏生命
猜你喜欢

1+1<2 ?! HESIC论文解读

Review the old and know the new -- constant renewal at normal temperature

Sword finger offer 10- ii Frog jumping on steps

Flink 实战问题(七):No Watermark(Watermarks are only available EventTime is used)

com.fasterxml.jackson.databind.exc.MismatchedInputException: Expected array or string. at [Source:x

How to control the quality of HD slip ring in the production process

Implementation of ARP module in LwIP

Understanding of "the eigenvectors corresponding to different eigenvalues cannot be orthogonalized"

墨者学院-X-Forwarded-For注入漏洞实战
![自定义JSP[if,foreach,数据,select]标签](/img/a2/fc75c182d572d86f4466323e31d6c3.png)
自定义JSP[if,foreach,数据,select]标签
随机推荐
Target tracking shooting? Target occlusion shooting? With 1.9 billion installed petal apps, what unique features attract users?
墨者学院-X-Forwarded-For注入漏洞实战
Is there anyone who doesn't know the three cores of concurrent programming?
寻找旋转排序数组中的最小值 II[经典抽象二分 + 如何破局左中右三者相等]
What are the skills and methods for slip ring installation
Is it reliable to speculate in stocks by mobile phone? Is it safe to open an account and speculate in stocks online
BootstrapBlazor + FreeSql实战 Chart 图表使用(2)
2022健康博览会,山东养生保健展会,产后健康、睡眠健康展
Central Limit Theorem
万字详解-MindArmour 小白教程!
05 | standard design (Part 2): how to standardize the different styles of commit information, which are difficult to read?
Sword finger offer 10- ii Frog jumping on steps
kubernetes可视化界面dashboard
温故知新--常温常新
LeetCode 142. 环形链表 II
指南针开户安全的吗?
如何把老式键盘转换成USB键盘并且自己编程?
其他服务注册与发现
These 10 copywriting artifacts help you speed up the code. Are you still worried that you can't write a copywriting for US media?
Super hard core! Can the family photo album on Huawei's smart screen be classified automatically and accurately?