flink写入hdfs文件大小和时间间隔
【摘要】 sink.setBatchSize(1024 * 1024 * 400L); // this is 400 MB,
sink.setBatchRolloverInterval(20 * 60 * 1000L); // this is 20 mins
注意：batchSize和BatchRolloverInterval一定要加L，虽然不加L也不会报错，
但笔者遇到一个坑设置10...
sink.setBatchSize(1024 * 1024 * 400L); // this is 400 MB,
sink.setBatchRolloverInterval(20 * 60 * 1000L); // this is 20 mins
注意：batchSize和BatchRolloverInterval一定要加L，虽然不加L也不会报错，
但笔者遇到一个坑设置102410241024*50 (50G)程序也不报错，但是把int类型转换为long类型，值变成了-2147483648。
batchsize就失效了。
文章来源: www.jianshu.com，作者：百忍成金的虚竹，版权归原作者所有，如需转载，请联系作者。
原文链接：www.jianshu.com/p/01972d95b88e
【版权声明】本文为华为云社区用户转载文章，如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）