[PIG-3786] POReservoirSample should handle endOfAllInput flag

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: tez-branch
• Fix Version/s: tez-branch
• Component/s: tez
• Assignee: Daniel Dai
• Reporter: Daniel Dai
• Created: 28/Feb/14 20:38
• Updated: 21/Nov/14 05:58
• Resolved: 06/Mar/14 18:30

Description

POReservoirSample assumes it always get STATUS_OK until it hits STATUS_EOP, means all inputs finished. This is not true if the plan also contains a POStream, since POStream will issue a STATUS_EOP even if inputs are not exhausted. Need to make POReservoirSample handles STATUS_EOP and endOfAllInput flag. This cause e2e test failure such as ComputeSpec_3.

POPoissonSample should do the same.