org.apache.spark.examples.streaming.StreamingExamples Scala 版本 无Java版本

org.apache.spark.examples.streaming.StreamingExamples  Scala 版本 无Java版本

这个模块就设置了日志级别，在org.apache.spark.examples.streaming中注释掉

//StreamingExamples.setStreamingLogLevels(); 避免编译提示出错

 

import org.apache.spark.examples.streaming.StreamingExamples;

package org.apache.spark.examples.streaming

import org.apache.log4j.{Level, Logger}

import org.apache.spark.internal.Logging

/** Utility functions for Spark Streaming examples. */
object StreamingExamples extends Logging {

  /** Set reasonable logging levels for streaming if the user has not configured log4j. */
  def setStreamingLogLevels() {
    val log4jInitialized = Logger.getRootLogger.getAllAppenders.hasMoreElements
    if (!log4jInitialized) {
      // We first log something to initialize Spark's default logging, then we override the
      // logging level.
      logInfo("Setting log level to [WARN] for streaming example." +
        " To override add a custom log4j.properties to the classpath.")
      Logger.getRootLogger.setLevel(Level.WARN)
    }
  }
}