Re: Can flink aggregate in local TM,then aggregate in global TM?

2017-12-17 Thread zhaifengwei
Hi Fabian Hueske-2, Thanks for your reply.This is exactly what I was looking for. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Can flink aggregate in local TM,then aggregate in global TM?

2017-12-14 Thread zhaifengwei
I have a cluster environment, I need aggregate dataStream on it. I`m wonder whether I can aggregate in local server first, then aggregate in global. When I aggregate dataStream in global, the Network IO will increase fast. I just want decrease the Network IO, So I need aggregate in local server