我有一个在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 是否支持这一点。 这方面的文件不存在。
有人可以分享一些这方面的信息吗?
启用可查询状态需要一些配置,这主要涉及公开某些端口。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 环境,其中包括一个用于为每个部署启用可查询状态的选项(此选项是高级配置部分的一部分(。