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: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to