flink 命令行怎么查看任务为什么失败啊

在 Flink 命令行中，您可以使用 jobmanager 命令来查看任务的运行状态和日志信息，以帮助您诊断任务失败的原因。以下是使用 jobmanager 命令查看任务运行状态和日志信息的步骤：

首先，您需要连接到 Flink 的 JobManager。您可以使用以下命令来连接到 Flink 的 JobManager：
Copy code
$FLINK_HOME/bin/flink run -c org.apache.flink.client.cli.CliFrontend ./flink-1.13-dist/bin/flink run -m yarn-cluster -yn 2 -ys 2 -yjm 1024 -ytm 1024 -c com.example.FlinkJob /path/to/your/jar/file.jar
然后，您可以使用以下命令来查看任务的运行状态：
Copy code
$FLINK_HOME/bin/flink run -c org.apache.flink.client.cli.CliFrontend ./flink-1.13-dist/bin/flink run -m yarn-cluster -yn 2 -ys 2 -yjm 1024 -ytm 1024 -c com.example.FlinkJob /path/to/your/jar/file.jar --jobmanager http://localhost:9092
在上面的命令中，--jobmanager 参数指定了 Flink 的 JobManager 的地址。您可以使用 localhost 或者其他 Flink 节点的 IP 地址。
执行上面的命令后，您可以看到任务的运行状态，例如任务是否已经启动、是否已经结束、是否已经失败等。
如果任务已经失败，您可以使用以下命令来查看任务的日志信息：

Copy code
$FLINK_HOME/bin/flink run -c org.apache.flink.client.cli.CliFrontend ./flink-1.13-dist/bin/flink run -m yarn-cluster -yn 2 -ys 2 -yjm 1024 -ytm 1024 -c com.example.FlinkJob /path/to/your/jar/file.jar --jobmanager http://localhost:9092 --tail /path/to/your/jar/file.jar.log
在上面的命令中，--tail 参数指定了任务日志文件的路径。您可以使用任务的日志文件路径来查看任务的日志信息。
希望这些信息能够帮助您诊断任务失败的原因。