[jira] [Created] (FLINK-2953) Chained sortPartition() calls produce incorrect results in Scala DataSet API

["Fabian Hueske (JIRA)" <ji...@apache.org>]

Fabian Hueske created FLINK-2953:
------------------------------------

             Summary: Chained sortPartition() calls produce incorrect results in Scala DataSet API
                 Key: FLINK-2953
                 URL: https://issues.apache.org/jira/browse/FLINK-2953
             Project: Flink
          Issue Type: Bug
          Components: DataSet API, Scala API
    Affects Versions: 0.9, 0.10, 1.0
            Reporter: Fabian Hueske
            Assignee: Fabian Hueske
            Priority: Blocker
             Fix For: 0.9.2, 0.10


Chaining for {{sortPartition()}} calls does not work correctly in Scala DataSet API.

{code}
val x: DataSet[(Int, Int, Int)] = ... //
x
  .sortPartition(0, Order.DESCENDING)
  .sortPartition(2, Order.ASCENDING)
  .print()

// result
(1,2,3)
(1,3,4)
(1,2,5)
(3,7,8)

// should be
(3,7,8)
(1,2,3)
(1,3,4)
(1,2,5)
{code}

The same program in the Java DataSet API works correctly.




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