aboutsummaryrefslogtreecommitdiff
path: root/dev
diff options
context:
space:
mode:
Diffstat (limited to 'dev')
-rwxr-xr-xdev/run-tests.py2
-rw-r--r--dev/sparktestsupport/modules.py2
2 files changed, 4 insertions, 0 deletions
diff --git a/dev/run-tests.py b/dev/run-tests.py
index d1852b95bb..f689425ee4 100755
--- a/dev/run-tests.py
+++ b/dev/run-tests.py
@@ -303,6 +303,8 @@ def build_spark_sbt(hadoop_version):
"assembly/assembly",
"streaming-kafka-assembly/assembly",
"streaming-flume-assembly/assembly",
+ "streaming-mqtt-assembly/assembly",
+ "streaming-mqtt/test:assembly",
"streaming-kinesis-asl-assembly/assembly"]
profiles_and_goals = build_profiles + sbt_goals
diff --git a/dev/sparktestsupport/modules.py b/dev/sparktestsupport/modules.py
index a9717ff956..d82c0cca37 100644
--- a/dev/sparktestsupport/modules.py
+++ b/dev/sparktestsupport/modules.py
@@ -181,6 +181,7 @@ streaming_mqtt = Module(
dependencies=[streaming],
source_file_regexes=[
"external/mqtt",
+ "external/mqtt-assembly",
],
sbt_test_goals=[
"streaming-mqtt/test",
@@ -306,6 +307,7 @@ pyspark_streaming = Module(
streaming,
streaming_kafka,
streaming_flume_assembly,
+ streaming_mqtt,
streaming_kinesis_asl
],
source_file_regexes=[