[jira] [Updated] (FLINK-940) DeltaIteration coGroup at SolutionSet doesn't find values

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Updated] (FLINK-940) DeltaIteration coGroup at SolutionSet doesn't find values

Shang Yuanchun (Jira)

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

Bastian Köcher updated FLINK-940:
---------------------------------

    Attachment: IMPRO-3.SS14.G03.zip

Here is the source file for the issue. To illustrate the problem, I commented out one of the lines 390, 391. The lines should be equal, just with reversed input order. Nevertheless, the result is not the same. It seems like some values are simply lost.

> DeltaIteration coGroup at SolutionSet doesn't find values
> ---------------------------------------------------------
>
>                 Key: FLINK-940
>                 URL: https://issues.apache.org/jira/browse/FLINK-940
>             Project: Flink
>          Issue Type: Bug
>          Components: Java API
>    Affects Versions: pre-apache-0.5.1
>            Reporter: Bastian Köcher
>            Assignee: Stephan Ewen
>         Attachments: IMPRO-3.SS14.G03.zip
>
>
> If I execute a coGroup on a SolutionSet, the grouping doesn't find any matching tuples, but if I reverse the grouping(SolutionSet as second set), matching tuples are found.



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