Fix

apache · Dec 13, 2017 · 80231ab · 80231ab
1 parent e40c2f1
commit 80231ab
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java b/sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java
@@ -144,6 +144,7 @@ public Iterator<UnsafeRow> sort() throws IOException {
 
   public Iterator<UnsafeRow> sort(Iterator<UnsafeRow> inputIterator) throws IOException {
     final UnsafeSorterIterator[] sortedIterator = new UnsafeSorterIterator[1];
+    sortedIterator[0] = sorter.getSortedIterator();
     return new AbstractIterator<UnsafeRow>() {
       // inputIterator == null means the rows has been inserted
       boolean inserted = inputIterator == null;