niuaotian1 opened a new issue, #55820: URL: https://github.com/apache/doris/issues/55820
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/doris/issues?q=is%3Aissue) and found no similar issues. ### Version doris 版本：2.1.6 flink 版本1.15 doris connector 版本：1.6.2 （试过好几个版本） ### What's Wrong? kafka消费手动下发数据，agg模型会重复累加，确定消息只有一条，都是标准集群模式 <img width="618" height="181" alt="Image" src="https://github.com/user-attachments/assets/70948f0c-f290-4fc7-9a48-0f2992e70679"; /> topic 都是新建的，数据手动下发 77的数据就发了2条，统计出来是3条 99 的数据是3条 统计出来是5条 脚本语句： CREATE TABLE test ( student_id bigint(19), date_id date NOT NULL COMMENT '日期', student_name varchar(20) max, total_count bigint(19) sum, course_sum bigint(10) sum ) ENGINE=OLAP AGGREGATE KEY(student_id,date_id) AUTO PARTITION BY RANGE (date_trunc(date_id, 'day')) () DISTRIBUTED BY HASH(date_id) BUCKETS 1; select * from test; +------------+------------+--------------+-------------+------------+ | student_id | date_id | student_name | total_count | course_sum | +------------+------------+--------------+-------------+------------+ | 77 | 2025-09-09 | test2 | 3 | 201 | | 99 | 2025-09-09 | test2 | 5 | 387 | | 100 | 2025-09-09 | test2 | 1 | 80 | +------------+------------+--------------+-------------+------------+ ### What You Expected? agg模型消费一条，对应指标数据能单独增加，不会重复增加 ### How to Reproduce? _No response_ ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
