From 850b4a664cfc9b5ab4a3a0ec7a3ccaf277f9e9c2 Mon Sep 17 00:00:00 2001
From: Emma Montross <emontross@slack-corp.com>
Date: Mon, 26 Aug 2024 10:51:25 -0600
Subject: [PATCH 1/2] error log on chunk failure

---
 .../astra/logstore/search/AstraDistributedQueryService.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java b/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
index 8251226f0c..5b633d7342 100644
--- a/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
+++ b/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
@@ -418,6 +418,7 @@ private List<SearchResult<LogMessage>> distributedSearch(
               response.add(searchResult.get() == null ? SearchResult.error() : searchResult.get());
             } else {
               response.add(SearchResult.error());
+              LOG.error("Error fetching search result {}", searchResult);
             }
           } catch (Exception e) {
             LOG.error("Error fetching search result", e);

From 4862a5c51ba6c167568d7e857a3552f0cadb7634 Mon Sep 17 00:00:00 2001
From: Emma Montross <emontross@slack-corp.com>
Date: Mon, 26 Aug 2024 11:16:12 -0600
Subject: [PATCH 2/2] make log a warn

---
 .../astra/logstore/search/AstraDistributedQueryService.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java b/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
index 5b633d7342..0173e5e5bf 100644
--- a/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
+++ b/astra/src/main/java/com/slack/astra/logstore/search/AstraDistributedQueryService.java
@@ -418,7 +418,7 @@ private List<SearchResult<LogMessage>> distributedSearch(
               response.add(searchResult.get() == null ? SearchResult.error() : searchResult.get());
             } else {
               response.add(SearchResult.error());
-              LOG.error("Error fetching search result {}", searchResult);
+              LOG.warn("Error fetching part of search result {}", searchResult);
             }
           } catch (Exception e) {
             LOG.error("Error fetching search result", e);