patch bufferedMutator deals exception

Author: JackShi148

src/main/java/com/alipay/oceanbase/hbase/util/OHBufferedMutatorImpl.java

@@ -275,15 +275,11 @@ private void execute(boolean flushAll) throws IOException {
             // if commit all successfully, clean execBuffer
             execBuffer.clear();
         } catch (Exception ex) {
-            LOGGER.error(LCD.convert("01-00026"), ex);
-            if (ex.getCause() instanceof RetriesExhaustedWithDetailsException) {
-                LOGGER.error(tableName + ": One or more of the operations have failed after retries.");
-                RetriesExhaustedWithDetailsException retryException = (RetriesExhaustedWithDetailsException) ex.getCause();
-                // recollect failed mutations
-                execBuffer.clear();
-                for (int i = 0; i < retryException.getNumExceptions(); ++i) {
-                    execBuffer.add((Mutation) retryException.getRow(i));
-                }
+            // do not recollect error operations, notify outside
+            LOGGER.error("error happens, table name: {}", tableName.getNameAsString(), ex);
+            if (ex instanceof RetriesExhaustedWithDetailsException) {
+                LOGGER.error("TableName: {}, One or more of the operations have failed after retries.", tableName.getNameAsString(), ex);
+                RetriesExhaustedWithDetailsException retryException = (RetriesExhaustedWithDetailsException) ex;
                 if (listener != null) {
                     listener.onException(retryException, this);
                 } else {
@@ -293,13 +289,6 @@ private void execute(boolean flushAll) throws IOException {
                 LOGGER.error("Errors unrelated to operations occur during mutation operation", ex);
                 throw ex;
             }
-        } finally {
-            for (Mutation mutation : execBuffer) {
-                long size = mutation.heapSize();
-                currentAsyncBufferSize.addAndGet(size);
-                asyncWriteBuffer.add(mutation);
-                undealtMutationCount.incrementAndGet();
-            }
         }
     }