Revert "Revert "Double deserialization""

This reverts commit 213f47a.

Author: girarda

airbyte-integrations/connectors/destination-redshift/src/test-integration/java/io/airbyte/integrations/destination/redshift/RedshiftCopyDestinationAcceptanceTest.java

@@ -60,9 +60,19 @@ protected List<JsonNode> retrieveRecords(final TestDestinationEnv env,
  final String namespace,
  final JsonNode streamSchema)
  throws Exception {
- return retrieveRecordsFromTable(namingResolver.getRawTableName(streamName), namespace)
+ final List<JsonNode> records = retrieveRecordsFromTable(namingResolver.getRawTableName(streamName), namespace);
+ return records
  .stream()
- .map(j -> Jsons.deserialize(j.get(JavaBaseConstants.COLUMN_NAME_DATA).asText()))
+ .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;
+ }
+ })
  .collect(Collectors.toList());
  }