Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21428#discussion_r192258917
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/RPCContinuousShuffleReader.scala
---
@@ -48,7 +46,7 @@ private[shuffle] case class ReceiverEpochMarker(writerId:
Int) extends UnsafeRow
* TODO: Support multiple source tasks. We need to output a single epoch
marker once all
* source tasks have sent one.
*/
-private[shuffle] class UnsafeRowReceiver(
+private[shuffle] class RPCContinuousShuffleReader(
--- End diff --
Good point. Caught what I think are the rest.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
