diff options
| -rwxr-xr-x | dev/run-tests.py | 2 | ||||
| -rw-r--r-- | python/pyspark/sql/streaming.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/dev/run-tests.py b/dev/run-tests.py index 2030c4ab23..dcf1be9d95 100755 --- a/dev/run-tests.py +++ b/dev/run-tests.py @@ -335,7 +335,7 @@ def build_spark_maven(hadoop_version): def build_spark_sbt(hadoop_version): # Enable all of the profiles for the build: build_profiles = get_hadoop_profiles(hadoop_version) + modules.root.build_profile_flags - sbt_goals = ["package", + sbt_goals = ["test:package", # Build test jars as some tests depend on them "streaming-kafka-0-8-assembly/assembly", "streaming-flume-assembly/assembly", "streaming-kinesis-asl-assembly/assembly"] diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py index 0edaa51549..1d650946be 100644 --- a/python/pyspark/sql/streaming.py +++ b/python/pyspark/sql/streaming.py @@ -146,7 +146,7 @@ class ContinuousQueryManager(object): >>> cq.stop() """ if not isinstance(id, intlike): - raise ValueError("The id for the query must be an integer. Got: %d" % id) + raise ValueError("The id for the query must be an integer. Got: %s" % id) return ContinuousQuery(self._jcqm.get(id)) @since(2.0) |