1 webui的依赖

<dependency><groupId>org.apache.flink</groupId><artifactId>flink-runtime-web_2.11</artifactId><version>${flink.version}</version><scope>${scope.type}</scope>
</dependency>

2 本地运行代码

import org.apache.flink.api.common.eventtime.WatermarkStrategy
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.configuration.{Configuration, RestOptions}
import org.apache.flink.connector.kafka.source.KafkaSource
import org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer
import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, createTypeInformation}
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironmentobject DataStreamReadKafka {def main(args: Array[String]): Unit = {// 创建带webui的本地执行环境val conf = new Configuration()conf.setString(RestOptions.BIND_PORT, "8081") // 指定访问端口val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf)env.setParallelism(1)val tab_env = StreamTableEnvironment.create(env)// 读取kafka数据val topics = "test,test_2".split(",").toListval source = KafkaSource.builder[String].setBootstrapServers("localhost:9092").setTopics(topics: _*).setGroupId("shy_test").setStartingOffsets(OffsetsInitializer.earliest).setValueOnlyDeserializer(new SimpleStringSchema()).buildval input_stream = env.fromSource(source, WatermarkStrategy.noWatermarks(), "kafka_source")input_stream.print()// 启动执行环境env.execute()}}

3 访问webui

http://localhost:8081/

注意: 每个任务指定一个端口访问webUI

flink本地运行及访问webui相关推荐

【Flink】Flink 1.9 本地运行无法访问界面 {“errors“:[“Not found.“]}
文章目录 1.美图 2. 场景1 2.1.概述 3.场景2 1.美图 2. 场景1 2.1.概述本地写了一个程序,运行起来,没看到界面 @Testpublic void connectTest2() ...
[docker] 解决 docker 部署访问提示 Empty reply from server，但是本地运行能够正常访问
起因最近通过 Docker 部署 Nestjs 应用的时候发现,本地运行起来好好的应用,但是部署到 docker 中访问就提示 Empty reply from server. 解决通过一番折腾, ...
Vue项目本地运行环境下设置既能localhost访问又能IP访问，并且可以外网环境下通过域名访问
打开项目build下index.js文件,将localhost改为 0.0.0.0,port端口号改不改都行,只要保证这个端口号没有被占用即可. 然后打开项目package.json文件,找到将红框 ...
【Vue2】让别人访问自己本地运行项目
让别人访问自己本地运行项目第一步:将vue.config.js中的host:"localhost"改为host:"0,0,0,0". module.expor ...
开发函数计算的正确姿势 —— 使用 Fun Local 本地运行与调试
前言首先介绍下在本文出现的几个比较重要的概念: 函数计算(Function Compute): 函数计算是一个事件驱动的服务,通过函数计算,用户无需管理服务器等运行情况,只需编写代码并上传.函数计算 ...
基于Docker本地运行k8s（单节点）
基于Docker本地运行Kubernetes 概览下面的指引将高速你如何通过Docker创建一个单机.单节点的Kubernetes集群. 下图是最终的结果: 先决条件你必须拥有一台安装有Docke ...
如何取消IE“已限制此网页运行可以访问计算机的脚本或ActiveX控件”(小技巧)...
在本地调试html页,如果其中包含js 或flash ,IE经常会提示"IE已限制此网页运行可以访问计算机的脚本或ActiveX控件 ".虽然出于安全考虑IE阻止本地脚本运行这个做 ...
使用 mock 数据在本地运行 SAP Fiori Elements 应用的工作原理
本系列的前两篇文章: 在没有任何前端开发经验的基础上, 创建第一个 SAP Fiori Elements 应用如何使用 mock 数据在本地运行 SAP Fiori Elements 本文研究 Fi ...
W ndoWs文件夹窗口,如何在本地网络中访问-Synology-NAS-上的文件-(Wndows).pdf
如何在本地网络中访问-Synology-NAS-上的文件-(Wndows) 如何在本地网络中访问 Synology NAS 上的文件 (Windows) 概述 Synology NAS 经过专门设计, ...
解决： Vue 项目本地运行 run 与服务器上 build 样式不一致，build 后样式不生效
前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. PS:本人遇到这个问题是用文中最后一句话解决:" 在组件的样式中记得添加 'scoped' ...

flink本地运行及访问webui

1 webui的依赖

2 本地运行代码

3 访问webui

flink本地运行及访问webui相关推荐

最新文章

热门文章