@TOC

程序打包

  1. 先在pom里加上插件
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
<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>
  1. 按照下面的步骤把程序打包即可
  2. 到上面的路径下找到自己的包即可

web页面提交

  1. 到自己的flink web页面，按照下面的步骤依次点击上传自己的程序包
  2. 再按照下面的步骤提交jar包
  3. 提交成功之后就会出现下面的页面

命令行提交

命令：

1
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页面会有正在运行的任务：


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