From a9a830a93a48e4f9e2ded656ab0d43a5fef84400 Mon Sep 17 00:00:00 2001 From: mohitdeuex Date: Thu, 22 Jun 2023 14:26:46 +0530 Subject: [PATCH] Fix failine reindexing issue --- .../org/openmetadata/service/jdbi3/EntityRepository.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 b1808aac190..61534369f34 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 @@ -451,11 +451,11 @@ public abstract class EntityRepository { String beforeCursor; String afterCursor = null; - beforeCursor = after == null ? null : entities.get(0).getName(); - if (entities.size() > limitParam) { // If extra result exists, then next page exists - return after cursor + beforeCursor = after == null ? null : JsonUtils.readValue(jsons.get(0), entityClass).getName(); + if (jsons.size() > limitParam) { T lastReadEntity = JsonUtils.readValue(jsons.get(limitParam), entityClass); - entities.remove(limitParam); - afterCursor = entities.get(limitParam - 1).getName(); + entities.remove(lastReadEntity.getId()); + afterCursor = JsonUtils.readValue(jsons.get(limitParam - 1), entityClass).getName(); errors.forEach((key, value) -> entities.remove(key)); // Remove the Last Json Entry if present in error, since the read was actually just till limitParam , and if // error