File tree Expand file tree Collapse file tree 4 files changed +2
-6
lines changed
common/unsafe/src/main/java/org/apache/spark/unsafe
core/src/main/scala/org/apache/spark/storage
external/kinesis-asl/src/test/java/org/apache/spark/streaming/kinesis Expand file tree Collapse file tree 4 files changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ public final class Platform {
4848 boolean _unaligned ;
4949 String arch = System .getProperty ("os.arch" , "" );
5050 if (arch .equals ("ppc64le" ) || arch .equals ("ppc64" )) {
51- // Since java.nio.Bits.unaligned() doesn't return true on ppc (See JDK-8165231), but
51+ // Since java.nio.Bits.unaligned() doesn't return true on ppc (See JDK-8165231), but
5252 // ppc64 and ppc64le support it
5353 _unaligned = true ;
5454 } else {
Original file line number Diff line number Diff line change @@ -29,8 +29,6 @@ import scala.reflect.ClassTag
2929import scala .util .Random
3030import scala .util .control .NonFatal
3131
32- import com .google .common .io .ByteStreams
33-
3432import org .apache .spark ._
3533import org .apache .spark .executor .{DataReadMethod , ShuffleWriteMetrics }
3634import org .apache .spark .internal .Logging
@@ -41,7 +39,6 @@ import org.apache.spark.network.netty.SparkTransportConf
4139import org .apache .spark .network .shuffle .ExternalShuffleClient
4240import org .apache .spark .network .shuffle .protocol .ExecutorShuffleInfo
4341import org .apache .spark .rpc .RpcEnv
44- import org .apache .spark .security .CryptoStreamUtils
4542import org .apache .spark .serializer .{SerializerInstance , SerializerManager }
4643import org .apache .spark .shuffle .ShuffleManager
4744import org .apache .spark .storage .memory ._
Original file line number Diff line number Diff line change 4747 <suppress checks =" MethodName"
4848 files =" sql/catalyst/src/main/java/org/apache/spark/sql/streaming/GroupStateTimeout.java" />
4949 <suppress checks =" MethodName"
50- files =" sql/catalyst /src/main/java /org/apache/spark/sql/streaming/Trigger.java" />
50+ files =" sql/core /src/main/scala /org/apache/spark/sql/streaming/Trigger.java" />
5151</suppressions >
Original file line number Diff line number Diff line change 2525import org .apache .spark .streaming .Duration ;
2626import org .apache .spark .streaming .Seconds ;
2727import org .apache .spark .streaming .LocalJavaStreamingContext ;
28- import org .apache .spark .streaming .api .java .JavaDStream ;
2928
3029public class JavaKinesisInputDStreamBuilderSuite extends LocalJavaStreamingContext {
3130 /**
You can’t perform that action at this time.
0 commit comments