Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
2.0.2
-
None
Description
python/pyspark/sql/streaming.py in partitionBy(self, *cols) 716 if len(cols) == 1 and isinstance(cols[0], (list, tuple)): 717 cols = cols[0] --> 718 self._jwrite = self._jwrite.partitionBy(_to_seq(self._spark._sc, cols)) 719 return self 720 NameError: global name '_to_seq' is not defined