StructuredStreaming中，如果trigger触发时前一批数据还没处理完怎么办？

会等之前job执行完再执行此次job。

设定trigger的触发时间为100ms，不断的对source写入数据，可以发现前一个trigger触发的数据批次计算job如果没有处理完，后一个job不会启动，不会并行的去执行job。
每个trigger触发时会启动一个新的job计算当前批次数据。

 

链接：https://www.jianshu.com/p/bc626390cf48