[BEAM-4781] PTransforms that simply return their input cause portable Flink to crash.

• Type: Task
• Status: Resolved
• Priority: P2
• Resolution: Not A Problem
• Fix Version/s: Not applicable
• Component/s: sdk-py-core
• Labels: stale-P2
• Assignee: Unassigned
• Reporter: Robert Bradshaw
• Created: 13/Jul/18 01:41
• Updated: 24/Jul/20 22:19
• Resolved: 02/Jun/20 12:34

Description

E.g.

 

class MaybePrint(beam.PTransform):
   def expand(self, pcoll):
    if some_flag:
      pcoll | beam.Map(logging.info)
    return pcoll