[
https://issues.apache.org/jira/browse/BEAM-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-7091:
-------------------------------
Description:
Under some unknown conditions - probably caused by some other error - I see
following trace in flink's taskmanager:
{code:java}
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).
was:
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).
> 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ý
> Priority: Minor
>
> Under some unknown conditions - probably caused by some other error - I see
> following trace in flink's taskmanager:
> {code:java}
> 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)
