diff --git a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java index 98f27934ed43..4d9de3ff7528 100644 --- a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java +++ b/airbyte-integrations/connectors/destination-bigquery/src/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