@@ -715,7 +715,7 @@ public void batch(final List<? extends Row> actions, final Object[] results) thr
715
715
try {
716
716
compatOldServerBatch (actions , results , batchError );
717
717
} catch (Exception e ) {
718
- throw new IOException (e );
718
+ throw new IOException (tableNameString + " table occurred unexpected error." , e );
719
719
}
720
720
} else {
721
721
String realTableName = getTargetTableName (actions );
@@ -725,7 +725,7 @@ public void batch(final List<? extends Row> actions, final Object[] results) thr
725
725
try {
726
726
tmpResults = batch .execute ();
727
727
} catch (Exception e ) {
728
- throw new IOException (e );
728
+ throw new IOException (tableNameString + " table occurred unexpected error." , e );
729
729
}
730
730
int index = 0 ;
731
731
for (int i = 0 ; i != actions .size (); ++i ) {
@@ -1320,7 +1320,6 @@ private void innerDelete(Delete delete) throws IOException {
1320
1320
batch (actions , results );
1321
1321
} catch (Exception e ) {
1322
1322
logger .error (LCD .convert ("01-00004" ), tableNameString , e );
1323
- throw new IOException ("delete table " + tableNameString + " error." , e );
1324
1323
}
1325
1324
}
1326
1325
@@ -1607,9 +1606,6 @@ public void flushCommits() throws IOException {
1607
1606
} catch (Exception e ) {
1608
1607
logger .error (LCD .convert ("01-00008" ), tableNameString , null , autoFlush ,
1609
1608
writeBuffer .size (), e );
1610
- throw new IOException ("put table " + tableNameString + " error codes " + null
1611
- + "auto flush " + autoFlush + " current buffer size "
1612
- + writeBuffer .size (), e );
1613
1609
} finally {
1614
1610
// mutate list so that it is empty for complete success, or contains
1615
1611
// only failed records results are returned in the same order as the
0 commit comments