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