File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -879,13 +879,12 @@ def test_pipe_functions(self):
879
879
rdd = self .sc .parallelize (data )
880
880
with QuietTest (self .sc ):
881
881
self .assertEqual ([], rdd .pipe ('cc' ).collect ())
882
- self .assertRaises (Py4JJavaError , rdd .pipe ('cc' , mode = 'strict' ).collect )
882
+ self .assertRaises (Py4JJavaError , rdd .pipe ('cc' , checkCode = True ).collect )
883
883
result = rdd .pipe ('cat' ).collect ()
884
884
result .sort ()
885
885
[self .assertEqual (x , y ) for x , y in zip (data , result )]
886
- self .assertRaises (Py4JJavaError , rdd .pipe ('grep 4' , mode = 'strict' ).collect )
886
+ self .assertRaises (Py4JJavaError , rdd .pipe ('grep 4' , checkCode = True ).collect )
887
887
self .assertEqual ([], rdd .pipe ('grep 4' ).collect ())
888
- self .assertEqual ([], rdd .pipe ('grep 4' , mode = 'grep' ).collect ())
889
888
890
889
891
890
class ProfilerTests (PySparkTestCase ):
You can’t perform that action at this time.
0 commit comments