optimize HBaseAsyncWriteExecutor

netease-im · Nov 2, 2023 · c3eb5e7 · c3eb5e7
1 parent 46f7ec3
commit c3eb5e7
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/...ase/src/main/java/com/netease/nim/camellia/redis/proxy/hbase/HBaseAsyncWriteExecutor.java b/...ase/src/main/java/com/netease/nim/camellia/redis/proxy/hbase/HBaseAsyncWriteExecutor.java
@@ -129,15 +129,17 @@ public void run() {
                             flushDelete(deleteBuffer);
                         }
                     }
-                } catch (Exception e) {
+                } catch (Throwable e) {
                     logger.error("hbase async write error", e);
                 }
             }
         }
 
         private void flushPuts(List<Put> putBuffer) {
+            if (putBuffer.isEmpty()) {
+                return;
+            }
             int size = putBuffer.size();
-            if (size <= 0) return;
             hBaseTemplate.put(hbaseTableName(), putBuffer);
             putBuffer.clear();
             if (logger.isDebugEnabled()) {
@@ -146,8 +148,10 @@ private void flushPuts(List<Put> putBuffer) {
         }
 
         private void flushDelete(List<Delete> deleteBuffer) {
+            if (deleteBuffer.isEmpty()) {
+                return;
+            }
             int size = deleteBuffer.size();
-            if (size <= 0) return;
             hBaseTemplate.delete(hbaseTableName(), deleteBuffer);
             deleteBuffer.clear();
             if (logger.isDebugEnabled()) {