@@ -647,7 +647,7 @@ public void batch(final List<? extends Row> actions, final Object[] results) thr
647
647
try {
648
648
compatOldServerBatch (actions , results , batchError );
649
649
} catch (Exception e ) {
650
- throw new IOException (e );
650
+ throw new IOException (tableNameString + " table occurred unexpected error." , e );
651
651
}
652
652
} else {
653
653
String realTableName = getTargetTableName (actions );
@@ -657,7 +657,7 @@ public void batch(final List<? extends Row> actions, final Object[] results) thr
657
657
try {
658
658
tmpResults = batch .execute ();
659
659
} catch (Exception e ) {
660
- throw new IOException (e );
660
+ throw new IOException (tableNameString + " table occurred unexpected error." , e );
661
661
}
662
662
int index = 0 ;
663
663
for (int i = 0 ; i != actions .size (); ++i ) {
@@ -1266,7 +1266,6 @@ private void innerDelete(Delete delete) throws IOException {
1266
1266
batch (Collections .singletonList (delete ));
1267
1267
} catch (Exception e ) {
1268
1268
logger .error (LCD .convert ("01-00004" ), tableNameString , e );
1269
- throw new IOException ("delete table " + tableNameString + " error." , e );
1270
1269
}
1271
1270
}
1272
1271
@@ -1553,9 +1552,6 @@ public void flushCommits() throws IOException {
1553
1552
} catch (Exception e ) {
1554
1553
logger .error (LCD .convert ("01-00008" ), tableNameString , null , autoFlush ,
1555
1554
writeBuffer .size (), e );
1556
- throw new IOException ("put table " + tableNameString + " error codes " + null
1557
- + "auto flush " + autoFlush + " current buffer size "
1558
- + writeBuffer .size (), e );
1559
1555
} finally {
1560
1556
// mutate list so that it is empty for complete success, or contains
1561
1557
// only failed records results are returned in the same order as the
0 commit comments