问Apache K8s运算符和本机保存点格式
EN

Stack Overflow用户

提问于 2022-07-29 18:12:13

回答 1查看 150关注 0票数 0

Flink 1.15有一个新的本机保存点格式，它比当前的“规范”保存点格式更快地保存和恢复。但是，Flink文档只显示如何使用命令行编写本机保存点。我们正在K8s上运行Flink，目前正在使用Lyft Flink算子，但希望切换到新的Apache Flink算子。

此操作符可以定期地、在部署时或在向写保存点写入nonce时进行ConfigMap。我们想利用这一点。是否有任何方法来配置Apache操作符来编写本机保存点？

发布于 2022-08-01 08:43:15

当前，运算符在获取保存点(升级、手动/定期保存点)时总是使用默认(规范)格式。

没有内在的限制，为什么它这样做，但我们只是硬编码到默认时，增加了Flink 1.15支持最近。大多数相关代码都在FlinkService中，例如这里。

我认为我们应该将公开作为用户可以通过flinkConfiguration设置的一个简单配置选项。

为此打开了一个jira机票。如果你想把它捡起来，让我知道，应该很简单:)

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/73169474

复制

相似问题

问Apache K8s运算符和本机保存点格式EN