diff options
| author | Davies Liu <davies.liu@gmail.com> | 2014-08-12 16:26:01 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-08-12 16:26:01 -0700 |
| commit | 882da57a1c8c075a87909d516b169b624941a6ec (patch) | |
| tree | 503b67d5a2bd47879a9195d1ff303d7723b1971b /python | |
| parent | f0060b75ff67ab60babf54149a6860edc53cb6e9 (diff) | |
| download | spark-882da57a1c8c075a87909d516b169b624941a6ec.tar.gz spark-882da57a1c8c075a87909d516b169b624941a6ec.tar.bz2 spark-882da57a1c8c075a87909d516b169b624941a6ec.zip | |
fix flaky tests
Python 2.6 does not handle float error well as 2.7+
Author: Davies Liu <davies.liu@gmail.com>
Closes #1910 from davies/fix_test and squashes the following commits:
7e51200 [Davies Liu] fix flaky tests
Diffstat (limited to 'python')
| -rw-r--r-- | python/pyspark/sql.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py index 36040463e6..27f1d2ddf9 100644 --- a/python/pyspark/sql.py +++ b/python/pyspark/sql.py @@ -1094,7 +1094,7 @@ class SQLContext: ... "SELECT byte1 - 1 AS byte1, byte2 + 1 AS byte2, " + ... "short1 + 1 AS short1, short2 - 1 AS short2, int - 1 AS int, " + ... "float + 1.1 as float FROM table2").collect() - [Row(byte1=126, byte2=-127, short1=-32767, short2=32766, int=2147483646, float=2.1)] + [Row(byte1=126, byte2=-127, short1=-32767, short2=32766, int=2147483646, float=2.1...)] >>> rdd = sc.parallelize([(127, -32768, 1.0, ... datetime(2010, 1, 1, 1, 1, 1), |