From 18569c857a4a876ea3d9be29b3b06e55de8999a2 Mon Sep 17 00:00:00 2001
From: Sachin Kale <kalsac@amazon.com>
Date: Mon, 2 Sep 2024 20:22:17 +0530
Subject: [PATCH] Address PR comments

Signed-off-by: Sachin Kale <kalsac@amazon.com>
---
 .../node/remotestore/RemoteStorePinnedTimestampService.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/server/src/main/java/org/opensearch/node/remotestore/RemoteStorePinnedTimestampService.java b/server/src/main/java/org/opensearch/node/remotestore/RemoteStorePinnedTimestampService.java
index 4c2c03b049dcf..782ba5e9a6540 100644
--- a/server/src/main/java/org/opensearch/node/remotestore/RemoteStorePinnedTimestampService.java
+++ b/server/src/main/java/org/opensearch/node/remotestore/RemoteStorePinnedTimestampService.java
@@ -121,6 +121,7 @@ public void pinTimestamp(long timestamp, String pinningEntity, ActionListener<Vo
                     elapsedTime,
                     RemoteStoreSettings.getPinnedTimestampsLookbackInterval().nanos()
                 );
+                logger.error(errorMessage);
                 unpinTimestamp(timestamp, pinningEntity, ActionListener.wrap(() -> listener.onFailure(new RuntimeException(errorMessage))));
             } else {
                 listener.onResponse(null);
@@ -165,6 +166,7 @@ public void cloneTimestamp(long timestamp, String existingPinningEntity, String
                     timestamp,
                     existingPinningEntity
                 );
+                logger.error(errorMessage);
                 listener.onFailure(new IllegalArgumentException(errorMessage));
             }
         } catch (IOException e) {
@@ -205,6 +207,7 @@ public void unpinTimestamp(long timestamp, String pinningEntity, ActionListener<
                 listener.onResponse(null);
             } else {
                 String errorMessage = String.format(Locale.ROOT, "Timestamp: %s is not pinned by entity: %s", timestamp, pinningEntity);
+                logger.error(errorMessage);
                 listener.onFailure(new IllegalArgumentException(errorMessage));
             }
         } catch (IOException e) {