Yarn上找不到flink提交的任务

如果您在Yarn上运行Flink任务时无法找到已提交的任务，您可以尝试执行以下步骤：

1. 检查Flink任务是否已成功提交。您可以通过在Flink客户端运行命令`flink list`来查看所有正在运行的任务和它们的状态。如果任务没有成功提交，则需要检查Flink任务的日志并解决任何错误。

2. 检查Yarn的日志以查看是否有任何错误消息。您可以通过运行以下命令查看Yarn的日志：

   yarn logs -applicationId <application_id>

其中，`<application_id>`是您提交的Flink任务的应用程序ID。

3. 检查Yarn的资源管理器以查看Flink任务是否正在运行。您可以通过打开Yarn资源管理器的Web界面并查看应用程序列表来检查Flink任务的状态。如果Flink任务已成功提交但未在Yarn资源管理器中显示，则可能是由于网络或配置问题。

如果您遇到任何其他问题，请查阅Flink和Yarn的文档以获取更多信息。

相关问题

flink on yarn 解析中文是"?" 但Idea无影响

Flink on YARN运行时出现中文字符显示为"?"的问题，通常与字符编码设置有关。当Flink在YARN上运行时，可能因为环境变量或者任务运行时的字符集配置不正确，导致中文字符无法正确解析和显示。而在IntelliJ IDEA中无影响，可能是因为IDE的默认设置已经配置了正确的字符编码，或者在本地开发环境中字符集支持较好。

解决这类问题，可以尝试以下几个步骤：

1. 确保在提交Flink任务到YARN之前，正确设置了环境变量，比如 `HADOOP_CONF_DIR` 和 `FLINK_CONF_DIR` 等，这些环境变量包含了集群配置信息，其中可能包含字符编码的配置。

2. 检查Flink配置文件 `flink-conf.yaml`，确保其中的字符编码设置是正确的，比如 `fs.overwriteゲ编码` 等参数。

3. 如果你是在Java中提交Flink作业，可以在代码中设置字符编码，比如：

System.setProperty("file.encoding", "UTF-8");

这可以确保在运行Java程序时使用正确的字符编码。

4. 检查YARN的配置，确保其运行时环境中的字符编码也是UTF-8，这可能需要修改YARN集群的一些配置参数。

5. 如果是在Linux环境下，可以通过 `echo $LANG` 查看当前系统语言设置是否为UTF-8，如果不是，可以考虑通过设置 `export LANG=en_US.UTF-8` 来调整。

通过上述步骤尝试解决Flink on YARN中文显示问题，通常可以得到改善。

开启 Hadoop 集群，在 yarn 上以 per job 模式（即 Job 分 离 模 式 ， 不 采 用 Session 模 式 ） 运 行$FLINK_HOME/examples/batch/WordCount.jar， 将运行结果最后 10 行截图粘贴到答

开启Hadoop YARN集群并以Per-Job模式运行Apache Flink的例子需要几个步骤：

1. **准备环境**：
- 安装并配置Hadoop和YARN，确保它们都正常运行。
- 将Flink安装到集群上，设置好环境变量指向`$FLINK_HOME`。

2. **启动YARN**：
- 在Hadoop集群的ResourceManager上启动YARN服务，确保它监听正确的端口，并且对JobSubmissionProtocol开放。

3. **配置Flink**：
- 在Flink配置文件`flink-conf.yaml`中，配置`jobManager.rpc.address`和`jobManager.high-availability.storageDir`指向YARN的RM地址。
- 关闭session模式，启用per-job模式。可以在`high-availability`部分添加：

     high-availability:
       mode: standalone

4. **打包应用**：
- 打包`examples/batch/WordCount.jar`，可能需要添加`yarn-client`或`yarn-application`作为maven或gradle插件，以便于YARN管理。

5. **提交任务**：
- 使用Flink的`flink run`命令或者`yarn client`工具提交任务，类似于：

     $ bin/flink run -c org.apache.flink.streaming.examples.WordCount WordCount.jar

或者在YARN客户端环境中：

     $ bin/flink run -s yarn-cluster -j WordCount.jar

6. **查看结果**：
- 任务完成后，从Hadoop的JobHistory服务器或者YARN的任务历史日志中查找WordCount作业的结果。

7. **截取结果**：
- 一旦看到结果，你可以选择手动复制最终10行内容或者利用某些脚本语言（如bash或Python）抓取并保存前10行到图片。

请注意，这里提供的是一般的指导步骤，实际操作可能会因特定环境而略有差异。完成任务后，你应能看到类似这样的输出：

...
[RESULT] Top 10 most frequent words:
word1 count1
word2 count2
...

然后截取这部分内容作为答案的一部分。