[PIG-1911] Infinite loop with accumulator function in nested foreach

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Fix Version/s: 0.8.1
• Assignee: Thejas Nair
• Reporter: Olga Natkovich
• Created: 16/Mar/11 21:06
• Updated: 25/Apr/11 21:27
• Resolved: 08/Apr/11 19:13

Description

Sample script:

register v_udf.jar;
a = load '2records' as (f1:chararray,f2:chararray);
b = group a by f1;
d = foreach b

{ sort = order a by f1; generate org.udfs.MyCOUNT(sort) as something ; }

dump d;

This causes infinite loop if MyCOUNT implements Accumulator interface.

The workaround is to take the function out of nested foreach into a separate foreach statement.