Github user jose-torres commented on the issue:
https://github.com/apache/spark/pull/20253
In commit 4bb9c3f, there are no occurrences remaining of the string
"processAllAvailable" in KafkaContinuousSourceSuite.scala,
KafkaContinuousSinkSuite.scala, KafkaContinuousTest.scala, or StreamTest.scala.
There are four occurrences in KafkaSourceSuite.scala, two within the
MicroBatch suite and two matched to not happen in ContinuousExecution. (One
test with a foreach sink was moved to the MicroBatch suite, because it was
executing in microbatch mode anyway since we haven't updated foreach for
continuous processing.)
I believe this is exhaustive.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
