fix fail_condition

return True when an exception should be raised
prabeesh · Jun 30, 2015 · eb4801c · eb4801c
1 parent b0ac3a4
commit eb4801c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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'.")