Spark Structured Streaming 时间窗口 不能输出数据

问题遇到的现象和发生背景

Spark Structured Streaming 环境
接收 kafka 数据 进行处理 然后Append 模式 输出到控制台

问题相关代码,请勿粘贴截图

img

设置 watermark 和 window ,进行sum 聚合 控制台 没有输出数据

如果 只设置水位线 不进行sum 控制台可以数据数据,所以上面没有输出数据是什么原因


```scala
    val res_input = cityDS1
      .withWatermark("generation_time", "10 seconds")

https://blog.csdn.net/xiaoweite1/article/details/116040080?spm=1005.2026.3001.5635&utm_medium=distribute.pc_relevant_ask_down.none-task-blog-2~default~OPENSEARCH~Rate-4.pc_feed_download_top3ask&depth_1-utm_source=distribute.pc_relevant_ask_down.none-task-blog-2~default~OPENSEARCH~Rate-4.pc_feed_download_top3ask

https://www.cnblogs.com/tgzhu/p/7656508.html