We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aa3a7b6 commit d644477Copy full SHA for d644477
python/pyspark/worker.py
@@ -57,8 +57,8 @@ def main(infile, outfile):
57
SparkFiles._is_running_on_worker = True
58
59
# fetch names of includes (*.zip and *.egg files) and construct PYTHONPATH
60
- sys.path.append(spark_files_dir) # *.py files that were added will be copied here
61
- num_python_includes = read_int(infile)
+ sys.path.append(spark_files_dir) # *.py files that were added will be copied here
+ num_python_includes = read_int(infile)
62
for _ in range(num_python_includes):
63
filename = utf8_deserializer.loads(infile)
64
sys.path.append(os.path.join(spark_files_dir, filename))
0 commit comments