Skip to content

Commit 1d08d80

Browse files
committed
Import sorting
1 parent 0ee9311 commit 1d08d80

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,6 @@
2424
import java.nio.channels.WritableByteChannel;
2525
import java.util.Iterator;
2626

27-
import org.apache.spark.shuffle.api.ShuffleExecutorComponents;
28-
import org.apache.spark.shuffle.api.WritableByteChannelWrapper;
2927
import scala.Option;
3028
import scala.Product2;
3129
import scala.collection.JavaConverters;
@@ -54,6 +52,8 @@
5452
import org.apache.spark.serializer.SerializationStream;
5553
import org.apache.spark.serializer.SerializerInstance;
5654
import org.apache.spark.shuffle.ShuffleWriter;
55+
import org.apache.spark.shuffle.api.ShuffleExecutorComponents;
56+
import org.apache.spark.shuffle.api.WritableByteChannelWrapper;
5757
import org.apache.spark.storage.BlockManager;
5858
import org.apache.spark.unsafe.Platform;
5959
import org.apache.spark.util.Utils;

core/src/test/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriterSuite.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import java.nio.file.Files;
2323
import java.util.*;
2424

25-
import org.apache.spark.shuffle.sort.io.LocalDiskShuffleExecutorComponents;
2625
import org.mockito.stubbing.Answer;
2726
import scala.Option;
2827
import scala.Product2;
@@ -42,7 +41,6 @@
4241
import org.apache.spark.ShuffleDependency;
4342
import org.apache.spark.SparkConf;
4443
import org.apache.spark.TaskContext;
45-
import org.apache.spark.TaskContext$;
4644
import org.apache.spark.executor.ShuffleWriteMetrics;
4745
import org.apache.spark.executor.TaskMetrics;
4846
import org.apache.spark.io.CompressionCodec$;
@@ -57,6 +55,7 @@
5755
import org.apache.spark.security.CryptoStreamUtils;
5856
import org.apache.spark.serializer.*;
5957
import org.apache.spark.shuffle.IndexShuffleBlockResolver;
58+
import org.apache.spark.shuffle.sort.io.LocalDiskShuffleExecutorComponents;
6059
import org.apache.spark.storage.*;
6160
import org.apache.spark.util.Utils;
6261

0 commit comments

Comments
 (0)