检查点s3p在EMR上闪烁



我在EMR的flink中遇到了s3p的检查点问题。

创建EMR集群时,我在Presto中打了一个勾,并按照中的说明添加了jar文件https://ci.apache.org/projects/flink/flink-docs-stable/ops/plugins.html.

但当在flink中通过s3p检查点时,它仍然报告

由: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吗?谢谢

EMR中的Presto与Flink中的flink-s3-fs-presto插件无关。你以后可以把它解开(除了把东西炸开也没什么坏处(。

最可能的原因是您忘记在插件文件夹中创建子文件夹。你能给我一份Flink分销的ls吗?

相关内容

  • 没有找到相关文章

最新更新