[
https://issues.apache.org/jira/browse/FLINK-940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14035695#comment-14035695 ]
Bastian Köcher commented on FLINK-940:
--------------------------------------
We tried also with degree-of-parallelism of 4, but it still didn't work.
I think you misunderstand our shitty output.^^ The problem is that the "PointUpdater" or "PointUpdaterReverse" class should output each round something like "Merging document XY into cluster ZX", but this didn't happen. If the solutionset is the second input of the coGroup we get some results, but not all. That's weird because both versions should output the same amount of lines.
> 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)
Locked
