我的 spark-submit 命令是:
spark-submit --class com.sundogsoftware.spark.WordCountBetterDataset --master yarn --deploy-mode cluster SparkCourse.jar
为了定义 sparkSession,我使用这个:
val spark = SparkSession
.builder
.master("spark://youness:7077")
.appName("WordCount")
.getOrCreate()
但最后,我的工作以返回码 13 失败。