Skip to content

Commit 50f80b1

Browse files
committed
Remove pyFiles from SparkContext construction
1 parent c362f69 commit 50f80b1

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

examples/src/main/python/als.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ def update(i, vec, mat, ratings):
4949
"""
5050
Usage: als [M] [U] [F] [iterations] [slices]"
5151
"""
52-
sc = SparkContext(appName="PythonALS", pyFiles=[realpath(__file__)])
52+
sc = SparkContext(appName="PythonALS")
5353
M = int(sys.argv[1]) if len(sys.argv) > 1 else 100
5454
U = int(sys.argv[2]) if len(sys.argv) > 2 else 500
5555
F = int(sys.argv[3]) if len(sys.argv) > 3 else 10

examples/src/main/python/logistic_regression.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ def readPointBatch(iterator):
5050
if len(sys.argv) != 3:
5151
print >> sys.stderr, "Usage: logistic_regression <file> <iterations>"
5252
exit(-1)
53-
sc = SparkContext(appName="PythonLR", pyFiles=[realpath(__file__)])
53+
sc = SparkContext(appName="PythonLR")
5454
points = sc.textFile(sys.argv[1]).mapPartitions(readPointBatch).cache()
5555
iterations = int(sys.argv[2])
5656

0 commit comments

Comments
 (0)