QueryableState Flink AWS EMR



我有一个在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 环境,其中包括一个用于为每个部署启用可查询状态的选项(此选项是高级配置部分的一部分(。

相关内容

  • 没有找到相关文章

最新更新