diff options
| author | Li Zhihui <zhihui.li@intel.com> | 2015-03-29 21:30:37 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-03-29 21:30:37 -0700 |
| commit | 01dc9f50d1aae1f24021062291d73182a2622f2c (patch) | |
| tree | 558fdea7783603d12769e0d6932bf69d78bcc00d /core | |
| parent | a8d53afb4e119788fa0d9dd6b3e3ca94cea98581 (diff) | |
| download | spark-01dc9f50d1aae1f24021062291d73182a2622f2c.tar.gz spark-01dc9f50d1aae1f24021062291d73182a2622f2c.tar.bz2 spark-01dc9f50d1aae1f24021062291d73182a2622f2c.zip | |
Fix string interpolator error in HeartbeatReceiver
Error log before fixed
<code>15/03/29 10:07:25 ERROR YarnScheduler: Lost an executor 24 (already removed): Executor heartbeat timed out after ${now - lastSeenMs} ms</code>
Author: Li Zhihui <zhihui.li@intel.com>
Closes #5255 from li-zhihui/fixstringinterpolator and squashes the following commits:
c93f2b7 [Li Zhihui] Fix string interpolator error in HeartbeatReceiver
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala index 548dcb93c3..8435e1ea26 100644 --- a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala +++ b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala @@ -89,7 +89,7 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, scheduler: TaskSchedule logWarning(s"Removing executor $executorId with no recent heartbeats: " + s"${now - lastSeenMs} ms exceeds timeout $executorTimeoutMs ms") scheduler.executorLost(executorId, SlaveLost("Executor heartbeat " + - "timed out after ${now - lastSeenMs} ms")) + s"timed out after ${now - lastSeenMs} ms")) if (sc.supportDynamicAllocation) { sc.killExecutor(executorId) } |