目前我有一个使用滑动窗口的流，可以通过这样的伪代码来减少。

val df = stream.withColumn("processingTime", current_timestamp()).
           .groupBy(// window of "5 min" as interval and 10 seconds slide Duration)
           .agg(// some aggregation here)
           .writeStream.forEachBatch( (batch, batchId) => {
                // Second aggregation and write batch to console
           }).trigger(Triggers.Processing("0 second"))
           .start()

我希望带有print out的代码每10秒控制一个批，但它总是每20秒执行一次。
可能的原因是什么？