Skip to content

Commit 7a32095

Browse files
authored
[Fix] hbase cleint close report error in multi-thread environment (#139)
1 parent 145a3e3 commit 7a32095

File tree

2 files changed

+0
-12
lines changed

2 files changed

+0
-12
lines changed

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1543,7 +1543,6 @@ public void close() throws IOException {
15431543
if (cleanupPoolOnClose) {
15441544
executePool.shutdown();
15451545
}
1546-
ObTableClientManager.clear();
15471546
}
15481547

15491548
@Override

src/main/java/com/alipay/oceanbase/hbase/util/ObTableClientManager.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -128,17 +128,6 @@ public static ObTableClient getOrCreateObTableClient(ObTableClientKey obTableCli
128128
return OB_TABLE_CLIENT_INSTANCE.get(obTableClientKey);
129129
}
130130

131-
public static void clear() throws IOException {
132-
try {
133-
for (Map.Entry<ObTableClientKey, ObTableClient> pair : OB_TABLE_CLIENT_INSTANCE.entrySet()) {
134-
pair.getValue().close();
135-
}
136-
} catch (Exception e) {
137-
throw new IOException("fail to close tableClient" , e);
138-
}
139-
OB_TABLE_CLIENT_INSTANCE.clear();
140-
}
141-
142131
public static class ObTableClientKey {
143132
private String paramUrl;
144133
private String fullUserName;

0 commit comments

Comments
 (0)