[ https://issues.apache.org/jira/browse/BEAM-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels closed BEAM-4781. ------------------------------------ Fix Version/s: Not applicable Resolution: Not A Problem Tried out the above and do not see an error like in the description. > PTransforms that simply return their input cause portable Flink to crash. > ------------------------------------------------------------------------- > > Key: BEAM-4781 > URL: https://issues.apache.org/jira/browse/BEAM-4781 > Project: Beam > Issue Type: Task > Components: sdk-py-core > Reporter: Robert Bradshaw > Priority: P2 > Labels: stale-P2 > Fix For: Not applicable > > > E.g. > > {code:python} > class MaybePrint(beam.PTransform): > def expand(self, pcoll): > if some_flag: > pcoll | beam.Map(logging.info) > return pcoll > {code} > -- This message was sent by Atlassian Jira (v8.3.4#803005)