Re: Question on Task Chaining

2015-11-07 Thread Isha Arkatkar
ll. In that > case, the FilterFunction will be in a different slot than the MapFunction. > The system will try to co-locate them (locality aware scheduling), so they > may end up in the same JVM if that TaskManager had more free slots. If not, > they run in different JVMs. > > Hope

Question on Task Chaining

2015-11-06 Thread Isha Arkatkar
Hi all, I am new to flink and wanted to understand effects of setting task chaining and resource group allocation. I tried following configurations, with task slots set to 2: 1. map(..).disableChaining.filter(..) In this case, I can see 2 vertices for this application, both on the same no