File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/core/src/test/scala/org/apache/spark/sql/streaming Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -460,9 +460,9 @@ class StreamingQuerySuite extends StreamTest with BeforeAndAfter with Logging wi
460460 val streamingInputDF = createSingleTriggerStreamingDF(streamingTriggerDF).toDF(" value" )
461461
462462 val progress = getFirstProgress(streamingInputDF.join(streamingInputDF, " value" ))
463- assert(progress.numInputRows === 20 ) // data is read multiple times in self-joins
463+ assert(progress.numInputRows === 10 )
464464 assert(progress.sources.size === 1 )
465- assert(progress.sources(0 ).numInputRows === 20 )
465+ assert(progress.sources(0 ).numInputRows === 10 )
466466 }
467467
468468 test(" input row calculation with mixed batch and streaming V1 sources" ) {
You can’t perform that action at this time.
0 commit comments