From 06e47bf80f26e04abc77acaec5b153f46ea7fb94 Mon Sep 17 00:00:00 2001
From: Apache9 <palomino219@gmail.com>
Date: Fri, 14 Jun 2019 20:51:11 +0800
Subject: [PATCH] [hbase10] Use Admin.tableExists instead of
Table.getTableDescriptor to test whether the table exists, as the latter has
been removed on master branch (#1315)
---
hbase10/src/main/java/com/yahoo/ycsb/db/HBaseClient10.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/hbase10/src/main/java/com/yahoo/ycsb/db/HBaseClient10.java b/hbase10/src/main/java/com/yahoo/ycsb/db/HBaseClient10.java
index d7088597..7f529103 100644
--- a/hbase10/src/main/java/com/yahoo/ycsb/db/HBaseClient10.java
+++ b/hbase10/src/main/java/com/yahoo/ycsb/db/HBaseClient10.java
@@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.BufferedMutator;
import org.apache.hadoop.hbase.client.BufferedMutatorParams;
import org.apache.hadoop.hbase.client.Connection;
@@ -152,7 +153,11 @@ public class HBaseClient10 extends com.yahoo.ycsb.DB {
// will not propagate this error upstream once the workload
// starts.
final TableName tName = TableName.valueOf(table);
- connection.getTable(tName).getTableDescriptor();
+ try (Admin admin = connection.getAdmin()) {
+ if (!admin.tableExists(tName)) {
+ throw new DBException("Table " + tName + " does not exists");
+ }
+ }
}
}
} catch (java.io.IOException e) {
--
GitLab