Revert "Double deserialization"

This reverts commit ee8d752.
airbytehq · Feb 23, 2022 · 213f47a · 213f47a
1 parent ee8d752
commit 213f47a
Showing 1 changed file with 2 additions and 12 deletions.
diff --git a/...a/io/airbyte/integrations/destination/redshift/RedshiftCopyDestinationAcceptanceTest.java b/...a/io/airbyte/integrations/destination/redshift/RedshiftCopyDestinationAcceptanceTest.java
@@ -60,19 +60,9 @@ protected List<JsonNode> retrieveRecords(final TestDestinationEnv env,
                                            final String namespace,
                                            final JsonNode streamSchema)
       throws Exception {
-    final List<JsonNode> records = retrieveRecordsFromTable(namingResolver.getRawTableName(streamName), namespace);
-    return records
+    return retrieveRecordsFromTable(namingResolver.getRawTableName(streamName), namespace)
         .stream()
-        .map(j -> {
-          final String text = j.get(JavaBaseConstants.COLUMN_NAME_DATA).asText();
-          final JsonNode deserialized = Jsons.deserialize(text);
-          if (deserialized.isTextual()) {
-            final JsonNode d = Jsons.deserialize(deserialized.asText());
-            return d;
-          } else {
-            return deserialized;
-          }
-        })
+        .map(j -> Jsons.deserialize(j.get(JavaBaseConstants.COLUMN_NAME_DATA).asText()))
         .collect(Collectors.toList());
   }