[kafka] branch trunk updated: Minor: enable index for emit final sliding window (#12461)

[gu...@apache.org]

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 <11...@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 <wa...@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(),