kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix message count for sliding windows test (#9248)
Date Wed, 02 Sep 2020 22:20:17 GMT
This is an automated email from the ASF dual-hosted git repository.

vvcephei 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 24b03a6  MINOR: Fix message count for sliding windows test (#9248)
24b03a6 is described below

commit 24b03a688f95012d6b2e35390f889bfd465aeacb
Author: leah <lthomas@confluent.io>
AuthorDate: Wed Sep 2 17:19:39 2020 -0500

    MINOR: Fix message count for sliding windows test (#9248)
    
    Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, John Roesler <vvcephei@apache.org>
---
 .../streams/integration/KStreamAggregationIntegrationTest.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
index 5cd08f5..e101c2f 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
@@ -484,13 +484,13 @@ public class KStreamAggregationIntegrationTest {
                 new TimeWindowedDeserializer<>(new StringDeserializer(), 500L),
                 new StringDeserializer(),
                 String.class,
-                25);
+                30);
 
         final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer(
                 new TimeWindowedDeserializer<String>(),
                 new StringDeserializer(),
                 String.class,
-                25,
+                30,
                 true);
 
         final Comparator<KeyValueTimestamp<Windowed<String>, String>> comparator
=
@@ -587,14 +587,14 @@ public class KStreamAggregationIntegrationTest {
                 new TimeWindowedDeserializer<>(),
                 new IntegerDeserializer(),
                 String.class,
-                15);
+                30);
 
         // read from ConsoleConsumer
         final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer(
                 new TimeWindowedDeserializer<String>(),
                 new IntegerDeserializer(),
                 String.class,
-                15,
+                30,
                 true);
 
         final Comparator<KeyValueTimestamp<Windowed<String>, Integer>>
comparator =


Mime
View raw message