diff options
| author | Sean Owen <sowen@cloudera.com> | 2015-04-27 19:50:55 -0400 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-04-27 19:50:55 -0400 |
| commit | ab5adb7a973eec9d95c7575c864cba9f8d83a0fd (patch) | |
| tree | ae05e0003efe275028382b16a842660f6e50e43c /external/flume-sink | |
| parent | 5d45e1f60059e2f2fc8ad64778b9ddcc8887c570 (diff) | |
| download | spark-ab5adb7a973eec9d95c7575c864cba9f8d83a0fd.tar.gz spark-ab5adb7a973eec9d95c7575c864cba9f8d83a0fd.tar.bz2 spark-ab5adb7a973eec9d95c7575c864cba9f8d83a0fd.zip | |
[SPARK-7145] [CORE] commons-lang (2.x) classes used instead of commons-lang3 (3.x); commons-io used without dependency
Remove use of commons-lang in favor of commons-lang3 classes; remove commons-io use in favor of Guava
Author: Sean Owen <sowen@cloudera.com>
Closes #5703 from srowen/SPARK-7145 and squashes the following commits:
21fbe03 [Sean Owen] Remove use of commons-lang in favor of commons-lang3 classes; remove commons-io use in favor of Guava
Diffstat (limited to 'external/flume-sink')
| -rw-r--r-- | external/flume-sink/pom.xml | 4 | ||||
| -rw-r--r-- | external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala | 4 |
2 files changed, 6 insertions, 2 deletions
diff --git a/external/flume-sink/pom.xml b/external/flume-sink/pom.xml index 67907bbfb6..1f3e619d97 100644 --- a/external/flume-sink/pom.xml +++ b/external/flume-sink/pom.xml @@ -36,6 +36,10 @@ <dependencies> <dependency> + <groupId>org.apache.commons</groupId> + <artifactId>commons-lang3</artifactId> + </dependency> + <dependency> <groupId>org.apache.flume</groupId> <artifactId>flume-ng-sdk</artifactId> </dependency> diff --git a/external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala b/external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala index 4373be443e..fd01807fc3 100644 --- a/external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala +++ b/external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala @@ -21,9 +21,9 @@ import java.util.concurrent.atomic.AtomicLong import scala.collection.mutable -import org.apache.flume.Channel -import org.apache.commons.lang.RandomStringUtils import com.google.common.util.concurrent.ThreadFactoryBuilder +import org.apache.flume.Channel +import org.apache.commons.lang3.RandomStringUtils /** * Class that implements the SparkFlumeProtocol, that is used by the Avro Netty Server to process |