错误 HBASE-ZOOKEEPER:连接太多

2023-11-29

我在我的应用程序中使用 Hbase-Hadoop 组合,并使用 Data Nucleus 作为 ORM。

当我尝试一次通过多个线程访问 Hbase 时,它​​会抛出异常:

Exception in thread "Thread-26" javax.jdo.JDODataStoreException

org.apache.hadoop.hbase.ZooKeeperConnectionException: HBase is able to connect to ZooKeeper but the connection closes immediately. This could be a sign that the server has too many connections (30 is the default). Consider inspecting your ZK server logs for that error and then make sure you are reusing HBaseConfiguration as often as you can. See HTable's javadoc for more information.

Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /hbase

我该如何处理这种情况?我需要做任何配置来增加连接池吗?


Zookeeper 服务器有一个活动连接限制,默认为 30。 您需要通过在zookeeper配置文件zoo.cfg中相应地设置maxClientCnxns属性来增加此限制。

对于 100 个连接:

maxClientCnxns=100

告诉zookeeper对连接数不施加限制:

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

错误 HBASE-ZOOKEEPER:连接太多 的相关文章

  • JDO 异常:“查询需要 1 个参数,但已提供 2 个值。”

    尽管我的 JDO 查询包含TWO declareParameters语句 下面的代码产生一个错误 声称只接受一个参数 查询需要 1 个参数 但已提供 2 个值 这两个参数是amountP and taxP javax jdo Query q
  • 如何更改hbase表中列族的名称

    我有一个 Hbase 表 只有 1 个列族 cf1 下面有 100 列 我需要将 cf1 更改为新的列族 CF1 简而言之 我需要修改列族名称 我已经浏览了以下链接http comments gmane org gmane comp jav
  • Spark:如何通过 python-api 使用 HBase 过滤器,例如 QualiferFilter

    我想通过使用像 python api 中的 QualiferFilter 这样的过滤器从 HBase 获取行 我知道如何从 HBase 获取行 就像在代码下一样 host localhost keyConv org apache spark
  • HBase 上的 Thrift 有性能基准吗?

    我有一个可以将大量数据写入 hbase 的系统 系统是用c 编写的 发现hbase有其他语言的thrift接口 我的问题是 HBase 上的 Thrift 有性能基准吗 与java原生api相比 最劣势是什么 我推荐最近关于这个主题的两篇博
  • 分布式序列号生成?

    我一般都实现了序列号生成过去使用数据库序列 例如使用 Postgres SERIAL 类型http www neilconway org docs sequences http www neilconway org docs sequenc
  • 如何在 hbase 中存储原始数据类型并检索

    如何使用 hbase api 存储和检索原始数据类型 我的任务是在 hbase 上保存随机事件 其中包含随机生成的不可预测的数据类型 并需要在我想要的时候取回它们 有人可以帮我解决这个问题吗 因为我对 hbase 和这些东西真的很陌生 这是
  • Hbase连接zookeeper错误

    环境 Ubuntu 14 04 hadoop 2 2 0 hbase 0 98 7 当我启动hadoop和hbase 单节点模式 时 都成功 我还检查了hadoop的网站8088 hbase的网站60010 jps 4507 Seconda
  • Kafka 无法在 Azure Web 应用服务上运行

    我们正在尝试在 Azure Web 应用服务上部署 Kafka 我们不断收到以下错误 容器 NN 未响应端口 2181 上的 HTTP ping 站点启动失败 请参阅容器日志进行调试 WEBSITES PORT 设置为 2181 并且在 D
  • 错误:org.apache.hadoop.hbase.MasterNotRunningException:null+hbase+hadoop

    我最近用两台机器 在ubuntu上 配置了hadoop集群 到目前为止效果很好 但是当我尝试在上面的 hadoop 集群上配置 hbase 时 它 显示错误 这就是我所做的 我有两台机器 192 168 1 110 Hadoop主站 192
  • Zookeeper管理服务器端口

    在Windows上安装了zookeeper 3 5 6 bin 出现错误 无法启动AdminServer 异常退出 org apache zookeeper server admin AdminServer AdminServerExcep
  • HBase:创建多个表或包含多个列的单个表?

    什么时候创建多个表而不是创建具有大量列的单个表才有意义 据我了解 表通常只有几个列族 1 2 每个列族可以支持 1000 多个列 当 HBase 似乎在单个表中可能存在大量列时表现良好时 什么时候创建单独的表才有意义 在回答问题本身之前 让
  • 动物园管理员:java.lang.ClassNotFoundException:org.apache.zookeeper.admin.ZooKeeperAdmin

    我有一个版本为3 4 10的zookeeper和版本为2 12 0的curator 但版本低于3 5 8的zookeeper对log4j1有严格的传递依赖 我想使用 log4j2 这就是为什么需要更新 Zookeeper 版本 我尝试了不同
  • 在hbase中创建表

    我是 hbase 和 hadoop 的新手 无论如何 我已经成功建立了一个由3台机器组成的hadoop集群 现在我需要一些帮助来建立数据库 我有一个表 评论 包含字段 user id comments 对评论的评论 可以多个 和状态字段相同
  • 与恶霸算法相比,高级主选举算法有什么好处?

    我读过当前的主选举算法 如 Raft Paxos 或 Zab 如何在集群上选举主节点 但不明白为什么他们使用复杂的算法而不是简单的恶霸算法 我正在开发一个集群库并使用 UDP 多播来发送心跳消息 每个节点加入一个多播地址 并定期向该地址发送
  • 从 Storm Bolt 将行插入 HBase

    我希望能够从分布式 非本地 Storm 拓扑将新条目写入 HBase 有一些 GitHub 项目提供以下任一功能 HBase 映射器 https github com ptgoetz storm hbase or 预制风暴螺栓 https
  • Hibernate vs JPA vs JDO - 各自的优缺点? [关闭]

    Closed 这个问题需要多问focused help closed questions 目前不接受答案 我熟悉 ORM 这个概念 几年前我什至在 NET 项目中使用过 nHibernate 然而 我还没有跟上 Java 中 ORM 的主题
  • 在 Amazon EMR 上使用 java 中的 hbase 时遇到问题

    因此 我尝试使用作为 MapReduce 步骤启动的自定义 jar 来查询 Amazon ec2 上的 hbase 集群 我的 jar 在地图函数内 我这样调用 Hbase public void map Text key BytesWri
  • Kafka不启动空白输出

    我正在努力安装 Kafka 和 Zookeeper 我已经运行了 Zookeeper 并且它当前正在运行 我将所有内容设置为 https dzone com articles running apache kafka on windows
  • 无法与 ZooKeeper 通信 - 更新被禁用

    我们正面临着 Zoo Keeper 的一个特殊问题 其中 ZK 突然失去了与 solr 云的连接并开始抛出异常 其中显示 无法与 ZooKeeper 对话 更新被禁用 我们的应用程序有 2 个 solr 集群 分别设置在 2 个不同的数据中
  • Zookeeper + Kafka - 无法创建数据目录

    我在单节点中使用zookeeper 3 4 8并尝试使用kafka 当我运行这个命令时 zookeeper server start sh usr local kafka 2 9 2 0 8 2 2 config zookeeper pro

随机推荐

  • 如何从sklearn管道变压器中提取特征名称?

    以供参考 Python 3 8 3 sklearn 1 0 2 我有一个scikit learn pipeline为我格式化一些数据 如下所述 我定义我的pipeline像这样 Pipeline 1 cat selector make co
  • Cassandra 性能随时间更新行

    我正在尝试确定 Cassandra 是否适合我的应用程序 因为未知我们将来需要扩展多少并且可能会迅速发生 我一直在观看 2013 年 C 峰会的各个部分 具体来说 Axel Liljencrantz Spotify 的后端开发人员 在这里说
  • 使用 ASP.NET Core 将 PDF 返回到浏览器

    我在 ASP Net core 中创建了 Web API 以返回 PDF 这是我的代码 public HttpResponseMessage Get int id var response new HttpResponseMessage S
  • 如何编写标准 CSV

    读起来非常简单标准 CSV文件 例如 val t spark read format csv option inferSchema true option header true load file home xyz user t csv
  • 如何加快 R 中的包/库加载时间?

    我有一个run stat r可以在命令行中运行的脚本 例如Rscript anova r在我的 ubuntu 服务器上 load package library ez run code 问题是加载时间ez打包需要2 3秒 R 是否可以预加载
  • 在 POSIX C 中获取自己的外部 IP 地址

    我希望获得自己的 IP 地址 以便将该信息发布到对等网络中 在 POSIX C 中我们有getaddrinfo NULL 但这似乎总是返回INADDR ANY or INADDR LOOPBACK 这对我来说没用 有什么建议么 问题之一是
  • 通过反射添加和删除事件处理程序 C#

    再会 我的目的是实现允许我们订阅和取消订阅对象事件的类 这是我班级的代码 public static class EventSubscriber public static void AddEventHandler EventInfo ev
  • 如何理解WinDBG SOS中!dumpheap的-min/-max选项

    文档说它用于限制输出对象的大小 但根据我的测试 这不是我所期望的 0 000 gt dumpheap mt 000007fee12406a8 max 400 min 399 Address MT Size 000000000d1dc1f8
  • 在 Scala 中,构造函数如何引用它正在创建的对象?

    我想在 Scala 中实现一个基于原型的系统 类型层次结构的根部是 ROOT 节点 它有一个引用自身的原型 以下代码演示了我正在尝试执行的操作 class Node val prototype Node private def this t
  • 解释回归模型中的交互作用

    我希望这是一个简单的问题 我有一个实验设计 测量两组的一些反应 比方说血压 对照组和受影响组 两组都接受三种治疗 t1 t2 t3 数据在任何意义上都不是配对的 这是一个示例数据 set seed 1 df lt data frame re
  • JavaScript 三元运算符速记

    我知道在 PHP 5 3 中不再使用这种冗余的三元运算符语法 startingNum startingNum startingNum 1 我们可以在适用的情况下为三元运算符使用简写语法 startingNum startingNum 1 我
  • VBA 将多个工作表导入工作簿

    我有以下代码 它允许我选择一个文件并从中导入 笔 选项卡 但是我想选择多个文件 我希望能够从多个工作簿中选择 笔 选项卡 每个工作簿在合并工作簿中都有自己的选项卡 您能帮忙看看这如何运作吗 我认为这可能需要使用 For Each 函数 但不
  • Python 中浮点数的余数[重复]

    这个问题在这里已经有答案了 我只是想给大家展示一下python中的运算结果 我无法解释 gt gt gt 1 0 1 0 0 0 OK gt gt gt 1 0 0 1 0 09999 gt gt gt 1 0 0 001 0 00999
  • 为什么 instanceof 对 babel-node 下的 Error 子类实例不起作用?

    我看到instanceof运算符不适用于以下实例Error子类 当运行在babel 节点OS X 上的版本 6 1 18 Node 版本 5 1 0 这是为什么 相同的代码在浏览器中运行良好 试试我的fiddle举个例子 以下代码输出tru
  • 如何使用 C# 将 JSON 发布到服务器?

    这是我正在使用的代码 create a request HttpWebRequest request HttpWebRequest WebRequest Create url request KeepAlive false request
  • SIGINT 处理和 getline

    我写了这个简单的程序 void sig ha int signum cout lt lt received SIGINT n int main string name struct sigaction newact old newact s
  • 将 C# Windows 窗体置于另一个窗口的中心

    我希望我的表单在相对于调用我的表单时处于活动状态的窗口的中心启动并打开 假设如果 Firefox 处于活动状态并且我显示表单 我希望我的表单显示在 Firefox 窗口的 中心 我认为实现此目的的一种方法是使用 user32 dll 中的
  • Xamarin Android 以编程方式下载并安装 apk

    所以我有一个验证更新的按钮 当我单击它时 我希望它下载并安装 apk 但我不断收到错误There was a problem parsing the package 正在下载 gt var imagePath Path Combine An
  • Grails 域类与其自身的关系

    我需要一种方法来让域类拥有许多自身 换句话说 存在父子关系 我正在处理的表有数据 然后有一个名为 parent id 的列 如果任何项目设置了parent id 则它是该元素的子元素 Grails 中有什么方法可以告诉 hasMany 查看
  • 错误 HBASE-ZOOKEEPER:连接太多

    我在我的应用程序中使用 Hbase Hadoop 组合 并使用 Data Nucleus 作为 ORM 当我尝试一次通过多个线程访问 Hbase 时 它 会抛出异常 Exception in thread Thread 26 javax j