当前位置:网站首页>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 参数就能正常显示
边栏推荐
- CPU exception handling
- 大咖讲 | 最前沿的昇思MindSpore开源社区运营的经验分享,快拿出小本本记录呀!
- 新型冠状病毒变异Delta毒株的模拟(MindSPONGE应用)
- JSON解析,ESP32轻松获取时间气温和天气
- test
- find_circ详细使用指南
- 2022健康博览会,山东养生保健展会,产后健康、睡眠健康展
- Moher College - SQL injection vulnerability test (error reporting and blind note)
- Interface test framework practice (I) | requests and interface request construction
- 互联网行业,常见含金量高的证书,看看你有几个?
猜你喜欢
![统计无向图中无法互相到达点对数[经典建邻接表+DFS统计 -> 并查集优化][并查集手册/写的详细]](/img/cc/a0be58eddc72c22a9a6ee5c61eb81a.png)
统计无向图中无法互相到达点对数[经典建邻接表+DFS统计 -> 并查集优化][并查集手册/写的详细]

Special topic II on mathematical physics of the sprint strong foundation program

温故知新--常温常新

Oracle database basics concepts

Is there anyone who doesn't know the three cores of concurrent programming?

大赛报名 | AI+科学计算重点赛事之一——中国开源科学软件创意大赛,角逐十万奖金!

当Transformer遇见偏微分方程求解

其他服务注册与发现

全网最全的混合精度训练原理

Network in network (dolls)
随机推荐
目标追踪拍摄?目标遮挡拍摄?拥有19亿安装量的花瓣app,究竟有什么别出心裁的功能如此吸引用户?
com.fasterxml.jackson.databind.exc.MismatchedInputException: Expected array or string. at [Source:x
光谱共焦如何测量玻璃基板厚度
墨者学院-SQL注入漏洞测试(报错盲注)
MySQL之账号管理、建库以及四大引擎+案例
Simulation of delta variant strain of novel coronavirus (mindsponge application)
idea 热启动失效解决方案
Solution of idea hot start failure
2022年地理信息系统与遥感专业就业前景与升学高校排名选择
温故知新--常温常新
全網最全的混合精度訓練原理
中信证券佣金 网上开户炒股安全吗
巧记大小端字节序
解决STC8G1K08程序不能运行的问题和端口配置
These 10 copywriting artifacts help you speed up the code. Are you still worried that you can't write a copywriting for US media?
05 | 規範設計(下):commit 信息風格迥异、難以閱讀,如何規範?
當Transformer遇見偏微分方程求解
如何写好测试用例以及go单元测试工具testify简单介绍
Leetcode skimming 4 Find the median of two positive arrays
全网最全的混合精度训练原理