join format fix

wdm0006 · Nov 30, 2016 · 1a9631e · 1a9631e
1 parent e59059e
commit 1a9631e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dummy_spark/rdd.py b/dummy_spark/rdd.py
@@ -865,7 +865,7 @@ def leftOuterJoin(self, other, numPartitions=None):
         :return:
         """
 
-        data = [(k, (dict(self._jrdd).get(k)), v) for k, v in other._jrdd]
+        data = [(k, (dict(self._jrdd).get(k), v)) for k, v in other._jrdd]
         return RDD(data, self.ctx)
 
     def rightOuterJoin(self, other, numPartitions=None):

diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 from codecs import open
 from os import path
 
-VERSION = '0.0.6'
+VERSION = '0.0.7'
 
 here = path.abspath(path.dirname(__file__))