无限允许Apache Flink Windows延迟-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

无限允许Apache Flink Windows延迟

2018-11-28 16:01:06 1391 1

"
假定流中的事件(包含感兴趣的值)基于事件时间被分配给窗口。在我的情况下,事件不仅无序到达而且迟到,而且事件也是版本化的。我的意思是,对于给定的事件时间,两个事件可能会到达。在这种情况下,窗口应该再次点火。这些事件到来之间的时间可能是几天(甚至几周)。我已经找到了Windows允许的Lateness选项。这是一个可能的解决方案,还是这个数量在许多不能丢弃的窗口中,因为另一个事件可能仍然到达(这基本上归结为问题,如果窗口被持久化或保存在内存中)。"

取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:16:48

    "一般来说,允许的迟到需要是有限的,以避免保持无限量的状态。但是您可以将Flink配置为使用RocksDBStateBackend,它将状态溢出到磁盘,从而允许与本地磁盘一样多的状态。

    如果非常晚期的事件是罕见的,你可能最好以某种特殊的方式来容纳它们,而不是通过所有状态的开销来增加通用管道的负担。"

    0 0
相关问答

1

回答

Apache Flink库中的DataSet API是什么呢?

2021-12-07 21:12:50 121浏览量 回答数 1

1

回答

使用了 Flink CDC后有哪些优势?

2022-01-19 15:22:43 3908浏览量 回答数 1

1

回答

Flink CDC 中使用最多且最重要的是什么?

2022-01-19 15:24:00 2514浏览量 回答数 1

1

回答

Flink CDC 项目中的一致性通过加锁保证痛点是什么?

2022-01-19 15:25:54 2524浏览量 回答数 1

1

回答

Flink CDC 2.0的整体流程是怎么样的?

2022-01-19 15:33:19 2539浏览量 回答数 1

1

回答

Flink CDC 2.0的提升有哪些?

2022-01-19 15:34:27 2492浏览量 回答数 1

1

回答

Flink CDC Connectors是什么技术?

2022-01-19 15:39:18 562浏览量 回答数 1

1

回答

Flink CDC 2.1发布地址是什么?

2022-01-19 15:40:00 568浏览量 回答数 1

1

回答

Flink CDC 社区怎么做深 CDC 技术?

2022-01-19 15:47:02 503浏览量 回答数 1

1

回答

Flink CDC connectors方案有哪些优点?

2022-01-19 15:51:23 581浏览量 回答数 1
+关注
flink小助手
flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。
0
文章
377
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载