Skip to content

Commit 074d59f

Browse files
authored
Merge pull request #152 from stuBirdFly/client_1.3
put and delete throw execption
2 parents 160ad8c + ea4e9bd commit 074d59f

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
@@ -1266,6 +1266,7 @@ private void innerDelete(Delete delete) throws IOException {
12661266
batch(Collections.singletonList(delete));
12671267
} catch (Exception e) {
12681268
logger.error(LCD.convert("01-00004"), tableNameString, e);
1269+
throw e;
12691270
}
12701271
}
12711272

@@ -1552,6 +1553,9 @@ public void flushCommits() throws IOException {
15521553
} catch (Exception e) {
15531554
logger.error(LCD.convert("01-00008"), tableNameString, null, autoFlush,
15541555
writeBuffer.size(), e);
1556+
if (e instanceof IOException) {
1557+
throw (IOException) e;
1558+
}
15551559
} finally {
15561560
// mutate list so that it is empty for complete success, or contains
15571561
// only failed records results are returned in the same order as the

0 commit comments

Comments
 (0)