From eb4801c78e143698bc2c3ebaecce73f455786a1c Mon Sep 17 00:00:00 2001 From: Scott Taylor Date: Wed, 1 Jul 2015 00:33:49 +0100 Subject: [PATCH] fix fail_condition return True when an exception should be raised --- python/pyspark/rdd.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 10c9950051bb0..a56f061bef628 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -699,10 +699,10 @@ def fail_condition(x): return False elif mode == 'strict': def fail_condition(x): - return x == 0 + return x != 0 elif mode == 'grep': def fail_condition(x): - return x == 0 or x == 1 + return x != 0 and x != 1 else: raise ValueError("mode must be one of 'permissive', 'strict' or 'grep'.")