[FLINK-6550] Calling ctx.collect with a null OutputTag should log a warning or throw an exception

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.4.0
• Component/s: API / DataStream
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 11/May/17 15:09
• Updated: 19/Jul/17 08:46
• Resolved: 18/Jul/17 19:01

Description

When using side outputs it is currently possible to call

{Context#collect(OutputTag<X>, X record)}

with null for the OutputTag. Effectively this causes the data to be swallowed. It is unlikely that a user actually intends this, so i propose to either log a warning or throw an exception.

Issue Links

• links to: GitHub Pull Request #4312