hbase 相关问题

HBase是Hadoop数据库(columnar)。当您需要对大数据进行随机,实时读/写访问时,请使用它。该项目的目标是托管非常大的表 - 数十亿行X百万列 - 在商品硬件集群上。

HBase Master正在显示过渡状态

在HBase中,Master处于过渡状态,并且发现了过渡中的许多区域。如何解决它,可能是什么原因?我们尝试分配区域并将区域状态设置为FAILED_OPEN状态。

回答 2 投票 -2

HBase Zookeeper AUTH_FAILED-找不到任何Kerberos tgt

环境HBase 1.5 Hadoop 2.9.2 Zookeeper 3.5.6错误在将Zookeeper配置为使用Kerberos并在hbase -...中配置HBase jaas.conf登录配置...后收到以下错误。

回答 1 投票 0

[尝试从Spark查询HBase上的数据时出现NoSuchMethodError

我正在尝试使用SparkSQL / DataFrames查询加载到HBase表中的数据。我的集群基于Cloudera CDH 6.2.0(Spark版本2.4.0和HBase版本2.1.0)。遵循本指南,我...

回答 1 投票 1

HBase批量加载挂起,剩余2个文件

我正在从Spark批量加载HBase,并通过HFileOutputFormat2写入HFiles。一切都好,直到大容量加载似乎挂在最后的几个文件上INFO org.apache.hadoop.hbase.tool ....

回答 1 投票 0

从Python和happybase / Thrift连接到Hbase

我已经安装了Cloudera Manager Express 5.9.0,并安装了HBase,并且Thrift服务器在VirtualBox vm中的CentOS 7.3的端口9090上运行。请帮助弄清楚为什么我无法成功...

回答 3 投票 0

HBase Java代码中的行数

我正在尝试使用Java //获得具有数百万条记录的Hbase表中的行数// // ResultScanner Scanner = table.getScanner(s ;; int count = 0; ...

回答 1 投票 -1

Hbse:如何使用两个不同的标准进行行键过滤

在Hbase表中,行键如下所示:(特定ID)_(带有时间戳的日期)我想用两种情况过滤表中的条目:具有特定ID-可以通过...

回答 1 投票 0

在Java中处理hbase连接和表的最佳实践?

我正在使用hbase-client 1.2.3,我在Connection.getTable()方法中看到一条注释:检索用于访问表的Table实现。返回的表不是线程安全的,新的...

回答 1 投票 7

将Windows 10中的Hbase独立连接到Java应用程序中的Virtualbox VM中

我正在尝试使用Windows 10中运行的Java应用程序在Ubuntu VM中连接(并创建新表)到HBase中。我确定HBase也可以正常工作,并且Java代码也可以正常工作,因为如果我直接将其发送到。 ..

回答 1 投票 0

在镶木地板中添加新列并导入到HBase中

我是否应该做一些特别的事情来通知HBase,新的列已添加到镶木地板中(模式已更改)?或者就像MongoDB一样,我可以直接在HBase中插入新的实木复合地板(使用...

回答 1 投票 0

Spark-为具有多个列的一个rowKey创建HFile

JavaRDD hbaseFile = jsc.textFile(HDFS_MASTER + HBASE_FILE); JavaPairRDD putJavaRDD = hbaseFile.mapToPair(line-> convertToKVCol1(line,COLUMN_AGE)...

回答 2 投票 0

ZKTestingUtility的Hbase测试实用程序依赖性问题

[尝试在Scala 2.12.8中使用HbaseTestingUtility,但我找不到类org.apache.hadoop.hbase.HBaseZKTestingUtility-继续存根。新的HBaseTestingUtility()sbt导入val ...

回答 1 投票 1

Kafka Connect Hbase接收器

我正在尝试为kafka(https://github.com/mravi/kafka-connect-hbase)部署hbase接收器连接器。因此,我按照步骤1和2下载并配置了Hbase和Confluent平台。然后它说,...

回答 2 投票 1

用于Hbase的Kafka Connect

我正在尝试为kafka(https://github.com/mravi/kafka-connect-hbase)部署hbase接收器连接器。因此,我按照步骤1和2下载并配置了Hbase和Confluent。然后说,复制...

回答 1 投票 0

错误:类HTable中的构造函数HTable无法应用于给定类型

我正在使用hadoop hbase。我只是编写了一个简单的程序来插入数据库。当我运行程序时,出现以下错误:InsertData.java:31:错误:类中的构造函数HTable ...

回答 1 投票 1

HBase AsyncProcess警告

我的HBase Get / Put有时会花费很长时间。当我检查日志时,我看到下面的行打印了很长时间。有谁知道为什么会这样吗? 18/09/25 10:04:43 INFO ...

回答 1 投票 5

使用AWS EMR更新S3数据

我将实木复合地板文件放入S3存储桶中,并使用Athena对其进行查询。我想对数据进行行级更改,但我试图避免拉低千兆字节的镶木地板数据,进行修改,以及...

回答 1 投票 0

Phoenix-> csv->封装的令牌和定界符之间的无效字符

我需要将CSV转储文件上传到Phoenix数据库,而没有任何特殊字符的文件被加载而没有问题./psql.py -t TTT本地主机/home/isaev/output.csv -d';'但是...

回答 1 投票 0

如何使用pyspark从HBase表中读取数据?

我创建了一个名为emp的虚拟HBase表,该表具有一条记录。以下是数据。 > hbase(main):005:0>放入'emp','1','personal data:name','raju'0行>在0.1540秒内> hbase(...

回答 1 投票 1

[通过ResultScanner对象调用next()时的java.io.InterruptedIOException

我正在尝试读取和解析ResultScanner扫描器,但是在调用next()时出现异常。这是我的代码的相关部分:var scan:Scan = new Scan()val keyRegEx:...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.