diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-01-18 09:44:32 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-01-18 09:44:32 +0000 |
| commit | eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a (patch) | |
| tree | b265b1f01f194765ae90bc973ee4be72e4891c81 /external/kinesis-asl/src/main/scala | |
| parent | 4494cd9716d64a6c7cfa548abadb5dd0c4c143a6 (diff) | |
| download | spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.tar.gz spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.tar.bz2 spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.zip | |
[SPARK-19227][SPARK-19251] remove unused imports and outdated comments
## What changes were proposed in this pull request?
remove ununsed imports and outdated comments, and fix some minor code style issue.
## How was this patch tested?
existing ut
Author: uncleGen <hustyugm@gmail.com>
Closes #16591 from uncleGen/SPARK-19227.
Diffstat (limited to 'external/kinesis-asl/src/main/scala')
2 files changed, 2 insertions, 2 deletions
diff --git a/external/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala b/external/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala index 859fe9edb4..a70c13d7d6 100644 --- a/external/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala +++ b/external/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala @@ -22,7 +22,7 @@ import java.nio.ByteBuffer import scala.util.Random -import com.amazonaws.auth.{BasicAWSCredentials, DefaultAWSCredentialsProviderChain} +import com.amazonaws.auth.DefaultAWSCredentialsProviderChain import com.amazonaws.regions.RegionUtils import com.amazonaws.services.kinesis.AmazonKinesisClient import com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream diff --git a/external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala b/external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala index 70b5cc7ca0..3e697f36a4 100644 --- a/external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala +++ b/external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala @@ -26,7 +26,7 @@ import com.amazonaws.services.kinesis.clientlibrary.types.ShutdownReason import org.apache.spark.internal.Logging import org.apache.spark.streaming.Duration import org.apache.spark.streaming.util.RecurringTimer -import org.apache.spark.util.{Clock, SystemClock, ThreadUtils} +import org.apache.spark.util.{Clock, SystemClock} /** * This is a helper class for managing Kinesis checkpointing. |