Skip to content

Commit 0c3e20c

Browse files
committed
Fix python bug
1 parent db5ae3f commit 0c3e20c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/sql/streaming.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -774,8 +774,8 @@ def trigger(self, processingTime=None, once=None):
774774
jTrigger = self._spark._sc._jvm.org.apache.spark.sql.streaming.Trigger.ProcessingTime(
775775
interval)
776776
elif once is not None:
777-
if once is True:
778-
raise ValueError('Value for once must be True. Got' % once)
777+
if once is not True:
778+
raise ValueError('Value for once must be True. Got: %s' % once)
779779
jTrigger = self._spark._sc._jvm.org.apache.spark.sql.streaming.Trigger.Once()
780780
else:
781781
raise ValueError('No trigger provided')

0 commit comments

Comments
 (0)