Could you please send a screenshot?
> On 20. Feb 2018, at 11:09, Aneesha Kaushal <aneesha.kaus...@reflektion.com>
> wrote:
>
> Hello Aljoscha
>
> I looked into the Subtasks session on Flink Dashboard, for the about two
> tasks.
>
> Thanks
> Aneesha
>
>> On 20-Feb-2018, at 3:32 PM, Aljoscha Krettek <aljos...@apache.org
>> <mailto:aljos...@apache.org>> wrote:
>>
>> Hi,
>>
>> Could you please also post where/how you see which tasks are mapped to which
>> slots/TaskManagers?
>>
>> Best,
>> Aljoscha
>>
>>> On 20. Feb 2018, at 10:50, Aneesha Kaushal <aneesha.kaus...@reflektion.com
>>> <mailto:aneesha.kaus...@reflektion.com>> wrote:
>>>
>>> Hello,
>>>
>>> I have a fink batch job, where I am grouping dataset on some keys, and then
>>> using group reduce. Parallelism is set to 16.
>>> The slots for the Map task is distributed across all the machines, but for
>>> GroupReduce all the slots are being assigned to the same machine. Can you
>>> help me understand why/when this can happen?
>>> Code looks something like:
>>> dataset.map(MapFunction())
>>> .groupBy(<keys to groupon>)
>>> .sortGroup(<key to sort on>, Order.DESCENDING)
>>> .reduceGroup(GroupReduceFunction()).name("Group reduce")
>>> From flink dashboard:
>>>
>>> <Screen Shot 2018-02-20 at 2.39.35 PM.png>
>>>
>>>
>>> Thanks in advance
>>> Aneesha
>>>
>>>
>>>
>>>
>>
>
