Questions tagged [hbase-client]
27 questions
10
votes
4 answers
hbase-client 2.0.x error
I'm trying to connect to a remote hbase server using the hbase-client java API.
So far i've been able to make it work with the hbase-client version 1.3.1. But to resolve a dependency conflict with gRPC i'm trying to make use of the hbase-client…
Nowa Concordia
- 709
- 6
- 23
8
votes
1 answer
A steady number of HBase requests are taking almost exactly 5000ms to complete (successfully) despite lower timeouts. No idea why
My client is using org.apache.hbase:hbase-client:2.1.0" and the server is running 1.2.0-cdh5.11.1 (1.2.0-cdh5.11.0 in an alternative test cluster).
My client is very simple, it instantiates a Connection class at startup (this class - as recommended…
encee
- 4,544
- 4
- 33
- 35
6
votes
1 answer
HBase BufferedMutator vs PutList performance
I recently came across BufferedMutator class of HBase which can be used for batch inserts and deletes.
I was previously using a List to put data as hTable.put(putList) to do the same.
Benchmarking my code didn't seem to show much difference too,…
Parijat Purohit
- 921
- 6
- 16
3
votes
1 answer
HBase client - server’s version compatibility
I wonder how can I know if my HBase client’s jar fit to my HBase server’s version. Is there any place where it is specified which HBase versions are supported with an HBase client jar?
In my case I want to use the newest HBase client jar (2.4.5)…
user7551211
- 649
- 1
- 6
- 25
2
votes
1 answer
HBase client - java.lang.ClassNotFoundException: org.apache.hadoop.crypto.key.KeyProviderTokenIssuer
I'm trying to run a legacy project that connects to HBase.
It has (among other dependencies):
org.apache.hbase
hbase-client
1.2.0-cdh5.7.2
…
riorio
- 6,500
- 7
- 47
- 100
2
votes
0 answers
ConnectionClosedException when reading data from HBase running inside docker
I have HBase running in docker. I can connect using the shaded client and perform getClusterMetrics() and get the table descriptor.
However, when I try reading data from the table using either get or scan, I get this exception
543935…
nb.alexiev
- 379
- 3
- 10
2
votes
1 answer
Hbase Table.batch takes 300 secs to insert 800,000 entries into table
I am reading a json file of size 30 mb, process to create column family and key values. Then create Put object, insert rowkey and values into it. Create list of such put objects and call Table.batch() and pass this list. I am calling this when my…
AnswerSeeker
- 203
- 4
- 16
1
vote
0 answers
Getting DEADLINE_EXCEEDED when scanning bigtable using Hbase client
I am getting the following error when scanning a large number of rows(~1 million) based on a prefix
Status{code=DEADLINE_EXCEEDED, description=deadline exceeded:
-646391190127 ns from now, cause=null}
Could someone suggest what are the…
Nithin
- 415
- 4
- 14
1
vote
1 answer
Bigtable scan of 130 million rows throws java.lang.IllegalStateException: Not started
Trying to scan Bigtable which has 130 million rows using the HBase java client. After a few hours into the scan, it throws:
INFO com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation - Retrying failed call. Failure #1, got:…
Srini
- 53
- 8
1
vote
1 answer
Prefix search on a specific column in hbase not working in java
There is a column lets say Countries in hbase and I want to prefix on this column(this is not a row key) then I will use ColumnPrefixFilter and do something like this
ColumnPrefixFilter columnPrefixFilter = new…
agrawal1084
- 129
- 2
- 11
1
vote
1 answer
Cast to long datatype - BigQuery
BigQuery and SQL noob here. I was going through possible data types big query supports here. I have a column in bigtable which is of type bytes and its original data type is scala Long. This was converted to bytes and stored in bigtable from my…
Karan Ashar
- 1,392
- 1
- 10
- 23
1
vote
1 answer
Can't Connect to BigTable using Connection Factory
I am using a custom code to load HFiles directly into BigTable using the following API's
LoadIncrementalHFiles loader = new LoadIncrementalHFiles(conf);
loader.doBulkLoad(new Path(inputPath), admin, table, regionLocator);
while using…
Aman Vaishya
- 179
- 12
1
vote
1 answer
Too many hconnections of my hbase client
In order to get max throughoutput, I use batch puts and increments to put data into hbase,
code sample:
Configuration configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum",…
jamee
- 553
- 1
- 5
- 25
1
vote
2 answers
Can't connect to Bigtable to scan HTable data due to hardcoded managed=true in hbase client jars
I'm working on a custom load function to load data from Bigtable using Pig on Dataproc. I compile my java code using the following list of jar files I grabbed from Dataproc. When I run the following Pig script, it fails when it tries to establish a…
EduBoom
- 147
- 1
- 8
1
vote
1 answer
Version Compatibility in Spark and Hbase-client
I am trying to write a Spark batch job. I want to package it to a jar and use it with spark submit. My program works perfectly in spark-shell, however I get the following error when I try to run it with spark submit:
Exception in thread "main"…
Saygın Doğu
- 305
- 1
- 4
- 17