SPARK-1729. Make Flume pull data from source, rather than the current push model

harishreedharan · harishreedharan · commit 08176adc2a1a · 2014-05-18T01:06:22.000-07:00
Exclude IO Netty in the Flume sink.
diff --git a/project/SparkBuild.scala b/project/SparkBuild.scala
@@ -635,9 +635,9 @@ object SparkBuild extends Build {
       previousArtifact := sparkPreviousArtifact("spark-streaming-flume-sink"),
       libraryDependencies ++= Seq(
         "org.apache.flume" % "flume-ng-sdk" % "1.4.0" % "compile"
-          excludeAll(excludeJBossNetty, excludeThrift),
+          excludeAll(excludeIONetty, excludeThrift),
         "org.apache.flume" % "flume-ng-core" % "1.4.0" % "compile"
-          excludeAll(excludeJBossNetty, excludeThrift)
+          excludeAll(excludeIONetty, excludeThrift)
       )
     ) ++ sbtavro.SbtAvro.avroSettings
   }

Original file line number	Diff line number	Diff line change
`@@ -635,9 +635,9 @@ object SparkBuild extends Build {`
`635`	`635`	`previousArtifact := sparkPreviousArtifact("spark-streaming-flume-sink"),`
`636`	`636`	`libraryDependencies ++= Seq(`
`637`	`637`	`"org.apache.flume" % "flume-ng-sdk" % "1.4.0" % "compile"`
`638`		`- excludeAll(excludeJBossNetty, excludeThrift),`
	`638`	`+ excludeAll(excludeIONetty, excludeThrift),`
`639`	`639`	`"org.apache.flume" % "flume-ng-core" % "1.4.0" % "compile"`
`640`		`- excludeAll(excludeJBossNetty, excludeThrift)`
	`640`	`+ excludeAll(excludeIONetty, excludeThrift)`
`641`	`641`	`)`
`642`	`642`	`) ++ sbtavro.SbtAvro.avroSettings`
`643`	`643`	`}`