Skip to content

Commit 4be6906

Browse files
committed
Fix Spark Scala style for line over 100 chars.
1 parent 85b24f7 commit 4be6906

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

core/src/main/scala/org/apache/spark/network/ConnectionManager.scala

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -428,15 +428,15 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
428428
connectionsAwaitingSasl -= connection.connectionId
429429

430430
messageStatuses.synchronized {
431-
messageStatuses
432-
.values.filter(_.connectionManagerId == sendingConnectionManagerId).foreach(status => {
433-
logInfo("Notifying " + status)
434-
status.synchronized {
435-
status.attempted = true
436-
status.acked = false
437-
status.markDone()
438-
}
439-
})
431+
messageStatuses.values.filter(_.connectionManagerId == sendingConnectionManagerId)
432+
.foreach(status => {
433+
logInfo("Notifying " + status)
434+
status.synchronized {
435+
status.attempted = true
436+
status.acked = false
437+
status.markDone()
438+
}
439+
})
440440

441441
messageStatuses.retain((i, status) => {
442442
status.connectionManagerId != sendingConnectionManagerId
@@ -461,7 +461,8 @@ private[spark] class ConnectionManager(port: Int, conf: SparkConf,
461461
assert(sendingConnectionManagerId == remoteConnectionManagerId)
462462

463463
messageStatuses.synchronized {
464-
for (s <- messageStatuses.values if s.connectionManagerId == sendingConnectionManagerId) {
464+
for (s <- messageStatuses.values
465+
if s.connectionManagerId == sendingConnectionManagerId) {
465466
logInfo("Notifying " + s)
466467
s.synchronized {
467468
s.attempted = true

0 commit comments

Comments
 (0)