File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
core/src/main/scala/org/apache/spark/network/nio Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -460,7 +460,7 @@ private[spark] class ReceivingConnection(
460460 if (currId != null ) currId else super .getRemoteConnectionManagerId()
461461 }
462462
463- // The reciever 's remote address is the local socket on remote side : which is NOT
463+ // The receiver 's remote address is the local socket on remote side : which is NOT
464464 // the connection manager id of the receiver.
465465 // We infer that from the messages we receive on the receiver socket.
466466 private def processConnectionManagerId (header : MessageChunkHeader ) {
Original file line number Diff line number Diff line change @@ -501,7 +501,7 @@ private[nio] class ConnectionManager(
501501
502502 def changeConnectionKeyInterest (connection : Connection , ops : Int ) {
503503 keyInterestChangeRequests += ((connection.key, ops))
504- // so that registerations happen !
504+ // so that registrations happen !
505505 wakeupSelector()
506506 }
507507
@@ -832,7 +832,7 @@ private[nio] class ConnectionManager(
832832 }
833833
834834 /**
835- * Send a message and block until an acknowldgment is received or an error occurs.
835+ * Send a message and block until an acknowledgment is received or an error occurs.
836836 * @param connectionManagerId the message's destination
837837 * @param message the message being sent
838838 * @return a Future that either returns the acknowledgment message or captures an exception.
You can’t perform that action at this time.
0 commit comments