diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 328e1d18d451b..c3bcaf9f3de20 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -696,7 +696,6 @@ def pipe(self, command, env={}, checkCode=False): :param checkCode: whether or not to check the return value of the shell command. """ - def func(iterator): pipe = Popen( shlex.split(command), env=env, stdin=PIPE, stdout=PIPE)