diff --git a/python/pyspark/sql/types.py b/python/pyspark/sql/types.py index d9979ba948d89..19beeaa4aa327 100644 --- a/python/pyspark/sql/types.py +++ b/python/pyspark/sql/types.py @@ -1291,7 +1291,7 @@ def can_convert(self, obj): def convert(self, obj, gateway_client): Timestamp = JavaClass("java.sql.Timestamp", gateway_client) seconds = (calendar.timegm(obj.utctimetuple()) if obj.tzinfo - else time.mktime(obj.timetuple())) + else time.mktime(obj.timetuple())) return Timestamp(int(seconds) * 1000 + obj.microsecond // 1000) # datetime is a subclass of date, we should register DatetimeConverter first