Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/20397#discussion_r167392663
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/RateSourceV2Suite.scala
---
@@ -78,7 +78,7 @@ class RateSourceV2Suite extends StreamTest {
val reader = new RateStreamMicroBatchReader(
new DataSourceV2Options(Map("numPartitions" -> "11", "rowsPerSecond"
-> "33").asJava))
reader.setOffsetRange(Optional.empty(), Optional.empty())
- val tasks = reader.createReadTasks()
+ val tasks = reader.createDataReaderFactories()
--- End diff --
nit: seems we should rename the variable too ..
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
