Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21560#discussion_r196238635
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/ContinuousShuffleReadRDD.scala
---
@@ -21,22 +21,25 @@ import java.util.UUID
import org.apache.spark.{Partition, SparkContext, SparkEnv, TaskContext}
import org.apache.spark.rdd.RDD
+import org.apache.spark.rpc.RpcAddress
import org.apache.spark.sql.catalyst.expressions.UnsafeRow
import org.apache.spark.sql.internal.SQLConf
import org.apache.spark.util.NextIterator
case class ContinuousShuffleReadPartition(
index: Int,
+ endpointName: String,
queueSize: Int,
numShuffleWriters: Int,
epochIntervalMs: Long)
extends Partition {
+
--- End diff --
Unnecessary
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
