[DRILL-640] Limit operator leaks memory when used with exchanges

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Assignee: Mehant Baid
• Reporter: Mehant Baid
• Created: 05/May/14 22:25
• Updated: 31/Jul/14 06:33
• Resolved: 08/May/14 03:07

Description

Limit operator currently invokes kill() when it reaches the desired limit of records. Current semantic of kill() does not stop upstream operators if they are across exchanges. So its the responsibility of the operator to drain out all the record batches and clear the memory, otherwise we will hit memory leaks.