From fd8ace2d9a796f69ce34ad202907008cd6e4d274 Mon Sep 17 00:00:00 2001
From: Xiangrui Meng <meng@databricks.com>
Date: Mon, 25 Aug 2014 14:55:20 -0700
Subject: [PATCH] [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
---
.../scala/org/apache/spark/network/ConnectionManager.scala | 4 ++--
1 file 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"))
})
}
}
--
GitLab