[jira] [Created] (FLINK-1324) Iterations may fail when a cached data set based on a sort is not fully consumed

[Shang Yuanchun (Jira)]

Stephan Ewen created FLINK-1324:
-----------------------------------

             Summary: Iterations may fail when a cached data set based on a sort is not fully consumed
                 Key: FLINK-1324
                 URL: https://issues.apache.org/jira/browse/FLINK-1324
             Project: Flink
          Issue Type: Bug
          Components: Local Runtime
    Affects Versions: 0.8-incubating
            Reporter: Stephan Ewen
            Assignee: Stephan Ewen
             Fix For: 0.8-incubating


This happens for example when a sort feeds into a merge join and the merge join exits early (zig zag merge determined that it can stop).

You can reproduce this bug by running the transitive closure in Scala (or Java with an enforced merge join) using the following toy data set.

{code}
Path(2, 1),
Path(4, 1),
Path(6, 3),
Path(8, 3),
Path(10, 1),
Path(12, 1),
Path(14, 3),
Path(16, 3),
Path(18, 1),
Path(20, 1) );
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)