Does anyone who worked on SS or is familiar with it have an opinion on this?:
https://issues.apache.org/jira/browse/SPARK-24699 https://github.com/apache/spark/pull/21676 I don't like the idea of making Trigger.Once execute two batches, but it is the simplest way to get the desired batch state cleanup and output.