大_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日

悬赏问题

  • ¥15 请问Ubuntu要怎么安装chrome呀?
  • ¥15 视频编码 十六进制问题
  • ¥15 Xsheii7我安装这个文件的时候跳出来另一个文件已锁定文件的无一部分进程无法访问。这个该怎么解决
  • ¥15 unity terrain打包后地形错位,跟建筑不在同一个位置,怎么办
  • ¥15 FileNotFoundError 解决方案
  • ¥15 uniapp实现如下图的图表功能
  • ¥15 u-subsection如何修改相邻两个节点样式
  • ¥30 vs2010开发 WFP(windows filtering platform)
  • ¥15 服务端控制goose报文控制块的发布问题
  • ¥15 学习指导与未来导向啊