Remove wrapping actual exception in IOException

data-integrations · Nov 15, 2024 · 550f350 · 550f350
1 parent efeef28
commit 550f350
Showing 1 changed file with 5 additions and 9 deletions.
diff --git a/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQueryOutputFormat.java b/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQueryOutputFormat.java
@@ -192,9 +192,8 @@ public void checkOutputSpecs(JobContext job) throws FileAlreadyExistsException,
     } catch (GeneralSecurityException gse) {
       String errorMessage = "Failed to create BigQuery client";
       throw ErrorUtils.getProgramFailureException(
-        new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), errorMessage,
-        String.format(errorMessageFormat, ErrorPhase.VALIDATING_OUTPUT_SPECS, errorMessage), ErrorType.SYSTEM, true,
-        new IOException(errorMessage, gse));
+        new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), errorMessage, String.format(errorMessageFormat,
+          ErrorPhase.VALIDATING_OUTPUT_SPECS, errorMessage), ErrorType.SYSTEM, true, gse);
     }
 
     // Let delegate process its checks.
@@ -228,8 +227,7 @@ public static class BigQueryOutputCommitter extends ForwardingBigQueryFileOutput
         String errorMessage = "Failed to create BigQuery client";
         throw ErrorUtils.getProgramFailureException(
           new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), errorMessage,
-          String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true,
-          new IOException(errorMessage, e));
+          String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true, e);
       }
     }
 
@@ -290,8 +288,7 @@ public void commitJob(JobContext jobContext) throws IOException {
         String errorMessage = "Failed to import GCS into BigQuery.";
         throw ErrorUtils.getProgramFailureException(
           new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), errorMessage,
-          String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true,
-          new IOException(errorMessage, e));
+          String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true, e);
       }
 
       cleanup(jobContext);
@@ -658,8 +655,7 @@ private static Optional<TableSchema> getTableSchema(Configuration conf) throws I
             BigQueryConfiguration.OUTPUT_TABLE_SCHEMA.getKey());
           throw ErrorUtils.getProgramFailureException(
             new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), errorMessage,
-            String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true,
-            new IOException(errorMessage, e));
+            String.format(errorMessageFormat, ErrorPhase.COMMITTING, errorMessage), ErrorType.SYSTEM, true, e);
         }
       }
       return Optional.empty();