在 Flink 的配置文件中设置 Hadoop 的环境变量,让 Flink 能够访问 Hadoop 的配置和文件系统。例如,可以通过设置 HADOOP_CLASSPATH 环境变量来实现。
将 Hadoop 的依赖打包到 Flink 的 uber jar 包中,这样 Flink 就能够直接访问 Hadoop 的 API 和文件系统。例如,可以下载 flink-shaded-hadoop-2-uber jar 包并将其放在 Flink 的 lib 目录中。
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/70024433/viewspace-2968563/ ,如需转载,请注明出处,否则将追究法律责任。