程序员经验分享-hwhale

Flink Connection拒绝：localhost / 127.0.0.1:8081

2023-11-06

提交flink 任务报错

Exception: Connection refused: localhost/127.0.0.1:8081
    at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
    at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
    ... 16 more
Caused by: org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:8081

 

错误的原因：没有启动flink

启动flink  ./bin/start-cluster.sh

 

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

flink

异常

Flink Connection拒绝：localhost / 127.0.0.1:8081 的相关文章

  • Flink CDC（2.0） 如何加速海量数据的实时集成？

    原文 Flink CDC 如何加速海量数据的实时集成 知乎 导读 Flink CDC如何解决海量数据集成的痛点 如何加速海量数据处理 Flink CDC社区如何运营 如何参与社区贡献 今天的介绍会围绕下面四点展开 Flink CDC 技术

  • Macbook Pro 鼠标卡顿问题

    Macbook Pro 鼠标卡顿问题 目前无解 只能改善 该问题最早能追溯到 2015年 https jingyan baidu com article ff42efa93632c5c19e220208 html 原因 据说是无线频段冲突

  • 微众银行DSS部署单机-普通版

    DSS 普通版部署 我的服务器 我的配置 vim conf config sh vim conf db sh QA 我的服务器 centos 7 0 8C16G 100G机械硬盘 我的配置 bashrc文件内容 JDK export JAV

  • Flink---1、概述、快速上手

    1 Flink概述 1 1 Flink是什么 Flink的官网主页地址 https flink apache org Flink的核心目标是 数据流上有状态的计算 Stateful Computations over Data Stream

  • Flink Web UI 介绍

    一 提交flink任务到yarn flink run m yarn cluster yn 1 p 2 yjm 1024 ytm 1024 ynm FlinkOnYarnSession MemberLogInfoProducer d c co

  • flink源码阅读---Flink intervalJoin 使用和原理分析

    1 前言 Flink中基于DataStream的join 只能实现在同一个窗口的两个数据流进行join 但是在实际中常常会存在数据乱序或者延时的情况 导致两个流的数据进度不一致 就会出现数据跨窗口的情况 那么数据就无法在同一个窗口内join

  • flink中AggregateFunction 执行步骤以及含义全网详细解释

    package operator import org apache flink api common functions AggregateFunction import org apache flink api common funct

  • 基于Canal与Flink实现数据实时增量同步(一)

    点击上方蓝色字体 关注我 canal是阿里巴巴旗下的一款开源项目 纯Java开发 基于数据库增量日志解析 提供增量数据订阅 消费 目前主要支持了MySQL 也支持mariaDB 准备 配置MySQL的binlog 常见的binlog命令 是

  • 不得不引起足够重视的anonymous用户！

    连日的阴雨 使原本炎热的天气突然变得潮湿起来 烦躁的心情也慢慢地平复了下来 像往常一下 借用CuteFtp工具登录自己的VPS 检查一下文件异常 突然之间 几个刺眼的 exe文件呈现在我的眼前 顿时惊出我一身冷汗 下意识到 网站被黑客入侵了

  • Flink checkPoint和SavePoint

    savepoint和checkpoint都是flink为容错提供的强大功能特性 能够自动或手动保存job的运行状态 两者区别 checkpoint 应用定时触发 用户保存状态 会过期 内部应用失败重启的时候启用 但是手动cancel时 会删

  • 【源码改造】Flink-jdbc-connector源码简析+改造支持谓词下推

    一 需求背景分析 flink sql在维表关联时 会有一个场景 当右表的数据量比较大且有些数据虽然符合join条件 但其实对于下游来说数据可能没用 这样就浪费了flink的计算资源 且拉低了数据处理能力 如果在join前就把维表的数据进一步

  • flink 1.4版本flink table方式消费kafka写入hive方式踩坑

    最近在搞flink 搞了一个当前比较新的版本试了一下 当时运行了很长时间 hdfs里面查询有文件 但是hive里面查询这个表为空 后面用了很多种方式 一些是说自己去刷新hive表 如下 第一种方式刷新 alter table t kafka

  • flink学习42：tableAPI的join、union、排序、插入操作

    连接 内连接 外连接 集合操作 union 获取交集 获取差集 in 操作 排序操作 插入操作

  • Apache Flink Checkpoint 应用实践

    Checkpoint 与 state 的关系 Checkpoint 是从 source 触发到下游所有节点完成的一次全局操作 下图可以有一个对 Checkpoint 的直观感受 红框里面可以看到一共触发了 569K 次 Checkpoint

  • flink大数据处理流式计算详解

    flink大数据处理 文章目录 flink大数据处理 二 WebUI可视化界面 测试用 三 Flink部署 3 1 JobManager 3 2 TaskManager 3 3 并行度的调整配置 3 4 区分 TaskSolt和parall

  • 流计算框架 Flink 与 Storm 的性能对比

    概述 将分布式实时计算框架 Flink 与 Storm 进行性能对比 为实时计算平台和业务提供数据参考 一 背景 Apache Flink 和 Apache Storm 是当前业界广泛使用的两个分布式实时计算框架 其中 Apache Sto

  • 【硬刚大数据之学习路线篇】2021年从零到大数据专家的学习指南(全面升级版)

    欢迎关注博客主页 https blog csdn net u013411339 本文由 王知无 原创 首发于 CSDN博客 本文首发CSDN论坛 未经过官方和本人允许 严禁转载 欢迎点赞 收藏 留言 欢迎留言交流 声明 本篇博客在我之前发表

  • JAVA,异常

    异常概念 通常大家认为异常就是错误 但这个错误有很多种 1 语法错误 2 JVM虚拟机错误 3 平台错误 4 程序运行错误 平台或者资源或者逻辑 数值等错误 常见的异常 1 java lang NullPointerException 空指

  • Flink_06_ProcessAPI(个人总结)

    声明 1 本文为我的个人复习总结 并非那种从零基础开始普及知识 内容详细全面 言辞官方的文章 2 由于是个人总结 所以用最精简的话语来写文章 3 若有错误不当之处 请指出 侧输出流 SideOutput 即分支流 可以用来接收迟到数据 也可

  • 在JDK17尝鲜Flink1.17

    在JDK17尝鲜Flink1 17 前言 还没玩明白老版本 Flink1 17就来了 总还是要向前看的 根据官网文档 https nightlies apache org flink flink docs release 1 17 docs

随机推荐

  • 基于沙猫群优化算法的函数寻优算法

    文章目录 一 理论基础 1 沙猫群优化算法 1 初始化种群 2 搜索猎物 探索 3 攻击猎物 开发 4 探索和开发 2 SCSO算法伪代码 二 仿真实验与结果分析 三 参考文献 一 理论基础 1 沙猫群优化算法 文献 1 提出了一种新的元启

  • 【Apifox】国产测试工具雄起

    在开发过程中 我们总是避免不了进行接口的测试 而相比手动敲测试代码 使用测试工具进行测试更为便捷 高效 今天发现了一个非常好用的接口测试工具Apifox 相比于Postman 他还拥有一个非常nb的功能 在接口的测试完成后 它可以一键生成接

  • Scripting.FileSystemObject控件的用法

    文件系统对象FSO的英文全称是File System Object 这种对象模型提出了有别于传统的文件操作语句处理文件和文件夹的方法 通过采用object method这种在面向对象编程中广泛使用的语法 将一系列操作文件和文件夹的动作通过调

  • Cadence orcad 原理图导出带书签目录的办法

    Cadence orcad 导出pdf 方便软件工程师或者其他人员查看 但是Cadence自带的导出pdf的办法不能同时导出书签目录 不利于查看 这片文章就是介绍怎么使用Cadence orcad 原理图导出带书签目录的pdf 这里以cad

  • 使用umr读取AMDGPU VRAM

    使用umr读取AMDGPU VRAM 造case 使用UMR读取内存 使用devmem2验证读取 huge page 造case gdb args kfdtest GNU gdb Ubuntu 9 2 0ubuntu1 20 04 1 9

  • 自动发送邮件（第一次做勿喷）

    import smtplib from email message import EmailMessage email EmailMessage Creating a object for EmailMessage email from x

  • 考ACM需要的知识(转)

    转自 http www ithao123 com topic 10002 html 对ACM竞赛的算法大概分了一下类 分成了数学 数据结构和算法三大块 对ACM竞赛的算法大概分了一下类 分成了数学 数据结构和算法三大块 一 数学 Mathe

  • 在机器学习里，什么是凸样本集和非凸样本集？

    如果一个数据集D是凸的 那么对于其中任意的两点x y D R 0 1 则 x 1 y D表达式 x 1 y被称作点x y 的 凸性组合 convex combination 简单来说 数据集D中任意两点的连线上的点 也会在数据集D内 那么数

  • Linux性能监控命令_nmon 安装与使用

    目录 1 安装nmon 1 1 下载 nmon 监控工具 1 2 下载 nmon 分析工具 2 nmon监控 2 1 实时监控 监控CPU 监控内存 监控磁盘 监控网络 监控文件系统 2 2 后台监控 3 图形报表解读 3 1 SYS SU

  • 剑指offer 学习笔记 构建乘积数组

    面试题66 构建乘积数组 给定一个数组A n 请构建一个数组B n 其中B i A 0 xA 1 x xA i 1 xA i 1 x xA n 1 不能使用除法 如没有不能使用除法的限制 可以用A中所有元素的乘积除A i 来得到B i 此时

  • C#调用Java后端的restful接口（传递多参数）

    由于工作中的需要 在C 的winform窗口中调用html前端页面 是用webbrowser实现 此处不多做概述 但是前端请求的接口是用Java编写的 在webbrowser中使用C 来请求Java后端的restful接口 此处是C win

  • 掌上生活服务器维护中,招行掌上生活登录不上

    由于换了手机号 招行掌上生活一直登不上 打了不下10个客服电话后 终于得到一套非常复杂可能有效尚未尝试的解决方案 怕等下忘了 赶紧先记录一下 那么这个方案复杂到什么程度呢 复杂到客服妹妹已经无法理解 只能一字不落地读给我听然后寄希望于我的程

  • 可信启动、安全启动：SGX、TrustZone、SecureEnclave

    最近在公众号上看到了一篇文章 算是又丰富了自己的安全方面的眼界 最近看公众号取代了小视频 知乎这些东西 以前是真的不喜欢碎片化的东西 看什么学什么总是要找到书籍 但是这样的做法太过的极端 因为有时候有些事是两面性的 比如像安全这方面 本来有

  • Java 华为真题-黄金宝箱最大值

    需求 一贫如洗的樵夫阿里巴巴在去砍柴的路上 无意中发现了强盗集团的藏宝地 藏宝地有编号从0 N的箱子 每个箱子上面贴有一个数字 阿里巴巴念出一个咒语数字k k

  • New Bing/Bing AI一直提示未登录

    重新注册microsoft账号 任意邮箱均可 地区选US 期间必须一直挂着全局dl

  • 如何解决秒杀的性能问题和超卖的讨论

    一 秒杀带来了什么 秒杀或抢购活动一般会经过 预约 抢订单 支付 这3个大环节 而其中 抢订单 这个环节是最考验业务提供方的抗压能力的 抢订单环节一般会带来2个问题 1 高并发 比较火热的秒杀在线人数都是10w起的 如此之高的在线人数对于网

  • 树莓派无屏幕wifi ssh和vnc界面连接，手机ssh连接

    系统下载和系统烧写到SD卡 国内下载地址 下载zip解压 https mirrors tuna tsinghua edu cn raspberry pi os images raspios full armhf images raspios

  • 新技能 get —— Python 断点续传下载文件

    from urllib request import urlretrieve import sys import os prev reported download percent None 首先定义下载 hook 作为 urllib re

  • Elastic Search 相关度计算

    为了搞清楚elastic search背后是如何计算文档搜索时候的相关度 我决定自己做实验去探索 这篇博客讲得还不错 http blog csdn net dm vincent article details 42099063 而博客本身也

  • Flink Connection拒绝：localhost / 127.0.0.1:8081

    提交flink 任务报错 Exception Connection refused localhost 127 0 0 1 8081 at java util concurrent CompletableFuture encodeThrow

热门标签