Skip to content

Commit

Permalink
merge with master
Browse files Browse the repository at this point in the history
  • Loading branch information
lianhuiwang committed Jul 16, 2015
1 parent d503fce commit e651683
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
import org.apache.spark.sql.types.StructType;
import org.apache.spark.storage.BlockId;
import org.apache.spark.storage.BlockManager;
import org.apache.spark.storage.BlockObjectWriter;
import org.apache.spark.storage.DiskBlockObjectWriter;
import org.apache.spark.storage.TempLocalBlockId;
import org.apache.spark.unsafe.PlatformDependent;
import org.apache.spark.unsafe.memory.MemoryBlock;
Expand Down Expand Up @@ -740,7 +740,7 @@ public class UnsafeSorterKVSpillWriter {
private final File file;
private final BlockId blockId;
private final int numRecordsToWrite;
private BlockObjectWriter writer;
private DiskBlockObjectWriter writer;
private int numRecordsSpilled = 0;

public UnsafeSorterKVSpillWriter(
Expand Down

0 comments on commit e651683

Please sign in to comment.