diff options
Diffstat (limited to 'python/pyspark/join.py')
| -rw-r--r-- | python/pyspark/join.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/join.py b/python/pyspark/join.py index 94df399016..c1f5362648 100644 --- a/python/pyspark/join.py +++ b/python/pyspark/join.py @@ -93,7 +93,7 @@ def python_full_outer_join(rdd, other, numPartitions): vbuf.append(None) if not wbuf: wbuf.append(None) - return [(v, w) for v in vbuf for w in wbuf] + return ((v, w) for v in vbuf for w in wbuf) return _do_python_join(rdd, other, numPartitions, dispatch) |