大_G 2022-03-31 13:07 采纳率: 42.9%
浏览 34
已结题

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

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

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

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

img

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

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


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

  • 写回答

2条回答 默认 最新

报告相同问题?

问题事件

  • 已结题 (查看结题原因) 4月2日
  • 修改了问题 3月31日
  • 创建了问题 3月31日