[jira] [Closed] (BEAM-7091) FlinkRunner: NPE in DoFnOperator

["Maximilian Michels (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Maximilian Michels closed BEAM-7091.
------------------------------------
       Resolution: Fixed
         Assignee: Jan Lukavsky
    Fix Version/s: 2.13.0

Thanks for reporting!

> 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ý
>            Assignee: Jan Lukavsky
>            Priority: Minor
>             Fix For: 2.13.0
>
>          Time Spent: 50m
>  Remaining Estimate: 0h
>
> 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)