#提交任务 flink run-application -t yarn-application /root/flink060106_util.jar。。。怎么理解。。
时间: 2024-06-04 19:08:26 浏览: 14
这是在使用 Apache Flink 分布式处理框架时提交一个任务的命令,具体解释如下:
`flink run-application`:启动一个 Flink 应用程序。
`-t yarn-application`:指定提交到 YARN 集群上运行。
`/root/flink060106_util.jar`:指定要运行的应用程序 JAR 包路径。
因此,该命令的含义是将 `/root/flink060106_util.jar` 提交到 YARN 集群以运行 Flink 应用程序。
相关问题
link.state.backend.path=hdfs://#HADOOP_NAMENODE_HOST#:#HADOOP_NAMENODE_PORT#/flink/etl-checkpoints
这个配置参数是用于设置 Flink 状态后端的路径。状态后端是用来存储 Flink 任务的状态信息的地方,以便在任务失败后进行恢复。
在给定的配置中,`link.state.backend.path` 被设置为 `hdfs://#HADOOP_NAMENODE_HOST#:#HADOOP_NAMENODE_PORT#/flink/etl-checkpoints`。这意味着 Flink 将使用 HDFS 作为状态后端,并将状态数据保存在指定路径下的 `flink/etl-checkpoints` 目录中。
需要注意的是,`#HADOOP_NAMENODE_HOST#` 和 `#HADOOP_NAMENODE_PORT#` 是占位符,表示你需要根据你的实际 Hadoop 集群配置来替换它们。你需要将 `HADOOP_NAMENODE_HOST` 替换为你的 Hadoop NameNode 主机名或 IP 地址,将 `HADOOP_NAMENODE_PORT` 替换为 Hadoop NameNode 的端口号。
确保配置正确,并且 Flink 可以访问指定路径下的 HDFS 文件系统,以便能够正常进行状态存储和恢复操作。
sudo mv ./ flink-1.9.1 ./flink mv: 目标'./flink' 不是目录
根据提供的引用,`sudo mv ./ flink-1.9.1 ./flink`这个命令的作用是将当前目录下的所有文件和文件夹移动到名为`flink-1.9.1`的目录下,并将`flink-1.9.1`目录重命名为`flink`,然后将`flink`目录的所有者和所属组都设置为`silver`。如果执行该命令时出现`mv: 目标'./flink' 不是目录`的错误,可能是因为当前目录下已经存在名为`flink`的文件,导致无法将`flink-1.9.1`目录重命名为`flink`。此时可以先删除当前目录下的`flink`文件,再重新执行`sudo mv ./ flink-1.9.1 ./flink`命令。
相关推荐
![jar](https://img-home.csdnimg.cn/images/20210720083455.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)