谢谢 Zhanghao。上午已经测试过了,简单功能是可以,后面会进一步验证这个试验性功能。
在 2022/7/15 下午12:26,“Zhanghao
Chen” 写入:
你好,可以看下:https://www.mail-archive.com/issues@flink.apache.org/msg498605.html
的总结。不过这个特性还是实验性的,请谨慎使用。
Best,
Zhanghao Chen
From: Zhizhao Shangguan
Hi,ALL:
咨询个问题,对于超过watermark后的数据,还想继续触发窗口操作(类似API的allowedLateness机制),flink
SQL可以实现吗? 可以话,要如何处理的?
Thanks♪(・ω・)ノ
HI Wei Zhong,
感谢您的回复!
发现是软链的问题(lib目录下的jar包不能用软链),去掉后就可以了。
在 2021/1/6 上午11:06,“Wei
Zhong” 写入:
Hi Zhizhao,
能检查一下'file://' 后面跟的是绝对路径吗?这个报错是因为对应的路径在本地磁盘上找不到导致的。
> 在 2021年1月6日,10:23,Zhizhao Shangguan 写道:
>
> Hi:
> PyFlink on Yarn,
Per-Job模式,如何增加多