Skip to content

Commit c22bd71

Browse files
minor fix
1 parent e580edd commit c22bd71

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,8 +134,8 @@ public final void punctuate(long timestamp) {
134134
eventStore.put(windowMs, rescheduledTasks.get(windowMs));
135135
} else {
136136
// can directly delete key from store
137-
log.debug("Deleting empty window for ts: {}", windowMs);
138137
eventStore.delete(windowMs);
138+
log.debug("Deleted empty window for ts: {}", windowMs);
139139
}
140140
} else {
141141
ArrayList<T> windowTasks = new ArrayList<>(events.subList(i, events.size()));

0 commit comments

Comments
 (0)