[HUDI-5061] bulk insert operation don't throw other exception except IOE Exception (apache#7001)

Co-authored-by: liufangqi.chenfeng <[email protected]>

Author: 2 people

hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketBulkInsertWriterHelper.java

@@ -69,8 +69,9 @@ public void write(RowData tuple) throws IOException {
       }
       handle.write(recordKey, partitionPath, record);
     } catch (Throwable throwable) {
-      LOG.error("Global error thrown while trying to write records in HoodieRowDataCreateHandle", throwable);
-      throw throwable;
+      IOException ioException = new IOException("Exception happened when bulk insert.", throwable);
+      LOG.error("Global error thrown while trying to write records in HoodieRowDataCreateHandle", ioException);
+      throw ioException;
     }
   }
 

hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java

@@ -113,8 +113,9 @@ public void write(RowData record) throws IOException {
       }
       handle.write(recordKey, partitionPath, record);
     } catch (Throwable t) {
-      LOG.error("Global error thrown while trying to write records in HoodieRowCreateHandle ", t);
-      throw t;
+      IOException ioException = new IOException("Exception happened when bulk insert.", t);
+      LOG.error("Global error thrown while trying to write records in HoodieRowCreateHandle ", ioException);
+      throw new IOException(ioException);
     }
   }