_ Fix Data Issue

(cherry picked from commit 7d4d7ac)
open-metadata · Mar 6, 2024 · 031c0f6 · 031c0f6
1 parent 164c087
commit 031c0f6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...rvice/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/SearchIndexApp.java b/...rvice/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/SearchIndexApp.java
@@ -218,8 +218,8 @@ private void entitiesReIndex(JobExecutionContext jobExecutionContext) {
         try {
           resultList = paginatedEntitiesSource.readNext(null);
           if (!resultList.getData().isEmpty()) {
+            searchIndexSink.write(entityProcessor.process(resultList, contextData), contextData);
             if (!resultList.getErrors().isEmpty()) {
-              searchIndexSink.write(entityProcessor.process(resultList, contextData), contextData);
               throw new SearchIndexException(
                   new IndexingError()
                       .withErrorSource(READER)

diff --git a/...src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java b/...src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntitiesSource.java
@@ -109,7 +109,8 @@ private ResultList<? extends EntityInterface> read(String cursor) throws SearchI
       } else {
         submittedRecords = batchSize;
         String decodedCursor = RestUtil.decodeCursor(cursor);
-        this.cursor = RestUtil.encodeCursor(String.valueOf(Integer.parseInt(decodedCursor) + batchSize));
+        this.cursor =
+            RestUtil.encodeCursor(String.valueOf(Integer.parseInt(decodedCursor) + batchSize));
         updateStats(0, batchSize);
       }
       IndexingError indexingError =