003 spark | 初始代码

    require(args.length >= 3, "Usage: a, b, c")
    val Array(a, b, c) = args
    val conf: SparkConf = new SparkConf().setAppName("Merge")

    conf.set("spark.scheduler.executorTaskBlacklistTime", "300000")
    conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
    val sc = new SparkContext(conf)