fix compile

jose-torres · jose-torres · commit cff37c45f084 · 2018-06-13T08:39:48.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/RPCContinuousShuffleWriter.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/RPCContinuousShuffleWriter.scala
@@ -53,7 +53,7 @@ class RPCContinuousShuffleWriter(
       endpoints(outputPartitioner.getPartition(row)).askSync[Unit](ReceiverRow(writerId, row))
     }
 
-    val futures = endpoints.map(_.ask[Unit](ReceiverEpochMarker(writerId)))
+    val futures = endpoints.map(_.ask[Unit](ReceiverEpochMarker(writerId))).toSeq
     implicit val ec = ThreadUtils.sameThread
     ThreadUtils.awaitResult(Future.sequence(futures), Duration.Inf)
   }

Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ class RPCContinuousShuffleWriter(`
`53`	`53`	`endpoints(outputPartitioner.getPartition(row)).askSync[Unit](ReceiverRow(writerId, row))`
`54`	`54`	`}`
`55`	`55`
`56`		`- val futures = endpoints.map(_.ask[Unit](ReceiverEpochMarker(writerId)))`
	`56`	`+ val futures = endpoints.map(_.ask[Unit](ReceiverEpochMarker(writerId))).toSeq`
`57`	`57`	`implicit val ec = ThreadUtils.sameThread`
`58`	`58`	`ThreadUtils.awaitResult(Future.sequence(futures), Duration.Inf)`
`59`	`59`	`}`