We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 287059a commit 7f4d78eCopy full SHA for 7f4d78e
1 file changed
core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala
@@ -611,7 +611,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll {
611
assert(reply2.contains(shortTimeout.timeoutProp))
612
613
// Ask with delayed response and allow the Future to timeout before Await.result
614
- val fut3 = rpcEndpointRef.ask[String](SleepyReply("goodbye"),shortTimeout)
+ val fut3 = rpcEndpointRef.ask[String](SleepyReply("goodbye"), shortTimeout)
615
616
// Allow future to complete with failure using plain Await.result, this will return
617
// once the future is complete to verify addMessageIfTimeout was invoked
0 commit comments