Flink - 本地执行 Failed to start the Queryable State Data Server

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: Flink 本地执行任务报错 Failed to start the Queryable State Data Server 以及 Unable to start Queryable State Server. All ports in provided range are occupied. 根据报错分析是因为本地端口被占用,没有足够端口供 Flink 本地客户端启动,所以解决方法就是处理被占用的端口。...

 一.引言

Flink 本地执行任务报错 Failed to start the Queryable State Data Server 以及 Unable to start Queryable State Server. All ports in provided range are occupied. 根据报错分析是因为本地端口被占用,没有足够端口供 Flink Queryable DataServer启动,所以解决方法就是处理被占用的端口。Queryable DataServer 主要负责查询 Flink 作业内部 value 使用。

image.gif编辑

二.本机解决方案-Mac

重启电脑即可 (*^▽^*)

三.服务器解决方案-Linux

端口占用过多的话,那就找到哪个占用多然后把任务 kill 掉即可。

A.查看电脑当前端口使用情况,其中第一列为程序 command,第二列为程序对应的 pid

lsof -i

image.gif

image.gif编辑

B.找到占用过多端口的程序pid

kill 掉任务对应的 pid 即可

kill -9 $pid

image.gif

Tips:

如果已知某个端口被占用过多或者想查看某个端口的占用情况,可以指定端口 port 查询:

lsof -i tcp:$port

image.gif

例如查询 49662 端口的占用情况:

lsof -i tcp:49662

image.gif

COMMAND  PID     USER   FD   TYPE   DEVICE          SIZE/OFF NODE NAME
java    1751     BITDDD 67u  IPv6   0x3148f6fa1a7526a9 0t0 TCP localhost:49662 (LISTEN)

image.gif


相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
目录
相关文章
|
2月前
|
监控 Oracle 关系型数据库
Flink CDC(Change Data Capture)是一种用于捕获数据库变更的技术
Flink CDC(Change Data Capture)是一种用于捕获数据库变更的技术
36 8
|
1月前
|
存储 SQL Java
阿里Flink云服务提供了CDC(Change Data Capture)功能
【2月更文挑战第10天】阿里Flink云服务提供了CDC(Change Data Capture)功能
36 1
|
6月前
|
大数据 数据库 流计算
Flink CDC(Change Data Capture)是一种从数据库中捕获数据变化并将其转换为可用于处理的数据的方法
Flink CDC(Change Data Capture)是一种从数据库中捕获数据变化并将其转换为可用于处理的数据的方法
52 1
|
缓存 资源调度 分布式计算
Apache Flink 进阶(六):Flink 作业执行深度解析
主要分享内容为 Flink Job 执行作业的流程,文章将从两个方面进行分享:一是如何从 Program 到物理执行计划,二是生成物理执行计划后该如何调度和执行。
Apache Flink 进阶(六):Flink 作业执行深度解析
|
4月前
|
NoSQL MongoDB 数据安全/隐私保护
Flink CDC支持MongoDB的CDC(Change Data Capture)连接器
Flink CDC支持MongoDB的CDC(Change Data Capture)连接器
118 4
|
10月前
|
消息中间件 Oracle 关系型数据库
Flink CDC(Change Data Capture)
Flink CDC(Change Data Capture)是一个 Flink 应用程序,用于从关系型数据库(如 MySQL、PostgreSQL 等)中捕获数据更改,将其转换为流数据,并将其发送到 Flink
200 1
|
10月前
|
消息中间件 Oracle 关系型数据库
Flink CDC (Change Data Capture)
Flink CDC (Change Data Capture) 是一种基于 Flink 的流式数据处理技术,用于捕获数据源的变化,并将变化发送到下游系统。Flink CDC 可以将数据源的变化转换为流式数据,并实时地将数据流发送到下游系统,以便下游系统及时处理这些变化。
445 1
|
存储 SQL NoSQL
FFA 2022 主会场 Keynote:Flink Towards Streaming Data Warehouse
Apache Flink 中文社区发起人、阿里巴巴开源大数据平台负责人王峰(莫问)在 FFA 2022 主会场的分享。
FFA 2022 主会场 Keynote:Flink Towards Streaming Data Warehouse
|
消息中间件 数据采集 分布式计算
在 Cloudera Data Flow 上运行你的第一个 Flink 例子
本文主要是介绍如何在 CDH6.3 中安装 Flink 1.9 以及运行你的第一个 Flink 例子。