From 76711348097aa34a47b3ca89ab2e9cd2991b08e3 Mon Sep 17 00:00:00 2001 From: benmoriceau Date: Mon, 2 Oct 2023 17:09:42 -0700 Subject: [PATCH] Remove validation --- .../cdk/integrations/destination_async/AsyncStreamConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java b/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java index 2c15638814a7..e8e16a0f83aa 100644 --- a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java +++ b/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java @@ -116,7 +116,7 @@ public void accept(final String messageString, final Integer sizeInBytes) throws //if (Strings.isNullOrEmpty(message.getRecord().getNamespace())) { message.getRecord().setNamespace(defaultNamespace); //} - validateRecord(message); + // validateRecord(message); } else if (Type.STATE.equals(message.getType())) { lastState = message; }