I'm using the 0.9.1 official release.
My input data are read form a text file 'activity' (provided as attachment):
My script is working correctly:
After running this script, the 'output' file contains a correct result:
But the issue occurs when I use BinStorage() instead of PigStorage() to store / reload my temporary files. The 'output' file in that case is not complete:
The not working script is the following:
So the issue seems to be located in the way the BinStorage() store or load bags.