我有一个在ApacheFlink集群中使用可查询状态特性的用例。https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html#activating-可查询状态
我不想设置自己的集群(但希望利用现有的托管解决方案)。
我评估了两种可能性:使用aws运动数据应用程序(kda)或使用aws emr。
似乎kda不支持可查询状态。
我不确定emr是否支持这一点。这方面的文件是不存在的。
有人能分享一下这方面的信息吗?
1条答案
按热度按时间webghufk1#
启用可查询状态需要一些配置,这主要涉及公开某些端口。emr并不妨碍您这样做——如果您愿意/需要,您可以在emr上进行完全定制的flink安装。
您可能需要考虑的另一种方法是在eks上使用ververica平台的社区版。看到了吗https://www.ververica.com/blog/announcing-ververica-platform-community-edition 以及https://docs.ververica.com/v2.1/installation/hosted_k8s_quickstart/aws_eks.html. 使用此解决方案,您将获得一个完全托管的flink环境,其中包括一个用于在每个部署中启用可查询状态的选项(此选项是高级配置部分的一部分)。