fixed pyspark stest
authorYaniv Rodenski <roadan@gmail.com>
Tue, 15 May 2018 02:47:27 +0000 (12:47 +1000)
committerYaniv Rodenski <roadan@gmail.com>
Tue, 15 May 2018 02:47:27 +0000 (12:47 +1000)
executor/src/test/resources/spark_intp.py

index 0faae2b..a427e92 100755 (executable)
@@ -23,14 +23,14 @@ import sys
 import zipimport
 from runtime import AmaContext, Environment
 
-os.chdir(os.getcwd() + '/build/resources/test/')
-import zipfile
-zip = zipfile.ZipFile('pyspark.zip')
-zip.extractall()
-zip = zipfile.ZipFile('py4j-0.10.4-src.zip', 'r')
-zip.extractall()
-sys.path.insert(1, os.getcwd() + '/executor/src/test/resources/pyspark')
-sys.path.insert(1, os.getcwd() + '/executor/src/test/resources/py4j')
+os.chdir(os.getcwd() + '/build/resources/test/')
+import zipfile
+zip = zipfile.ZipFile('pyspark.zip')
+zip.extractall()
+zip = zipfile.ZipFile('py4j-0.10.4-src.zip', 'r')
+zip.extractall()
+sys.path.insert(1, os.getcwd() + '/executor/src/test/resources/pyspark')
+sys.path.insert(1, os.getcwd() + '/executor/src/test/resources/py4j')
 
 # py4j_path = 'spark-2.2.1-bin-hadoop2.7/python/lib/py4j-0.10.4-src.zip'
 # py4j_importer = zipimport.zipimporter(py4j_path)