[kafka] branch trunk updated: MINOR: increase number of unique keys for Streams EOS system test (#5640)

[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 9f187a9  MINOR: increase number of unique keys for Streams EOS system test (#5640)
9f187a9 is described below

commit 9f187a9a880c603323a258df3450a29329f95d62
Author: Matthias J. Sax <mj...@apache.org>
AuthorDate: Wed Sep 19 15:09:33 2018 -0700

    MINOR: increase number of unique keys for Streams EOS system test (#5640)
    
    Increasing the number of unique keys, to increase likelihood that the test exposes KAFKA-7192.
    
    Reviewers: Apurva Mehta <ap...@confluent.io>, Guozhang Wang <gu...@confluent.io>, Bill Bejeck <bi...@confluent.io>, John Roesler <jo...@confluent.io>
---
 streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java b/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
index 0b18864..3187359 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
@@ -57,7 +57,7 @@ import java.util.concurrent.TimeUnit;
 
 public class EosTestDriver extends SmokeTestUtil {
 
-    private static final int MAX_NUMBER_OF_KEYS = 100;
+    private static final int MAX_NUMBER_OF_KEYS = 20000;
     private static final long MAX_IDLE_TIME_MS = 600000L;
 
     private static boolean isRunning = true;