要求是每来一条输出一次结果，计算一个数值按照group id，Flink有啥办法处理嘛？

在Flink中，你可以利用Group By操作和窗口操作来实现每来一条数据输出一次结果的需求。首先，你需要根据group id进行分组，然后使用窗口操作来定义每个窗口接收数据的条数。接着，你可以将窗口设置为滚动窗口，并设置窗口的步长为1，这样每来一条新数据就会触发一次计算，并将结果输出。

此外，Flink还支持高效的实时流计算，可以基于事件时间驱动或者处理时间驱动来进行计算。对于实时任务，Flink会生成一个数据源算子，该算子会持续不断地从Kafka中读取数据，并将每条数据发送给下游的Group聚合算子进行处理。发送数据的shuffle策略会根据group by中的key进行发送，相同的key会被发送到同一个SubTask（并发）中进行处理。

需要注意的是，Group By是SQL中最基础的分组操作，而agg则是SQL算子的统称，包含了COUNT/SUM/AVG等常用的聚合操作。在实际应用中，Group By+Agg的操作模式绝大多数场景下都会一起出现，因此理解并掌握好这种模式的最优写法也是非常重要的。

试试日志滚动，
https://blog.csdn.net/qq_21383435/article/details/115773446?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522169928010916800192258010%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=169928010916800192258010&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-4-115773446-null-null.nonecase&utm_term=flink%20%E6%97%A5%E5%BF%97%20&spm=1018.2226.3001.4450 此回答整理自钉群“【②群】Apache Flink China社区”