aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/streaming.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/sql/streaming.py')
-rw-r--r--python/pyspark/sql/streaming.py2
1 files changed, 1 insertions, 1 deletions
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)