开发者社区大数据与机器学习实时计算 Flink 正文

想问一下，flink窗口外如何保证顺序呢？即使kafka过来的数据，我们开窗处理后也按照kafka的

想问一下，flink窗口外如何保证顺序呢？即使kafka过来的数据，我们开窗处理后也按照kafka的顺序发出去。

展开

收起

云上静思 2022-08-03 10:57:37 913 版权

1 条回答

写回答

取消提交回答

云墩墩

flink是一条一条读取数据然后处理 sink的。考虑增加个外部存储redis。

此答案来自钉钉群“【2】Apache Flink China 社区”

2022-08-03 17:29:36

赞同展开评论

问答分类：

消息中间件 Kafka 流计算实时计算 Flink版云消息队列 Kafka 版

问答标签：

实时计算 Flink版数据实时计算 Flink版kafka 云消息队列 Kafka 版flink 云消息队列 Kafka 版数据实时计算 Flink版窗口

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

Flink CDC 如何保证数据读取的一致性？

Kafka如何保证顺序消费？

Flink中keyby以后是按照每个key值分别开窗吧？不同key值的窗口是互不影响的对吗？

咨询一个Flink问题，非开窗，非聚合的数据倾斜有什么优化思路？

咨询一个Flink问题，非开窗，非聚合的数据倾斜咋优化呀?

请教下在聚合场景下，如果上游数据出现更新或者删除，如何保证flink sql聚合结果的准确性？

Flink多并发sink 更新 redis 值，如何保证数据能按事件时间来更新数据？一致性如何保证？

566

Flink CDC里我一执行滚动开窗，就报下面的错误怎么解决？

111

Flink窗口计算是每来一个数据都会开窗吗？

在OceanBase数据库多个kafka消费者读取ob一张表数据如何保证不重复呀？

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199211

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

JVM实战—5.G1垃圾回收器的原理和调优

智能运维，由你定义：SAE自定义日志与监控解决方案

用Apifox调试Socket.IO接口，从原理到实践

4步实现状态机驱动的MQTT客户端，快速接入OneNet (1)

阿里妈妈基于 Flink+Paimon 的 Lakehouse 应用实践

想问一下，flink窗口外如何保证顺序呢？即使kafka过来的数据，我们开窗处理后也按照kafka的

实时计算 Flink

相关文章

热门讨论

热门文章