Skip to content

Commit feed499

Browse files
committed
[SPARK-6931] Correctly cast Python time float values to int before serialization
1 parent e23843c commit feed499

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/pyspark/worker.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,9 @@
3939

4040
def report_times(outfile, boot, init, finish):
4141
write_int(SpecialLengths.TIMING_DATA, outfile)
42-
write_long(1000 * boot, outfile)
43-
write_long(1000 * init, outfile)
44-
write_long(1000 * finish, outfile)
42+
write_long(int(1000 * boot), outfile)
43+
write_long(int(1000 * init), outfile)
44+
write_long(int(1000 * finish), outfile)
4545

4646

4747
def add_path(path):

0 commit comments

Comments
 (0)