You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2019/04/17 07:53:00 UTC
[jira] [Updated] (BEAM-7091) FlinkRunner: NPE in DoFnOperator
[ 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)