[FLINK-5088] Add option to limit subpartition queue length

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.1.3
• Component/s: Runtime / Network
• Assignee: Ufuk Celebi
• Reporter: Ufuk Celebi
• Created: 17/Nov/16 14:09
• Updated: 12/Dec/16 16:58
• Resolved: 12/Dec/16 16:58

Description

Currently the sub partition queues are not bounded. Queued buffers are consumed by the network event loop or local consumers.

Issue Links

• links to: GitHub Pull Request #2883