Not important

airbytehq · Oct 2, 2023 · e396025 · e396025
1 parent 89077b0
commit e396025
Showing 1 changed file with 2 additions and 16 deletions.
diff --git a/...rc/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java b/...rc/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java
@@ -37,26 +37,12 @@ public void write(UUID id, AirbyteRecordMessage recordMessage) {
 
   @Override
   public void write(JsonNode formattedData) throws IOException {
-
-    try {
-      writeChannel.write(ByteBuffer.wrap((Jsons.serialize(formattedData) + "\n").getBytes(Charsets.UTF_8)));
-    } catch (Exception e) {
-      LOGGER.error("BigQueryTableWriter");
-      LOGGER.error(formattedData.toPrettyString());
-      throw e;
-    }
+    writeChannel.write(ByteBuffer.wrap((Jsons.serialize(formattedData) + "\n").getBytes(Charsets.UTF_8)));
   }
 
   @Override
   public void write(String formattedData) throws IOException {
-
-    try {
-      writeChannel.write(ByteBuffer.wrap((formattedData + "\n").getBytes(Charsets.UTF_8)));
-    } catch (Exception e) {
-      LOGGER.error("BigQueryTableWriter", e);
-      LOGGER.error(formattedData);
-      throw e;
-    }
+    writeChannel.write(ByteBuffer.wrap((formattedData + "\n").getBytes(Charsets.UTF_8)));
   }
 
   @Override