我在spark中运行python编写的一个简单脚本 当我使用输入法时,运行的脚本会停留在这一行中 代码如下:
from pyspark import SparkConf, SparkContext
conf = SparkConf().setMaster("local").setAppName("My App")
sc = SparkContext(conf = conf)
testFileName = input("enter file name: ");
print("okey I'll open " + testFileName)
# load an RDD from a test file
fileRDD = sc.textFile(testFileName)
当您使用
spark-submit
提交应用程序时,您不与Python代码交互,而是与javaone交互,后者不需要stdin的任何输入。在如果您想让它工作,您必须跳过
spark-submit
,并直接将其作为Python脚本执行。在相关问题 更多 >
编程相关推荐