从flink集群外部访问flink状态的方法有哪些？

Question

TestEvent{
 String id,
 DateTime created_at,
 Long amount
} 

PS：我们可以将flink状态存储在dynamoDB中，并在那里创建一个API吗？还是以任何其他方式坚持和向外部世界揭露国家？

Answer 1

我建议现在忽略状态，而将接收器作为流应用程序输出结果的主要方式。

如果您已经使用Kinesis进行输入，您也可以使用Kinesis输出Flink的结果。然后，您可以使用AWS提供的DynamoDB的Kinesis适配器，如在相关的stackoverflow帖子中进一步描述的。

回到您最初的问题：您可以查询Flinks状态并将REST API与您的流应用程序一起提供，但这是一大堆工作，并不需要实现您的目标。您还可以通过state API访问checkpoint/savepointed状态，但这仍然是相当多的手工工作，可以通过上面概述的通常路线来保存。