Skip to content

Commit 2ed38ba

Browse files
JackShi148stuBirdFlymiyuan-ljr
authored
Fix namespace connect error (#136)
* add DepentdentFilter and SingleColumnValueExcludeFilter * add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases * hbase support batch (#84) * Add DeleteFamilyVersion function and corresponding test cases (#85) * add DepentdentFilter and SingleColumnValueExcludeFilter * add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases * add single cf timerange setting in Get * single cf setColumnFamilyTimeRange in Get and Scan * optimize code * add DeleteFamilyVersion and test cases * add DeleteFamilyVersion; optimize test cases * add DeleteFamilyVersion test case and pass * format code * delete useless self-defined table * remove DeleteFamilyVersion file and move all cases to MultiColumnFamilyTest * hbase support batchCallBack (#86) * adjust bufferdMutatorImpl 1.x to new batch * bufferedMutator do not retry, batch retry in table client * hbase support batch (#84) * add rpcTimeout and operationTimetout setting in bufferedMutator * fix test * Add DeleteFamilyVersion function and corresponding test cases (#85) * add DepentdentFilter and SingleColumnValueExcludeFilter * add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases * add single cf timerange setting in Get * single cf setColumnFamilyTimeRange in Get and Scan * optimize code * add DeleteFamilyVersion and test cases * add DeleteFamilyVersion; optimize test cases * add DeleteFamilyVersion test case and pass * format code * delete useless self-defined table * hbase support batchCallBack (#86) * fix test * fix test * init hbase_2.0 bufferedMutatorImpl * pass single bufferedMutator test * remove useless comments * format code * add inherited interface in bufferedMutator; fix concurrent bug in bufferedMuator execution * fix typo * fix exception erros message * update time to wait pool to shutdown * add import * pass test cases after merge * keep the same test case and sql with 1.x version * fix connection re-used between files because of incorrect close * close all obTableClient when closing OHTable and clear cache --------- Co-authored-by: stuBirdFly <84010733+stuBirdFly@users.noreply.github.com> Co-authored-by: miyuan-ljr <miyuan.ljr@antgroup.com>
1 parent 5ab7143 commit 2ed38ba

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1464,6 +1464,7 @@ public void close() throws IOException {
14641464
if (cleanupPoolOnClose) {
14651465
executePool.shutdown();
14661466
}
1467+
ObTableClientManager.clear();
14671468
}
14681469

14691470
@Override

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,18 @@ public static ObTableClient getOrCreateObTableClient(ObTableClientKey obTableCli
126126
return OB_TABLE_CLIENT_INSTANCE.get(obTableClientKey);
127127
}
128128

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

0 commit comments

Comments
 (0)