INNER CODE UNIT · Java
updateSparkLog4j2Properties
starlake-ai/starflow · src/main/java/Setup.java:764
private static void updateSparkLog4j2Properties(File sparkDir) {
File log4jFile = new File(new File(sparkDir, "conf"), "log4j2.properties");
try {
BufferedReader reader = new BufferedReader(new FileReader(log4jFile));
StringBuilder sb = new StringBuilder();
String line;
while ((line = reader.readLine()) != null) {
if (line.startsWith("rootLogger.level =")|| line.startsWith("rootLogger.level=")) {
line = "rootLogger.level = ${env:SL_LOG_LEVEL:-error}";
}
sb.append(line).append("\n");
}
reader.close();
sb.append("logger.shutdown.name=org.apache.spark.util.ShutdownHookManager").append("\n");
sb.append("logger.shutdown.level=OFF").append("\n");
sb.append("logger.env.name=org.apache.spark.SparkEnv").append("\n");
sb.append("logger.env.level=error").append("\n");