[
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)
