-
- Downloads
[SPARK-9826] [CORE] Fix cannot use custom classes in log4j.properties
Refactor Utils class and create ShutdownHookManager. NOTE: Wasn't able to run /dev/run-tests on windows machine. Manual tests were conducted locally using custom log4j.properties file with Redis appender and logstash formatter (bundled in the fat-jar submitted to spark) ex: log4j.rootCategory=WARN,console,redis log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.target=System.err log4j.appender.console.layout=org.apache.log4j.PatternLayout log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c{1}: %m%n log4j.logger.org.eclipse.jetty=WARN log4j.logger.org.eclipse.jetty.util.component.AbstractLifeCycle=ERROR log4j.logger.org.apache.spark.repl.SparkIMain$exprTyper=INFO log4j.logger.org.apache.spark.repl.SparkILoop$SparkILoopInterpreter=INFO log4j.logger.org.apache.spark.graphx.Pregel=INFO log4j.appender.redis=com.ryantenney.log4j.FailoverRedisAppender log4j.appender.redis.endpoints=hostname:port log4j.appender.redis.key=mykey log4j.appender.redis.alwaysBatch=false log4j.appender.redis.layout=net.logstash.log4j.JSONEventLayoutV1 Author: michellemay <mlemay@gmail.com> Closes #8109 from michellemay/SPARK-9826.
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 3 additions, 2 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/deploy/history/HistoryServer.scala 2 additions, 2 deletions...scala/org/apache/spark/deploy/history/HistoryServer.scala
- core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala 4 additions, 3 deletions...scala/org/apache/spark/deploy/worker/ExecutorRunner.scala
- core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala
- core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala
- core/src/main/scala/org/apache/spark/rdd/SqlNewHadoopRDD.scala 2 additions, 2 deletions...src/main/scala/org/apache/spark/rdd/SqlNewHadoopRDD.scala
- core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala 6 additions, 4 deletions...ain/scala/org/apache/spark/storage/DiskBlockManager.scala
- core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala 3 additions, 3 deletions.../scala/org/apache/spark/storage/TachyonBlockManager.scala
- core/src/main/scala/org/apache/spark/util/ShutdownHookManager.scala 266 additions, 0 deletions...ain/scala/org/apache/spark/util/ShutdownHookManager.scala
- core/src/main/scala/org/apache/spark/util/SparkUncaughtExceptionHandler.scala 1 addition, 1 deletion...org/apache/spark/util/SparkUncaughtExceptionHandler.scala
- core/src/main/scala/org/apache/spark/util/Utils.scala 3 additions, 219 deletionscore/src/main/scala/org/apache/spark/util/Utils.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala 2 additions, 2 deletions...pache/spark/sql/hive/thriftserver/HiveThriftServer2.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala 2 additions, 2 deletions...pache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/test/TestHive.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/sql/hive/test/TestHive.scala
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 4 additions, 4 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala 3 additions, 2 deletions...cala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
Loading
Please register or sign in to comment