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)
