Are you processing the bag in the UDF? Can you send sample records which is going in to UDF using dump command for alias C?
If the data is(alias A)
(key1,d1,d2)
(key2,d1,d3)
(key1,d1,d4)
(key1,d1,d5)
On grouping on 1st column the data should be grouped as below
{(key1),{ (key1,d1,d2), (key1,d1,d4), (key1,d1,d5) }}
{(key2),{ (key2,d1,d3) }}
If you are providing the data A to UDF you should get all records with
respect to same key in same bag.
--
Suraj Nayak
