开发者社区> 问答> 正文

如果输入有回撤流的话,group by时间窗口会遇到GroupWindowAggregate

flink window doesn't support retract stream 的话有什么workaround办法吗?常见的场景有 业务表cdc -> kakfa -> flink按时间窗口聚合 如果业务表是只会insert的日志表,该如何将retract table转换成普通table?

GroupWindowAggregate doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[default_catalog, default_database, mcsp_pay_log, ...

按时间窗口聚合不支持上游是canal-json格式的cdc表的情况么?我的业务表其实是一张日志表,怎样用flink sql将retract table转成append table?*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-05 22:12:40 1049 0
1 条回答
写回答
取消 提交回答
  • toAppendDataStream试试看,希望对你有所帮助*来自志愿者整理的flink

    2021-12-05 22:40:21
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
4个迭代,从批量交...1573957773.pdf 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载