РЕДАКТИРОВАТЬ: Проблема, по-видимому, заключается в преобразовании стандартной библиотеки времени и даты в метки времени для дат до начала эпохи в Windows
См. Следующий минимальный пример:
import datetime
#this works
datetime.datetime(1973,1,23,0).timestamp()
#this produces OSError: [Errno 22] Invalid argument
datetime.datetime(1953,1,23,0).timestamp()
Issue
Когда я конвертирую Pandas фрейм данных с датами datetime64 [ns], предшествующими эпохе, в Apache Spark Dataframe, я получаю кучу предупреждений о Exception ignored in: 'pandas._libs.tslibs.tzconversion._tz_convert_tzlocal_utc'
(полная трассировка стека ниже ) и даты до эпохи меняются на эпоху. Почему это происходит и как мне это предотвратить?
Версии программного обеспечения
Windows 10 Python: 3.7.6 pyspark 2.4.5 pandas 1.0.1
Код для воспроизведения
#imports
import pandas as pd
from datetime import datetime
from pyspark.sql import SparkSession
#set up spark
spark = SparkSession.builder.getOrCreate()
#create dataframe
df = pd.DataFrame({'Dates': [datetime(2019,3,29), datetime(1953,2,20)]})
#data types
df.dtypes
"""
Result:
Dates datetime64[ns]
dtype: object
"""
#try to convert to spark
sparkdf = spark.createDataFrame(df)
Трассировка стека
Exception ignored in: 'pandas._libs.tslibs.tzconversion._tz_convert_tzlocal_utc'
Traceback (most recent call last):
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\_common.py", line 144, in fromutc
return f(self, dt)
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\_common.py", line 258, in fromutc
dt_wall = self._fromutc(dt)
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\_common.py", line 222, in _fromutc
dtoff = dt.utcoffset()
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\tz.py", line 222, in utcoffset
if self._isdst(dt):
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\tz.py", line 291, in _isdst
dstval = self._naive_is_dst(dt)
File "C:\Users\jbishop\AppData\Roaming\Python\Python37\site-packages\dateutil\tz\tz.py", line 260, in _naive_is_dst
return time.localtime(timestamp + time.timezone).tm_isdst
OSError: [Errno 22] Invalid argument
Результирующий кадр данных
sparkdf.show()
+-------------------+
| Dates|
+-------------------+
|2019-03-29 00:00:00|
|1970-01-01 00:00:00|
+-------------------+
Типы данных
sparkdf.printSchema()
root
|-- Dates: timestamp (nullable = true)