为什么spark结构化流聚合结果是空行在spark流结构中,如果将内部连接和聚合与水印一起使用,则获得零行作为输出如何修复它 所有批次均为空 我使用的代码: val joinedQuery = df1.join(df2, expr("id ...2024-10-01 已阅读: n次