Robert Bradshaw created BEAM-4781:
-------------------------------------
Summary: 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: runner-flink
Reporter: Robert Bradshaw
Assignee: Aljoscha Krettek
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
(v7.6.3#76005)
