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 =
|