From ea4e9bd9f329829b7db304eebdfb3b13bf6e2aba Mon Sep 17 00:00:00 2001 From: stuBirdFly <1065492934@qq.com> Date: Wed, 12 Feb 2025 10:48:12 +0800 Subject: [PATCH] put and delete throw execption --- src/main/java/com/alipay/oceanbase/hbase/OHTable.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java index 3851012c..e1ab500b 100644 --- a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java +++ b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java @@ -1266,6 +1266,7 @@ private void innerDelete(Delete delete) throws IOException { batch(Collections.singletonList(delete)); } catch (Exception e) { logger.error(LCD.convert("01-00004"), tableNameString, e); + throw e; } } @@ -1552,6 +1553,9 @@ public void flushCommits() throws IOException { } catch (Exception e) { logger.error(LCD.convert("01-00008"), tableNameString, null, autoFlush, writeBuffer.size(), e); + if (e instanceof IOException) { + throw (IOException) e; + } } finally { // mutate list so that it is empty for complete success, or contains // only failed records results are returned in the same order as the