In my job, I have a input stage and pass it to aggregator stage.
My aggregator sometimes gives correct value and sometimes not. There is no change in data
I have values in below manner :
GroupKey COL_1 COL_2
a 8.127035 2.608613
a 3.499208 -3.6E-5
Sometimes it aggregrates and displays the result as below
GroupKey COL_1 COL_2
a 11.626243 2.608577
At sometimes, It displays the result in below manner
GroupKey COL_1 COL_2
a 8.127035 2.608613
There is no aggregation taking place here, It displays only one record and other record is not found in output.
Please suggest.