私はpyspark 1.6.2でpythonスクリプトファイルを実行します(認定トレーニングの理由から古いものです)。pyspark:Pythonスクリプトを実行してコマンドラインで結果を確認
spark-submit --master yarn-cluster s01.py
実行すると、「application_somelongnumberのアプリケーションレポート」が返されます。私が期待していたことは、スクリプトコマンドの出力を示すことでした。私が正しく開発したかどうかを確認できるように。私が欲しいものを手に入れようとすれば、どうすればいいですか?
私のスクリプトの内容:
#!/usr/bin/python
from pyspark.sql import Row
from pyspark.sql.functions import *
from pyspark import SparkContext
sc = SparkContext(appName = "solution01")
a = sc.textFile("/data/crime.csv")
b = a.take(1)
sc.stop()
print(b)
UPDATE :私はpysparkのs01.pyを実行すると、私は私の結果を参照してくださいが、私はそれがパラメータで実行されるようにしたいので、それは、意図した動作ではありませんクラスタ上で