Flink 编译 Flink1.9.1-CDH6.2 对应版本

Flink 在 CDH 6.2 平台上的编译需要特别注意 Hadoop 版本，因为 CDH 6.2 使用的 Hadoop 版本是 hadoop-3.0.0-cdh6.2.0。为了编译 Flink 1.9.1 在这个平台上，我们需要重新编译 Flink，以适应这个特定的 Hadoop 版本。
编译过程可以通过 Git 方式进行。首先，我们需要下载并编译 flink-shade。flink-shade 是 Flink 的一个子项目，它将 Flink 对应的 Hadoop 版本编译打包到本地 Maven 库中，以便在编译 Flink 时使用。在这个例子中，Flink 1.9.1 需要 flink-shaded-7.0。
具体步骤如下：

1. 从 Flink 的官方镜像站下载 flink-1.9.1-src.tgz 或 flink-shaded-7.0-src.tgz。
2. 解压下载的压缩文件。
3. 在解压后的目录中，执行 git clone 或下载 flink-shade 的源码。
4. 进入 flink-shade 的目录，执行 mvn clean install。
5. 在 Maven 本地仓库中，找到刚刚编译完成的 flink-shaded-7.0，并将其添加到 Flink 的依赖中。
6. 最后，重新编译 Flink，编译完成后即可得到适应 CDH 6.2 平台的 Flink 1.9.1。
   需要注意的是，在编译过程中可能会遇到一些问题，比如依赖冲突、版本不匹配等。这时需要根据具体情况进行排查和解决。
   除了重新编译，也可以选择使用 Flink 的 Standalone Cluster 模式，这种模式可以直接使用相应版本的 Flink，无需进行额外的编译。但需要注意的是，Standalone Cluster 模式仅适用于小规模的数据处理和分析场景，对于大规模的数据处理和实时计算，还是推荐使用 YARN 或 Mesos 等资源调度框架进行部署和管理。
   此外，为了更好地管理和维护 Flink 系统，建议在使用前仔细阅读官方文档和相关资料，了解 Flink 的系统架构、部署方式、性能优化等方面的知识。