Skip to content

Commit fe41a84

Browse files
committed
put and delete throw execption
1 parent f5983a7 commit fe41a84

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1320,6 +1320,7 @@ private void innerDelete(Delete delete) throws IOException {
13201320
batch(actions, results);
13211321
} catch (Exception e) {
13221322
logger.error(LCD.convert("01-00004"), tableNameString, e);
1323+
throw e;
13231324
}
13241325
}
13251326

@@ -1606,6 +1607,9 @@ public void flushCommits() throws IOException {
16061607
} catch (Exception e) {
16071608
logger.error(LCD.convert("01-00008"), tableNameString, null, autoFlush,
16081609
writeBuffer.size(), e);
1610+
if (e instanceof IOException) {
1611+
throw (IOException) e;
1612+
}
16091613
} finally {
16101614
// mutate list so that it is empty for complete success, or contains
16111615
// only failed records results are returned in the same order as the

0 commit comments

Comments
 (0)