fix: guard search indexing failure recording against invalid entity IDs

Skip failure records when entity IDs are null or exceed the 36-char column
limit, extract IDs from EntityInterface instances in PartitionWorker, and
swallow ClosedChannelException noise in the Jetty12 WebSocket handler.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: mohityadav766

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

@@ -19,6 +19,7 @@ public enum FailureStage {
   }
 
   private static final int DEFAULT_BATCH_SIZE = 100;
+  private static final int ENTITY_ID_MAX_LENGTH = 36;
 
   private final CollectionDAO.SearchIndexFailureDAO failureDAO;
   private final String jobId;
@@ -115,6 +116,16 @@ private void recordFailure(
       return;
     }
 
+    if (entityId != null && entityId.length() > ENTITY_ID_MAX_LENGTH) {
+      LOG.warn(
+          "Skipping failure record for entityType={}: entityId length {} exceeds column limit {} (value starts with '{}')",
+          entityType,
+          entityId.length(),
+          ENTITY_ID_MAX_LENGTH,
+          entityId.substring(0, Math.min(50, entityId.length())));
+      return;
+    }
+
     LOG.info(
         "Recording {} failure for entityType={}, entityId={}, error={}",
         stage,

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

@@ -21,6 +21,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.UUID;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicLong;
 import lombok.extern.slf4j.Slf4j;
@@ -501,8 +502,23 @@ private BatchResult processBatch(
 
     if (failureRecorder != null && readErrorCount > 0) {
       for (EntityError entityError : listOrEmpty(resultList.getErrors())) {
-        String entityId =
-            entityError.getEntity() != null ? entityError.getEntity().toString() : null;
+        Object rawEntity = entityError.getEntity();
+        String entityId = null;
+        if (rawEntity instanceof EntityInterface) {
+          UUID id = ((EntityInterface) rawEntity).getId();
+          if (id != null) {
+            entityId = id.toString();
+          }
+        } else if (rawEntity != null) {
+          entityId = rawEntity.toString();
+        }
+        if (entityId == null) {
+          LOG.warn(
+              "Skipping reader failure record for entityType={}: entityId is null, message={}",
+              entityType,
+              entityError.getMessage());
+          continue;
+        }
         failureRecorder.recordReaderEntityFailure(
             entityType, entityId, null, entityError.getMessage());
       }

openmetadata-service/src/main/java/org/openmetadata/service/socket/Jetty12WebSocketHandler.java

@@ -17,6 +17,7 @@
 import io.socket.engineio.server.EngineIoWebSocket;
 import java.io.IOException;
 import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -128,7 +129,16 @@ public void onClose(int statusCode, String reason) {
 
   @OnWebSocketError
   public void onError(Throwable error) {
-    LOG.error("WebSocket error: {}", error.getMessage(), error);
-    emit("error", "websocket error", error.getMessage());
+    if (error instanceof ClosedChannelException) {
+      LOG.debug("WebSocket channel closed by peer (likely abnormal disconnect)");
+      return;
+    }
+    try {
+      LOG.error(
+          "WebSocket error: {} - {}", error.getClass().getSimpleName(), error.getMessage(), error);
+      emit("error", "websocket error", error.getMessage());
+    } catch (Exception e) {
+      LOG.error("Failed to handle WebSocket error gracefully: {}", e.getMessage(), e);
+    }
   }
 }