Re: Flink Batch 模式下,The rpc invocation size 113602196 exceeds the maximum akka framesize

2020-09-29 Thread zheng faaron
Hi, 可以检查一下这个参数是否设置正确,也可以在jobmanager页面上看下是否有这个参数。我之前遇到过类似问题,设置这个参数可以解决问题。 Best, Faaron Zheng From: jy l Sent: Monday, September 28, 2020 4:57:46 PM To: user-zh@flink.apache.org Subject: Re: Flink Batch 模式下,The rpc invocation size 113602196 exceeds the maximum

Why setAllVerticesInSameSlotSharingGroupByDefault is set to false in batch mode

2020-09-15 Thread zheng faaron
Hi All, I find we set AllVerticesInSameSlotSharingGroupByDefault to false in flink 1.10. It will make batch job request lots of containers. I'm not sure why we set it to false directly. I try to set it to true and find the batch job can run correctly with a small amount containers. Why don't

Re: flink1.9.3 on yarn 提交任务问题

2020-09-08 Thread zheng faaron
Hi, 第一个问题,per-job的方式和session的方式在运行时是不在一个ui中的。 第二个问题,可以配置yarn. container. vcore Best, Faaron Zheng From: 宁吉浩 Sent: Monday, September 7, 2020 3:23:12 PM To: user-zh Subject: flink1.9.3 on yarn 提交任务问题 我选择用 bin/flink run -m yarn cluster 的方式提交任务; 遇到了两个问题: 1.