fix for Scala 2.13

zsxwing · zsxwing · commit 144d19813f6b · 2021-04-24T15:05:06.000-07:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
@@ -60,7 +60,7 @@ class ContinuousSuiteBase extends StreamTest {
       c.committedOffsets.lastOption.map { case (_, offset) =>
         offset match {
           case o: RateStreamOffset =>
-            o.partitionToValueAndRunTimeMs.mapValues(_.value)
+            o.partitionToValueAndRunTimeMs.mapValues(_.value).toMap
         }
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ class ContinuousSuiteBase extends StreamTest {`
`60`	`60`	`c.committedOffsets.lastOption.map { case (_, offset) =>`
`61`	`61`	`offset match {`
`62`	`62`	`case o: RateStreamOffset =>`
`63`		`- o.partitionToValueAndRunTimeMs.mapValues(_.value)`
	`63`	`+ o.partitionToValueAndRunTimeMs.mapValues(_.value).toMap`
`64`	`64`	`}`
`65`	`65`	`}`
`66`	`66`	`}`