fix(search): restore live settings on per-entity promote path

openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/distributed/DistributedSearchIndexExecutor.java

@@ -1102,6 +1102,17 @@ private void initializeEntityTracker(UUID jobId, boolean recreateIndex) {
     // Set up per-entity promotion callback if recreating indices
     if (recreateIndex && recreateContext != null) {
       this.recreateIndexHandler = Entity.getSearchRepository().createReindexHandler();
+      // Wire jobData into the handler so applyLiveServingSettings (in
+      // DefaultRecreateHandler.promoteEntityIndex) can resolve the configured live + bulk
+      // index settings. Without this, jobData is null on the handler instance the per-entity
+      // callback uses, buildRevertJson returns null, and the bulk-build overrides
+      // (refresh_interval=-1, replicas=0, async translog) silently become the live settings.
+      if (recreateIndexHandler
+              instanceof org.openmetadata.service.search.DefaultRecreateHandler defaultHandler
+          && currentJob != null
+          && currentJob.getJobConfiguration() != null) {
+        defaultHandler.withJobData(currentJob.getJobConfiguration());
+      }
       entityTracker.setOnEntityComplete(this::promoteEntityIndex);
       LOG.info(
           "Per-entity promotion callback SET for job {} (recreateIndex={}, recreateContext entities={})",

openmetadata-service/src/main/java/org/openmetadata/service/search/DefaultRecreateHandler.java

@@ -321,6 +321,15 @@ public void promoteEntityIndex(EntityReindexContext context, boolean reindexSucc
       return;
     }
 
+    // Restore live serving settings on the staged index before alias swap. The bulk-build
+    // overrides (refresh=-1, replicas=0, async translog) must NOT survive into live serving —
+    // otherwise live writes after promotion are buffered indefinitely and only become
+    // searchable on a manual _refresh, which surfaces as the "create-then-search returns
+    // nothing until reindex" symptom on knowledge pages. This mirrors the call in
+    // finalizeReindex; the per-entity distributed promotion path was missing it.
+    applyLiveServingSettings(searchClient, stagedIndex, entityType);
+    maybeForceMerge(searchClient, stagedIndex, entityType);
+
     // Always clear staged-index routing on the way out — see the rationale in finalizeReindex.
     try {
       Set<String> aliasesToAttach =

openmetadata-service/src/test/java/org/openmetadata/service/search/DefaultRecreateHandlerTest.java

@@ -6,6 +6,7 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.ArgumentMatchers.anySet;
 import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.lenient;
 import static org.mockito.Mockito.mock;
@@ -24,9 +25,12 @@
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
 import org.mockito.MockedStatic;
 import org.mockito.junit.jupiter.MockitoExtension;
 import org.openmetadata.schema.service.configuration.elasticsearch.ElasticSearchConfiguration;
+import org.openmetadata.schema.system.BulkIndexOverrides;
+import org.openmetadata.schema.system.EventPublisherJob;
 import org.openmetadata.search.IndexMapping;
 import org.openmetadata.service.Entity;
 import org.openmetadata.service.apps.bundles.searchIndex.ReindexingMetrics;
@@ -440,6 +444,59 @@ void testPromoteEntityIndexRecordsPromotionFailure() {
 
       verify(metrics).recordPromotionFailure("table");
     }
+
+    @Test
+    @DisplayName("Should restore live serving settings on staged index before alias swap")
+    void testPromoteEntityIndexAppliesLiveServingSettingsBeforeSwap() {
+      AliasState aliasState = new AliasState();
+      aliasState.put("table_search_index_rebuild_old", Set.of("table"));
+      aliasState.put("table_search_index_rebuild_new", new HashSet<>());
+
+      SearchClient client = aliasState.toMock();
+      SearchRepository repo = mock(SearchRepository.class);
+      when(repo.getSearchClient()).thenReturn(client);
+      when(repo.getClusterAlias()).thenReturn("");
+      when(repo.getIndexMapping("table"))
+          .thenReturn(
+              IndexMapping.builder()
+                  .indexName("table_search_index")
+                  .alias("table")
+                  .parentAliases(List.of("all"))
+                  .childAliases(List.of())
+                  .build());
+
+      EventPublisherJob jobData =
+          new EventPublisherJob()
+              .withBulkIndexSettings(
+                  new BulkIndexOverrides()
+                      .withNumberOfReplicas(0)
+                      .withRefreshInterval("-1")
+                      .withTranslogDurability(BulkIndexOverrides.TranslogDurability.ASYNC)
+                      .withTranslogSyncInterval("30s"));
+
+      try (MockedStatic<Entity> entityMock = mockStatic(Entity.class)) {
+        entityMock.when(Entity::getSearchRepository).thenReturn(repo);
+
+        EntityReindexContext context =
+            EntityReindexContext.builder()
+                .entityType("table")
+                .canonicalIndex("table_search_index")
+                .stagedIndex("table_search_index_rebuild_new")
+                .build();
+
+        new DefaultRecreateHandler().withJobData(jobData).promoteEntityIndex(context, true);
+      }
+
+      ArgumentCaptor<String> body = ArgumentCaptor.forClass(String.class);
+      verify(client).updateIndexSettings(eq("table_search_index_rebuild_new"), body.capture());
+      String json = body.getValue();
+      assertTrue(json.contains("\"refresh_interval\":\"1s\""), json);
+      assertTrue(json.contains("\"number_of_replicas\":1"), json);
+      assertTrue(json.contains("\"durability\":\"request\""), json);
+      assertTrue(
+          aliasState.indexAliases.get("table_search_index_rebuild_new").contains("table"),
+          "alias swap should still happen after settings revert");
+    }
   }
 
   @Nested