diff options
| author | Ashwin Swaroop <Ashwin Swaroop> | 2015-11-25 13:41:14 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-11-25 13:41:14 +0000 |
| commit | 63850026576b3ea7783f9d4b975171dc3cff6e4c (patch) | |
| tree | a9150a979d18cc5b61a7f4cdd53dc1c483ac17d0 /core | |
| parent | a0f1a11837bfffb76582499d36fbaf21a1d628cb (diff) | |
| download | spark-63850026576b3ea7783f9d4b975171dc3cff6e4c.tar.gz spark-63850026576b3ea7783f9d4b975171dc3cff6e4c.tar.bz2 spark-63850026576b3ea7783f9d4b975171dc3cff6e4c.zip | |
[SPARK-11686][CORE] Issue WARN when dynamic allocation is disabled due to spark.dynamicAllocation.enabled and spark.executor.instances both set
Changed the log type to a 'warning' instead of 'info' as required.
Author: Ashwin Swaroop <Ashwin Swaroop>
Closes #9926 from ashwinswaroop/master.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index e19ba11370..2c10779f2b 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -556,7 +556,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli // Optionally scale number of executors dynamically based on workload. Exposed for testing. val dynamicAllocationEnabled = Utils.isDynamicAllocationEnabled(_conf) if (!dynamicAllocationEnabled && _conf.getBoolean("spark.dynamicAllocation.enabled", false)) { - logInfo("Dynamic Allocation and num executors both set, thus dynamic allocation disabled.") + logWarning("Dynamic Allocation and num executors both set, thus dynamic allocation disabled.") } _executorAllocationManager = |