flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bastian Köcher (JIRA) <j...@apache.org>
Subject [jira] [Updated] (FLINK-940) DeltaIteration coGroup at SolutionSet doesn't find values
Date Tue, 17 Jun 2014 17:09:03 GMT

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

Mime
View raw message