Blog
flink-10 DataStream Api
自定义环境配置
// 自定义配置 修改 web页面端口
Configuration conf = new Configuration();
conf.setString(RestOptions.BIND_PORT, "8082");
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(conf);- 设置本地flink webui端口
- RestOptions 可以看到具体可以变更的参数
设置流 批运行模式
一般是在终端命令行参数中指定运行模式
bin/flink run -Dexecution.runtime-mode=BATCH ...