电子病历上的检查点s3p flink

mzsu5hc0  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(359)

我有问题的检查点由s3p在flink的电子病历。
在创建emr集群时,我在presto中打了个勾,并按照中的说明添加了jar文件https://ci.apache.org/projects/flink/flink-docs-stable/ops/plugins.html.
但在flink中通过s3p检查point时,它仍然报告
原因:org.apache.flink.core.fs.unsupportedfilesystemschemeexception:找不到方案“s3p”的文件系统实现。flink通过以下插件直接支持该方案:flink-s3-fs-presto。请确保每个插件都位于插件目录中自己的子文件夹中。看到了吗https://ci.apache.org/projects/flink/flink-docs-stable/ops/plugins.html 更多信息。如果您想为该方案使用hadoop文件系统,请将该方案添加到配置fs.allowed-fallback-filesystems中。有关支持的文件系统的完整列表,请参阅https://ci.apache.org/projects/flink/flink-docs-stable/ops/filesystems/.
你能帮我检查一下电子病历上的s3p检查站吗?谢谢。

vmdwslir

vmdwslir1#

电子病历里的presto和 flink-s3-fs-presto flink中的插件。你可以让它在未来不受束缚(除了炸掉东西也不会伤害)。
最可能的原因是您忘记在plugins文件夹中创建子文件夹。你能给我个电话吗 ls 你的Flink分布?

相关问题