To set the log level on all executors, you must set it inside the JVM on each worker.
For example:
%scala sc.parallelize(Seq("")).foreachPartition(x => { import org.apache.log4j.{LogManager, Level} import org.apache.commons.logging.LogFactory LogManager.getRootLogger().setLevel(Level.DEBUG) val log = LogFactory.getLog("EXECUTOR-LOG:") log.debug("START EXECUTOR DEBUG LOG LEVEL") })
To verify that the level is set, navigate to the Spark UI, select the Executors tab, and open the stderr log for any executor: