aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorXiangrui Meng <meng@databricks.com>2014-08-25 14:55:20 -0700
committerJosh Rosen <joshrosen@apache.org>2014-08-25 14:55:20 -0700
commitfd8ace2d9a796f69ce34ad202907008cd6e4d274 (patch)
treee93546a9e333b8ee5c7870588acbec16c333a08d /core
parentcc40a709c0494b68404a90769efc7f2b415eb125 (diff)
downloadspark-fd8ace2d9a796f69ce34ad202907008cd6e4d274.tar.gz
spark-fd8ace2d9a796f69ce34ad202907008cd6e4d274.tar.bz2
spark-fd8ace2d9a796f69ce34ad202907008cd6e4d274.zip
[FIX] fix error message in sendMessageReliably
rxin Author: Xiangrui Meng <meng@databricks.com> Closes #2120 from mengxr/sendMessageReliably and squashes the following commits: b14400c [Xiangrui Meng] fix error message in sendMessageReliably
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/network/ConnectionManager.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
index e5e1e72cd9..578d806263 100644
--- a/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
+++ b/core/src/main/scala/org/apache/spark/network/ConnectionManager.scala
@@ -851,8 +851,8 @@ private[spark] class ConnectionManager(
messageStatuses.synchronized {
messageStatuses.remove(message.id).foreach ( s => {
promise.failure(
- new IOException(s"sendMessageReliably failed because ack " +
- "was not received within ${ackTimeout} sec"))
+ new IOException("sendMessageReliably failed because ack " +
+ s"was not received within $ackTimeout sec"))
})
}
}