org.apache.spark.sql.streaming.ContinuousQueryManagerSuite

awaitAnyTermination with timeout and resetTerminated
awaitAnyTermination without timeout and resetTerminated
listing