diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-08-23 15:54:15 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-08-24 19:42:47 -0700 |
| commit | 4b523004877cf94152225484de7683e9d17cdb56 (patch) | |
| tree | f9c6fad8856d7056833e51816b74446b6ea305df /pyspark | |
| parent | 607b53abfca049e7d9139e2d29893a3bb252de19 (diff) | |
| download | spark-4b523004877cf94152225484de7683e9d17cdb56.tar.gz spark-4b523004877cf94152225484de7683e9d17cdb56.tar.bz2 spark-4b523004877cf94152225484de7683e9d17cdb56.zip | |
Fix options parsing in Python pi example.
Diffstat (limited to 'pyspark')
| -rw-r--r-- | pyspark/pyspark/examples/pi.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pyspark/pyspark/examples/pi.py b/pyspark/pyspark/examples/pi.py index ad77694c41..fe63d2c952 100644 --- a/pyspark/pyspark/examples/pi.py +++ b/pyspark/pyspark/examples/pi.py @@ -10,7 +10,7 @@ if __name__ == "__main__": "Usage: PythonPi <host> [<slices>]" exit(-1) sc = SparkContext(sys.argv[1], "PythonKMeans") - slices = sys.argv[2] if len(sys.argv) > 2 else 2 + slices = int(sys.argv[2]) if len(sys.argv) > 2 else 2 n = 100000 * slices def f(_): x = random() * 2 - 1 |