From dc251c70bb6ec58275b15821eef51348e9f9bd09 Mon Sep 17 00:00:00 2001 From: JackShi148 Date: Wed, 2 Apr 2025 14:53:46 +0800 Subject: [PATCH] set synchronized to bufferedMutator close to match original hbase --- .../com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java b/src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java index d6e63d40..52d8624b 100644 --- a/src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java +++ b/src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java @@ -312,7 +312,7 @@ public void disableWriteBufferPeriodicFlush() { } @Override - public void close() throws IOException { + public synchronized void close() throws IOException { if (closed) { return; }