0

我有一个在 Apache Flink 集群中使用可查询状态功能的用例。 https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html#activating-queryable-state

我不想设置自己的集群(但想利用现有的托管解决方案)。

我评估了两种可能性:使用 AWS Kinesis Data Application(KDA) 或使用 AWS EMR。

KDA 似乎不支持可查询状态。

我不确定 EMR 是否支持。不存在这方面的文档。

有人可以分享一些这方面的信息吗?

4

1 回答 1

0

启用可查询状态需要一些配置,这主要涉及公开某些端口。EMR 不会阻止您这样做——如果您愿意/需要,您可以在 EMR 上进行完全自定义的 Flink 安装。

您可能要考虑的另一种方法是在 EKS 上使用 Ververica Platform 的社区版。请参阅https://www.ververica.com/blog/announcing-ververica-platform-community-editionhttps://docs.ververica.com/v2.1/installation/hosted_k8s_quickstart/aws_eks.html。使用此解决方案,您将获得一个完全托管的 Flink 环境,其中包括一个用于在每个部署中启用可查询状态的选项(此选项是高级配置部分的一部分)。

于 2020-05-18T13:51:33.727 回答