-
0 votesanswersviews
Spark没有注册输出操作,因此无需执行,但我正在写入文件
val sc = new SparkContext(conf) val streamContext = new StreamingContext(sc, Seconds(1)) val log = Logger.getLogger("sqsLog") val sqs = streamContext.receiverStream(new SQSReceiver("q...