diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py index 376b86ea69bd..4d74aa33057a 100644 --- a/python/pyspark/sql/functions.py +++ b/python/pyspark/sql/functions.py @@ -1163,7 +1163,10 @@ def check_string_field(field, fieldName): raise TypeError("%s should be provided as a string" % fieldName) sc = SparkContext._active_spark_context - time_col = _to_java_column(timeColumn) + if isinstance(timeColumn, Column): + time_col = _to_java_column(timeColumn._jc.toString().encode('utf8')) + else: + time_col = _to_java_column(timeColumn) check_string_field(windowDuration, "windowDuration") if slideDuration and startTime: check_string_field(slideDuration, "slideDuration")