null out row

apache · Jul 27, 2015 · 590f311 · 590f311
1 parent f4cf91d
commit 590f311
Showing 1 changed file with 2 additions and 2 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
@@ -124,7 +124,7 @@ Iterator<InternalRow> sort() throws IOException {
       return new AbstractScalaRowIterator() {
 
         private final int numFields = schema.length();
-        private final UnsafeRow row = new UnsafeRow();
+        private UnsafeRow row = new UnsafeRow();
 
         @Override
         public boolean hasNext() {
@@ -142,7 +142,7 @@ public InternalRow next() {
               sortedIterator.getRecordLength());
             if (!hasNext()) {
               UnsafeRow copy = row.copy(); // so that we don't have dangling pointers to freed page
-              row.pointTo(null, 0, 0, 0); // so that we don't keep references to the base object
+              row = null; // so that we don't keep references to the base object
               cleanupResources();
               return copy;
             } else {