赞
踩
代码中设置SparkStreaming的输出日志级别
- val conf = new SparkConf().setAppName("Future").setMaster("local[2]")
-
- val ssc = new StreamingContext(conf, Seconds(5))
-
- ssc.sparkContext.setLogLevel("WARN")
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。