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 <1127478+lihao...@users.noreply.github.com> 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 <wangg...@gmail.com> --- .../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(),