Re: Network PartitionNotFoundException when run on multi nodes

2018-07-23 Thread Steffen Wohlers
ed > from JobManager, or some operations in upstream task initialization > unexpectly cost more time before registering result partition. > > Best, > Zhijiang > -- > 发件人:Steffen Wohlers > 发送时间:2018年7月22日(星期日)

回复:Network PartitionNotFoundException when run on multi nodes

2018-07-22 Thread Zhijiang(wangzhijiang999)
22:22 收件人:user 主 题:Network PartitionNotFoundException when run on multi nodes Hi all, I have some problems when running my application on more than one Task Manager. setup: node1: Job Manager, Task Manager node2: Task Manager I can run my program successfully on each node alone when I stop the

Re: Network PartitionNotFoundException when run on multi nodes

2018-07-22 Thread zhangminglei
Hi, Steffen You can take a look on this https://github.com/apache/flink/pull/6103 . Hopes can help! Cheers Minglei > 在 2018年7月22日,下午10:22,Steffen Wohlers 写道: > > Hi all, > > I have some problems when running my application on more than one Task > M

Network PartitionNotFoundException when run on multi nodes

2018-07-22 Thread Steffen Wohlers
Hi all, I have some problems when running my application on more than one Task Manager. setup: node1: Job Manager, Task Manager node2: Task Manager I can run my program successfully on each node alone when I stop the other Task Manager. But when I start both and set parallelism = 2, every time