diff --git a/server/src/main/java/org/opensearch/common/cache/tier/EhCacheDiskCachingTier.java b/server/src/main/java/org/opensearch/common/cache/tier/EhCacheDiskCachingTier.java
index aa136b02cbfb7..639936b62fc7b 100644
--- a/server/src/main/java/org/opensearch/common/cache/tier/EhCacheDiskCachingTier.java
+++ b/server/src/main/java/org/opensearch/common/cache/tier/EhCacheDiskCachingTier.java
@@ -320,6 +320,16 @@ public void onEvent(CacheEvent<? extends K, ? extends byte[]> event) {
                     assert event.getNewValue() == null;
                     break;
                 case REMOVED:
+                    this.removalListener.ifPresent(
+                        listener -> listener.onRemoval(
+                            new RemovalNotification<>(
+                                event.getKey(),
+                                valueSerializer.deserialize(event.getOldValue()),
+                                RemovalReason.INVALIDATED,
+                                TierType.DISK
+                            )
+                        )
+                    );
                     count.dec();
                     assert event.getNewValue() == null;
                     break;