Added debug log for tracking event store delete operations

avinashkolluru · avinashkolluru · commit e580eddd1047 · 2025-08-15T21:32:53.000+05:30
diff --git a/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java b/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java
@@ -134,6 +134,7 @@ public final void punctuate(long timestamp) {
             eventStore.put(windowMs, rescheduledTasks.get(windowMs));
           } else {
             // can directly delete key from store
+            log.debug("Deleting empty window for ts: {}", windowMs);
             eventStore.delete(windowMs);
           }
         } else {

Original file line number	Diff line number	Diff line change
`@@ -134,6 +134,7 @@ public final void punctuate(long timestamp) {`
`134`	`134`	`eventStore.put(windowMs, rescheduledTasks.get(windowMs));`
`135`	`135`	`} else {`
`136`	`136`	`// can directly delete key from store`
	`137`	`+ log.debug("Deleting empty window for ts: {}", windowMs);`
`137`	`138`	`eventStore.delete(windowMs);`
`138`	`139`	`}`
`139`	`140`	`} else {`