yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-21 23:13:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix failine reindexing issue

Browse Source
This commit is contained in:
mohitdeuex 2023-06-22 14:26:46 +05:30
parent cb6e42941a
commit a9a830a93a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java
View File

@ -451,11 +451,11 @@ public abstract class EntityRepository<T extends EntityInterface> {
String beforeCursor; String beforeCursor;
String afterCursor = null; String afterCursor = null;
beforeCursor = after == null ? null : entities.get(0).getName(); beforeCursor = after == null ? null : JsonUtils.readValue(jsons.get(0), entityClass).getName();
if (entities.size() > limitParam) { // If extra result exists, then next page exists - return after cursor if (jsons.size() > limitParam) {
T lastReadEntity = JsonUtils.readValue(jsons.get(limitParam), entityClass); T lastReadEntity = JsonUtils.readValue(jsons.get(limitParam), entityClass);
entities.remove(limitParam); entities.remove(lastReadEntity.getId());
afterCursor = entities.get(limitParam - 1).getName(); afterCursor = JsonUtils.readValue(jsons.get(limitParam - 1), entityClass).getName();
errors.forEach((key, value) -> entities.remove(key)); 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 // Remove the Last Json Entry if present in error, since the read was actually just till limitParam , and if
// error // error