Flink提交任务的两种方式非flink on yarn

目录

• 程序打包
• web页面提交
• 命令行提交

程序打包

1. 先在pom里加上插件

<build>
        <plugins>
            <!-- 该插件用于将Scala代码编译成class文件 -->
            <plugin>
                <groupId>net.alchim31.maven</groupId>
                <artifactId>scala-maven-plugin</artifactId>
                <version>3.2.2</version>
                <executions>
                    <execution>
                        <!-- 声明绑定到maven的compile阶段 -->
                        <goals>
                            <goal>compile</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-assembly-plugin</artifactId>
                <version>3.0.0</version>
                <configuration>
                    <descriptorRefs>
                        <descriptorRef>jar-with-dependencies</descriptorRef>
                    </descriptorRefs>
                </configuration>
                <executions>
                    <execution>
                        <id>make-assembly</id>
                        <phase>package</phase>
                        <goals>
                            <goal>single</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

2. 按照下面的步骤把程序打包即可
   

   

3. 到上面的路径下找到自己的包即可
   

   

web页面提交

1. 到自己的flink web页面，按照下面的步骤依次点击上传自己的程序包
   

   

2. 再按照下面的步骤提交jar包
   

   

3. 提交成功之后就会出现下面的页面
   

   

命令行提交

命令：

 bin/flink run -m master:8081 -p 4 -c [全类名] [jar包所在路径] --[属性名] 属性值

命令参数说明：

• -m
  • 指定主机名后面的端口为JobManager的 rest 通信端口，而不是 RPC 的端口，RPC通信端口是6123（在提交任务时，是通过 REST 端口号（HTTP端口号），将任务上传到JobManager）
• -p
  • 指定并行度（即使用几个Task Slots）
• -c
  • 指定main方法的全类名
• -s
  • 指定savePoint 的路径（用于任务重启时接上次操作继续进行，恢复数据使用）
• –hostname XXX --port XXX
  • 传入main方法的参数（以 – 属性名 属性值 的方式）

提交成功之后，web页面会有正在运行的任务：

喜欢的小伙伴给个关注吧~~~