Flink 本地开发 Web UI DashBoard

发表于 分类于

Flink 本地调试 Web UI DashBoard

Pom

1
2
3
4
5
<dependency>
	<groupId>org.apache.flink</groupId>
	<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
	<version>${flink.version}</version>
</dependency>

代码示例

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
package com.xxx.flink.app;

import com.xxx.flink.etl.UbtOdsEtl;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.RestOptions;
import org.apache.flink.streaming.api.CheckpointingMode;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class Main {

    public static void main(String[] args) throws Exception {

        Configuration conf = new Configuration();
        conf.setString(RestOptions.BIND_PORT, "8071-8089");
        //本地 WebUI DashBoard
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);

        //提交 Flink 集群使用
        //StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        env.setParallelism(3);
        env.enableCheckpointing(60000);
        env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);

        UbtOdsEtl.etl(env);

        env.execute();
    }
}

Flink WebUI DashBoard