You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/05/12 09:16:04 UTC

[jira] [Commented] (FLINK-6552) Ambiguous error message when retrieving multiple side-outputs

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

Aljoscha Krettek commented on FLINK-6552:
-----------------------------------------

Absolutely right, the message should be {{"Trying to add a side output for the same side-output id with a different type. This is not allowed."}} (Notice how it also says "side input" in the original message).

It should be possible to have multiple side outputs with different types. Where did this not work? I'm also wondering why you see this error message, it should already be caught by this: https://github.com/apache/flink/blob/922352ac35f3753334e834632e3e361fbd36336e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java#L447-L447

> Ambiguous error message when retrieving multiple side-outputs
> -------------------------------------------------------------
>
>                 Key: FLINK-6552
>                 URL: https://issues.apache.org/jira/browse/FLINK-6552
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API
>    Affects Versions: 1.3.0, 1.4.0
>            Reporter: Chesnay Schepler
>
> When calling {SingleOutputStreamOperator#getSideOutput(OutputTag<X>} multiple times with the output tags having different types you get the following exception:
> {code}
>  "Trying to add a side input for the same id with a different type. This is not allowed." 
> {code}
> This error message is ambiguous, as it could either mean that you cannot add 2 side outputs with the same name but different types or that 2 side outputs with different types cannot be retrieved from a single operator.
> Furthermore, the error message contains the concept of node id's (i guess?) which users aren't exposed to. This is confusing and should be reworded to work with operators.
> Lastly, i find this limitation rather odd. It is possible for an operator to have multiple side outputs. It is also possible to have a side output with a different type than the main output. Yet, it is not possible to have multiple side outputs with different types.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)