From 20cfeafd8557be55473b8091194704aec2ea3ba6 Mon Sep 17 00:00:00 2001 From: Bryan Cutler Date: Thu, 3 Sep 2015 16:38:45 -0700 Subject: [PATCH] [SPARK-6931] Correctly cast Python time float values to int before serialization --- python/pyspark/worker.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 8a93c320ec5d3..3637e0784a691 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):