感谢您的答复,刚才看到您的答复后,紧急远程连接跑了下,stdout还真的有数据出来了,周一上班时间再好好测试下,万分感谢!
在 2021-02-27 19:08:25,"xg...@126.com" 写道:
>1503,61,15811,1614405166858
>1504,61,15813,1614405333871
>1505,61,15814,1614405544862
>1506,61,15814,1614405673863
>就这几条数据,并行度设置为1
>
>
>
>发件人: yinghua...@163.com
1503,61,15811,1614405166858
1504,61,15813,1614405333871
1505,61,15814,1614405544862
1506,61,15814,1614405673863
就这几条数据,并行度设置为1
发件人: yinghua...@163.com
发送时间: 2021-02-27 14:23
收件人: user-zh
主题: Re: Flink SQL 应用情况请教
这个问题不知道是不是这个原因导致的,我在Flink的webUI监控界面source和sink任务中都没看到watermark的值,其中
你的checkpoint是用rocksdb还是filesystem?磁盘不同确实会影响checkpoint速度的
| |
熊云昆
|
|
邮箱:xiongyun...@163.com
|
签名由 网易邮箱大师 定制
在2021年02月27日 14:14,Jacob 写道:
Hi All,
生产环境有一个Job,在hadoopA集群运行稳定正常,checkpoint速度也很快(checkpoint间隔时间是30s,每一个checkpoint大小几十kb,做一次checkpoint耗时为毫秒级别)
相同的