Re:Re: Re: Flink SQL 应用情况请教

2021-02-27 文章 邮件帮助中心
感谢您的答复,刚才看到您的答复后,紧急远程连接跑了下,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

Re: Re: Flink SQL 应用情况请教

2021-02-27 文章 xg...@126.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的值,其中

回复:Flink checkpoint 速度慢问题请教

2021-02-27 文章 熊云昆
你的checkpoint是用rocksdb还是filesystem?磁盘不同确实会影响checkpoint速度的 | | 熊云昆 | | 邮箱:xiongyun...@163.com | 签名由 网易邮箱大师 定制 在2021年02月27日 14:14,Jacob 写道: Hi All, 生产环境有一个Job,在hadoopA集群运行稳定正常,checkpoint速度也很快(checkpoint间隔时间是30s,每一个checkpoint大小几十kb,做一次checkpoint耗时为毫秒级别) 相同的