spark structured streaming在对kfaka的流数据做多个query时候,有的query没有执行。spark版本是2.3,query全部执行后调用了spark.streams.waitAnyTeimination()还是不行,请问怎么全部执行?
streaming本来也不是实时的 有时间窗口 可能是时间窗口的问题 调一下时间窗口的大小
`单行代码`
关注海汼部落