You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 邓成刚【qq】 <bn...@qq.com> on 2019/03/28 09:02:27 UTC
关于Blink 消费kafka并行度问题
请教一下,Blink 消费kafka数据时,把并行度设置 30 ,就会出现Timeout,JOB跑不起来,应该是没有消费到数据,把并行度调 到 5就没问题,另外,JOB用到4个TOPic,每个30个PARTITION,但是把这同样JOB提交给FLINK 设置 30 并行度 就可以跑起来,有哪位大佬知道什么情况吗?
回复:关于Blink 消费kafka并行度问题
Posted by zhisheng <ti...@foxmail.com>.
爆错信息可以提供一下
------------------ 原始邮件 ------------------
发件人: "邓成刚【qq】"<bn...@qq.com>;
发送时间: 2019年3月28日(星期四) 下午5:02
收件人: "user-zh"<us...@flink.apache.org>;
主题: 关于Blink 消费kafka并行度问题
请教一下,Blink 消费kafka数据时,把并行度设置 30 ,就会出现Timeout,JOB跑不起来,应该是没有消费到数据,把并行度调 到 5就没问题,另外,JOB用到4个TOPic,每个30个PARTITION,但是把这同样JOB提交给FLINK 设置 30 并行度 就可以跑起来,有哪位大佬知道什么情况吗?