diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 8a93c320ec5d..3637e0784a69 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -37,9 +37,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):