This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f7ac5d3d00 Minor: enable index for emit final sliding window (#12461)
f7ac5d3d00 is described below
commit f7ac5d3d00f3cd3caa25c3003900bdb245d5252e
Author: Hao Li <[email protected]>
AuthorDate: Fri Jul 29 14:47:25 2022 -0700
Minor: enable index for emit final sliding window (#12461)
Enable index for sliding window emit final case as it's faster to fetch
windows for particular key
Reviewers: Guozhang Wang <[email protected]>
---
.../kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
index 5ca6b911b7..587d2d5a87 100644
---
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
+++
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
@@ -233,7 +233,7 @@ public class SlidingWindowedKStreamImpl<K, V> extends
AbstractStream<K, V> imple
Duration.ofMillis(retentionPeriod),
Duration.ofMillis(windows.timeDifferenceMs()),
false,
- false
+ true
) :
Stores.persistentTimestampedWindowStore(
materialized.storeName(),
