diff options
author | Xiangrui Meng <meng@databricks.com> | 2014-08-25 14:55:20 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@apache.org> | 2014-08-25 14:55:20 -0700 |
commit | fd8ace2d9a796f69ce34ad202907008cd6e4d274 (patch) | |
tree | e93546a9e333b8ee5c7870588acbec16c333a08d | |
parent | cc40a709c0494b68404a90769efc7f2b415eb125 (diff) | |
download | spark-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
-rw-r--r-- | core/src/main/scala/org/apache/spark/network/ConnectionManager.scala | 4 |
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")) }) } } |