如何使用flink访问臭氧数据？

zdwk9cvp 于 2022-12-09 发布在 Apache

关注(0)|答案(1)|浏览(149)

When I use Flink to access the ozone file system, I configure the relevant configuration files and place the relevant jars in the hadoop classpath. An error is reported when accessing the file system using wordcount.*

environment:

hadoop3.2.2
Flink1.12.1
Ozone1.2.1
JDK1.8

But if I execute hadoop fs -ls ofs://jykj0.yarn.com/ alone there is no problem.
Below is my config file core-site.xml：

<property>
  <name>fs.ofs.impl</name>
  <value>org.apache.hadoop.fs.ozone.RootedOzoneFileSystem</value>
</property>

<property>
  <name>fs.AbstractFileSystem.ofs.impl</name>
  <value>org.apache.hadoop.fs.ozone.OzoneFileSystem</value>
 <value>org.apache.hadoop.fs.ozone.RootedOzoneFileSystem</value>
</property>