我是 Flink 的新手，我使用以下脚本将批处理模式字数统计提交到纱线。
./flink run -m yarn-cluster ../examples/batch/WordCount.jar
它以纱线簇模式运行，因此 JM 将在纱线簇的一个节点中运行。
到目前为止一切顺利，但我不明白为什么我在运行上述脚本的控制台上看到打印的单词数据集结果？
我想知道 flink 纱线集群的行为是什么，例如，如果我运行 Dataset#collect，哪个进程将获取元素？
您会看到结果，因为 JobManager 将它们发送到客户端（cmd 行脚本）。
- 纱线簇模式意味着每次执行都会启动一个单独的簇。
- Yarn 会话模式意味着您提交到已在运行的集群。
您可以在此处查看分布式运行时工作原理的更多信息。