hadoop - 将 Flink 1.8.0 升级到 1.11.2 的问题

Question

我们在将 Flink 1.8.0 升级到 1.11.2 时遇到了一个问题。我们能够成功运行 Flink 给出的一些代码示例，例如 wordcount 和 window join。我们正在使用带有 Yarn 的 Flink。

我们的作业卡在接受状态，并显示消息“AM 容器已启动，等待 AM 容器向 RM 注册”。我们将上述示例代码使用的依赖项与我的代码所需的其他依赖项一起使用。我们在纱线队列中有足够多的资源。

使用此命令提交作业：

/home/hdfs/flink-1.11.2/bin/flink run -m yarn-cluster -p 4 -yjm 8096m -ytm 8098m -c test.StreamJob -jar /tmp/stream.jar --config ./config.json > ./test_bkt.log

标签： hadoopapache-flinkhadoop-yarn