You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/07/02 16:42:26 UTC

[jira] [Commented] (FLINK-997) NullPointerException in BinaryUnionReplacer for unions in iterations

    [ https://issues.apache.org/jira/browse/FLINK-997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14049967#comment-14049967 ] 

Till Rohrmann commented on FLINK-997:
-------------------------------------

The problem is that a union currently cannot be at the root of a data flow. A solution would be to insert an identity mapper in the BinaryUnionReplacer. However, then we have to generate two different plans, one for the record-based API and another for the new operators. Currently, I don't know from where I can retrieve the information whether the plan has been generated using the old or new API....

Maybe we should wait until the Scala API has been moved to the new operators. Then we can easily attach an identity mapper to union roots of iterations.

> NullPointerException in BinaryUnionReplacer for unions in iterations
> --------------------------------------------------------------------
>
>                 Key: FLINK-997
>                 URL: https://issues.apache.org/jira/browse/FLINK-997
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>
> The BinaryUnionReplacer throws a NullPointerException when replacing binary unions in an iteration which are also the last node of the iteration. The NullPointerException occurs when the outgoing channels are requested.



--
This message was sent by Atlassian JIRA
(v6.2#6252)