Skip to content

Commit 777a9a5

Browse files
tmalaskapwendell
authored andcommitted
SPARK-1584: Upgrade Flume dependency to 1.4.0
Updated the Flume dependency in the maven pom file and the scala build file. Author: tmalaska <[email protected]> Closes #507 from tmalaska/master and squashes the following commits: 79492c8 [tmalaska] excluded all thrift 159c3f1 [tmalaska] fixed the flume pom file issues 5bf56a7 [tmalaska] Upgrade flume version (cherry picked from commit d5c6ae6) Signed-off-by: Patrick Wendell <[email protected]>
1 parent 51a387a commit 777a9a5

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

external/flume/pom.xml

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,12 +61,16 @@
6161
<dependency>
6262
<groupId>org.apache.flume</groupId>
6363
<artifactId>flume-ng-sdk</artifactId>
64-
<version>1.2.0</version>
64+
<version>1.4.0</version>
6565
<exclusions>
6666
<exclusion>
6767
<groupId>org.jboss.netty</groupId>
6868
<artifactId>netty</artifactId>
6969
</exclusion>
70+
<exclusion>
71+
<groupId>org.apache.thrift</groupId>
72+
<artifactId>libthrift</artifactId>
73+
</exclusion>
7074
</exclusions>
7175
</dependency>
7276
<dependency>

project/SparkBuild.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -313,6 +313,7 @@ object SparkBuild extends Build {
313313
val excludeCurator = ExclusionRule(organization = "org.apache.curator")
314314
val excludePowermock = ExclusionRule(organization = "org.powermock")
315315
val excludeFastutil = ExclusionRule(organization = "it.unimi.dsi")
316+
val excludeThrift = ExclusionRule(organization = "org.apache.thrift")
316317

317318
def sparkPreviousArtifact(id: String, organization: String = "org.apache.spark",
318319
version: String = "0.9.0-incubating", crossVersion: String = "2.10"): Option[sbt.ModuleID] = {
@@ -607,7 +608,7 @@ object SparkBuild extends Build {
607608
name := "spark-streaming-flume",
608609
previousArtifact := sparkPreviousArtifact("spark-streaming-flume"),
609610
libraryDependencies ++= Seq(
610-
"org.apache.flume" % "flume-ng-sdk" % "1.2.0" % "compile" excludeAll(excludeNetty)
611+
"org.apache.flume" % "flume-ng-sdk" % "1.4.0" % "compile" excludeAll(excludeNetty, excludeThrift)
611612
)
612613
)
613614

0 commit comments

Comments
 (0)