开发者社区> 问答> 正文
0
0
分享

关于flink-sql count/sum 数据如何每天重新计算

现有此场景: 计算每天员工的业绩(只计算当天的)

现在我用flink-sql 的方式,insert into select current_date, count(1) ,worker from XX where writeTime>=current_date group by worker; 把数据按天分区的方式先把数据sink到mysql

但是发现落地到mysql的数据把前几天的数据都给算进来了,如何只算今天的数据? 另外还有一个疑惑,如何既计算当天数据,又包含了本月的所有数据?*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-06 15:39:29 1093 0
举报
飞天免费试用计划
领取免费云资源,开启云上实践第一步
云数据库 RDS MySQL
集群系列 2核4GB
额度3个月内有效
实时计算 Flink 版
5000CU*H 3个月
额度3个月内有效
RDS MySQL Serverless 基础系列
0.5-2RCU 50GB
额度3个月内有效
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等