如何在Pyspark中设置HBaseConfiguration?错误zookeeper.ClientCnxn

2024-05-05 16:34:52 发布

您现在位置:Python中文网/ 问答频道 /正文

仅在Hbase中,当我从Hbase访问数据时返回此错误

ERROR zookeeper.ClientCnxn: Error while calling watcher
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@aa2502c rejected from java.util.concurrent.ThreadPoolExecutor@2cf54ce9[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 1]

在Scala中,我看到了以下选项:

var hConf = HBaseConfiguration.create(conf)
hConf.set("hbase.zookeeper.quorum", ""brtlvlts1752co.bigdata.redecorp.br,brtlvlts1751co.bigdata.redecorp.br,brtlvlts1753co.bigdata.redecorp.br");
hConf.setInt("hbase.zookeeper.property.clientPort", 2181)
hConf.set("zookeeper.znode.parent", "/hbase")   

你在Pypark是怎么做到的

谢谢


Tags: 数据br错误utilerrorjavazookeeperconcurrent