summer000
Results
1
comments of
summer000
您好，有一个疑问，文章里提到：“再次强调，(a+) 在对 event time 做 window() + groupBy().aggregation() 即利用状态做跨执行批次的聚合，并且 (b+) 输出模式为 Append 模式或 Update 模式时，才需要 watermark，其它时候不需要；” 但其实只要做基于event_time的filter，例如MapGroupsWithState中的GroupStateTimeout.EventTimeTimeout，也需要使用watermark。