我有一个在 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 是否支持。不存在这方面的文档。
有人可以分享一些这方面的信息吗?