bug fix: window operator miss the watermark metadata of time column

uncleGen · uncleGen · commit 654c5121fd26 · 2017-03-21T15:49:11.000+08:00
diff --git 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):
+        raise TypeError("timeColumn should be the name of time column, and provided as a string.")
+    else:
+        time_col = _to_java_column(timeColumn)
     check_string_field(windowDuration, "windowDuration")
     if slideDuration and startTime:
         check_string_field(slideDuration, "slideDuration")
