Jan Lukavský created BEAM-7091:
----------------------------------
Summary: FlinkRunner: NPE in DoFnOperator
Key: BEAM-7091
URL: https://issues.apache.org/jira/browse/BEAM-7091
Project: Beam
Issue Type: Bug
Components: runner-flink
Affects Versions: 2.11.0
Reporter: Jan Lukavský
Under some unknown conditions - probably caused by some other error - I see
following trace in flink's taskmanager:
{code}
2019-04-17 07:41:17,863 ERROR
org.apache.flink.streaming.runtime.tasks.StreamTask - Error during
disposal of stream operator.
java.lang.NullPointerException
at
org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.dispose(DoFnOperator.java:435)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:477)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:378)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704)
at java.lang.Thread.run(Thread.java:748)
{code}
It looks like there are missing null checks in {DoFnOperator}, which will cause
this if {dispose} is called before {open} (for whatever reason).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
