Hadoop 集成

使用 Hadoop 类路径配置 Flink

Flink 将使用环境变量 HADOOP_CLASSPATH 来扩充启动 Flink 组件（如 Client，JobManager 或 TaskManager）时使用的类路径。默认情况下，大多数 Hadoop 发行版和云环境都不会设置此变量，因此如果 Flink 选择 Hadoop 类路径，则必须在运行 Flink 组件的所有计算机上导出环境变量。

在 YARN 上运行时，这通常不是问题，因为在 YARN 中运行的组件将使用 Hadoop 类路径启动，但是在向 YARN 提交作业时，Hadoop 依赖项必须位于类路径中。为此，通常就足够了

export HADOOP_CLASSPATH=`hadoop classpath`

In the shell 。请注意，这 hadoop 是 hadoop 二进制文件，它 classpath 是一个参数，用于打印已配置的 Hadoop 类路径。