diff --git a/airbyte-integrations/connectors/source-bigquery/src/test-integration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java b/airbyte-integrations/connectors/source-bigquery/src/test-integration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java index 9068da62dd09..66160ca3cdab 100644 --- a/airbyte-integrations/connectors/source-bigquery/src/test-integration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java +++ b/airbyte-integrations/connectors/source-bigquery/src/test-integration/java/io/airbyte/integrations/source/bigquery/BigQuerySourceComprehensiveTest.java @@ -343,6 +343,18 @@ protected String getNameSpace() { return dataset.getDatasetId().getDataset(); } + @Override + protected String getValueFromJsonNode(JsonNode jsonNode) { + if (jsonNode != null) { + String nodeText = jsonNode.asText(); + String nodeString = jsonNode.toString(); + String value = (nodeText != null && !nodeText.equals("") ? nodeText : nodeString); + value = (value != null && value.equals("null") ? null : value); + return value; + } + return null; + } + @AfterAll public void cleanTestInstance() { database.getRealDatabase().cleanDataSet(getNameSpace());