diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 7e5343c973dc5..0aefd1fb7c4c1 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -39,9 +39,9 @@ def report_times(outfile, boot, init, finish): write_int(SpecialLengths.TIMING_DATA, outfile) - write_long(1000 * boot, outfile) - write_long(1000 * init, outfile) - write_long(1000 * finish, outfile) + write_long(int(1000 * boot), outfile) + write_long(int(1000 * init), outfile) + write_long(int(1000 * finish), outfile) def add_path(path):