Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/20647#discussion_r170092091
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamSuite.scala ---
@@ -492,16 +492,16 @@ class StreamSuite extends StreamTest {
val explainWithoutExtended = q.explainInternal(false)
// `extended = false` only displays the physical plan.
-
assert("StreamingDataSourceV2Relation".r.findAllMatchIn(explainWithoutExtended).size
=== 0)
-
assert("DataSourceV2Scan".r.findAllMatchIn(explainWithoutExtended).size === 1)
+ assert("Streaming
Relation".r.findAllMatchIn(explainWithoutExtended).size === 0)
+ assert("Scan
FakeDataSourceV2".r.findAllMatchIn(explainWithoutExtended).size === 1)
--- End diff --
Why is this using the fake?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
