Github user jose-torres commented on a diff in the pull request:
    --- Diff: 
    @@ -68,7 +66,7 @@ private[shuffle] class UnsafeRowReceiver(
       override def receiveAndReply(context: RpcCallContext): 
PartialFunction[Any, Unit] = {
    -    case r: UnsafeRowReceiverMessage =>
    +    case r: RPCContinuousShuffleMessage =>
    --- End diff --
    I'm not sure what a critical RPC message is in this context. This line is 
intended to block forever if the queue is full; the receiver should not take 
any action or accept any other messages until the queue stops being full.


To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to