Skip to content
Snippets Groups Projects
Commit fd8ace2d authored by Xiangrui Meng's avatar Xiangrui Meng Committed by Josh Rosen
Browse files

[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
parent cc40a709
No related branches found
No related tags found
No related merge requests found
...@@ -851,8 +851,8 @@ private[spark] class ConnectionManager( ...@@ -851,8 +851,8 @@ private[spark] class ConnectionManager(
messageStatuses.synchronized { messageStatuses.synchronized {
messageStatuses.remove(message.id).foreach ( s => { messageStatuses.remove(message.id).foreach ( s => {
promise.failure( promise.failure(
new IOException(s"sendMessageReliably failed because ack " + new IOException("sendMessageReliably failed because ack " +
"was not received within ${ackTimeout} sec")) s"was not received within $ackTimeout sec"))
}) })
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment