Skip to content

Commit 828f8ae

Browse files
committed
more cleanup
1 parent e7c8978 commit 828f8ae

File tree

3 files changed

+10
-6
lines changed

3 files changed

+10
-6
lines changed

dev/audit-release/sbt_app_core/src/main/scala/SparkApp.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,14 +47,14 @@ object SimpleApp {
4747
System.exit(-1)
4848
}
4949
if (foundGanglia) {
50-
println("Ganglia sink was loaded via spark-core")
50+
println("Ganglia sink was loaded via spark-ganglia-lgpl")
5151
System.exit(-1)
5252
}
5353

5454
// Remove kinesis from default build due to ASL license issue
5555
val foundKinesis = Try(Class.forName("org.apache.spark.streaming.kinesis.KinesisReceiver")).isSuccess
5656
if (foundKinesis) {
57-
println("Kinesis was loaded via spark-core")
57+
println("Kinesis was loaded via spark-kinesis-asl")
5858
System.exit(-1)
5959
}
6060
}

extras/spark-kinesis-asl/pom.xml

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,14 +24,18 @@
2424
<relativePath>../../pom.xml</relativePath>
2525
</parent>
2626

27-
<!-- Kinesis integration is not included by default due to ASL-licensed code -->
27+
<!--
28+
Kinesis integration is not included by default due to ASL-licensed code.
29+
Note: This project - if activated - is packaged with the main Spark assembly.
30+
This only needs to packaged as a separate jar when running the examples.
31+
-->
2832
<groupId>org.apache.spark</groupId>
2933
<artifactId>spark-kinesis-asl_2.10</artifactId>
3034
<packaging>jar</packaging>
3135
<name>Spark Kinesis Integration</name>
3236

3337
<properties>
34-
<sbt.project.name>spark-kinesis-asl</sbt.project.name>
38+
<sbt.project.name>kinesis-asl</sbt.project.name>
3539
</properties>
3640

3741
<dependencies>

project/SparkBuild.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ object BuildCommons {
3636
"streaming-zeromq").map(ProjectRef(buildLocation, _))
3737

3838
val optionallyEnabledProjects@Seq(yarn, yarnStable, yarnAlpha, java8Tests, sparkGangliaLgpl, sparkKinesisAsl) =
39-
Seq("yarn", "yarn-stable", "yarn-alpha", "java8-tests", "ganglia-lgpl", "spark-kinesis-asl")
39+
Seq("yarn", "yarn-stable", "yarn-alpha", "java8-tests", "ganglia-lgpl", "kinesis-asl")
4040
.map(ProjectRef(buildLocation, _))
4141

4242
val assemblyProjects@Seq(assembly, examples) = Seq("assembly", "examples")
@@ -60,7 +60,7 @@ object SparkBuild extends PomBuild {
6060
var isAlphaYarn = false
6161
var profiles: mutable.Seq[String] = mutable.Seq.empty
6262
if (Properties.envOrNone("SPARK_GANGLIA_LGPL").isDefined) {
63-
println("NOTE: SPARK_GANGLIA_LGPL is deprecated, please use -Pganglia-lgpl flag.")
63+
println("NOTE: SPARK_GANGLIA_LGPL is deprecated, please use -Pspark-ganglia-lgpl flag.")
6464
profiles ++= Seq("spark-ganglia-lgpl")
6565
}
6666
if (Properties.envOrNone("SPARK_KINESIS_ASL").isDefined) {

0 commit comments

Comments
 (0)