diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java index dd4fc0f6f8f..f57c99f9d8c 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java @@ -43,7 +43,6 @@ import static org.openmetadata.service.util.EntityUtil.objectMatch; import static org.openmetadata.service.util.EntityUtil.tagLabelMatch; import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.node.ObjectNode; import com.networknt.schema.JsonSchema; @@ -393,7 +392,7 @@ public abstract class EntityRepository { @Transaction public ResultList listAfterWithSkipFailure( UriInfo uriInfo, Fields fields, ListFilter filter, int limitParam, String after) throws IOException { - List errors = new ArrayList<>(); + List errors = new ArrayList<>(); int total = dao.listCount(filter); List entities = new ArrayList<>(); if (limitParam > 0) { @@ -406,7 +405,7 @@ public abstract class EntityRepository { entities.add(entity); } catch (Exception e) { LOG.error("Failed in Set Fields for Entity with Json : {}", json); - errors.add(JsonUtils.readValue(json, new TypeReference<>() {})); + errors.add(json); } } @@ -819,7 +818,7 @@ public abstract class EntityRepository { } public final ResultList getResultList( - List entities, List errors, String beforeCursor, String afterCursor, int total) { + List entities, List errors, String beforeCursor, String afterCursor, int total) { return new ResultList<>(entities, errors, beforeCursor, afterCursor, total); } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/util/ResultList.java b/openmetadata-service/src/main/java/org/openmetadata/service/util/ResultList.java index 56c181f123f..21d9c6235b8 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/util/ResultList.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/util/ResultList.java @@ -36,7 +36,7 @@ public class ResultList { private Paging paging; @JsonProperty("errors") - private List errors; + private List errors; public ResultList() {} @@ -89,7 +89,7 @@ public class ResultList { .withTotal(total); } - public ResultList(List data, List errors, String beforeCursor, String afterCursor, int total) { + public ResultList(List data, List errors, String beforeCursor, String afterCursor, int total) { this.data = data; this.errors = errors; paging = @@ -110,12 +110,12 @@ public class ResultList { } @JsonProperty("errors") - public List getErrors() { + public List getErrors() { return errors; } @JsonProperty("errors") - public void setErrors(List data) { + public void setErrors(List data) { this.errors = data; } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java b/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java index 1632461dbad..75648414fe4 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java @@ -71,9 +71,7 @@ public class PaginatedEntitiesSource implements Source 0) { result .getErrors() - .forEach( - (error) -> - LOG.error("[PaginatedEntitiesSource] Failed in getting Record, RECORD: {}", error.toString())); + .forEach((error) -> LOG.error("[PaginatedEntitiesSource] Failed in getting Record, RECORD: {}", error)); } LOG.debug(