We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c555207 commit 4d40893Copy full SHA for 4d40893
1 file changed
python/pyspark/serializers.py
@@ -227,7 +227,7 @@ def _create_batch(series):
227
def cast_series(s, t):
228
if type(t) == pa.TimestampType:
229
# NOTE: convert to 'us' with astype here, unit ignored in `from_pandas` see ARROW-1680
230
- return _check_series_convert_timestamps_internal(s)\
+ return _check_series_convert_timestamps_internal(s.fillna(0))\
231
.values.astype('datetime64[us]', copy=False)
232
elif t == pa.date32():
233
# TODO: this converts the series to Python objects, possibly avoid with Arrow >= 0.8
0 commit comments