Apache Flink状态函数状态伸缩


0

我们可以随心所欲地扩展无状态函数。但是,如果我们在扩展无状态函数时不扩展它们,则有状态函数很可能成为瓶颈。由于数据在节点间的分布,缩放状态似乎很棘手。如果有状态函数成为瓶颈,我们能扩展它们吗?

1 答案


0

有状态函数的缩放方式与无状态函数完全相同。

在StateFun中,远程函数实际上是无状态进程,它们在调用给定密钥之前接收状态,在成功调用之后,状态的更改被传递回Flink集群。因此,扩展无状态或有状态函数实际上是一样的。

要了解更多信息,我建议您观看介绍StateFun 2.0的主题演讲或访问分布式体系结构页面


我来回答

写文章

提问题

面试题