kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] 02/02: HOTFIX: The cherry-pick for https://github.com/apache/kafka/pull/7207 to 2.2 causes a failure in AssignedStreamsTasksTest
Date Wed, 04 Sep 2019 15:09:25 GMT
This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit 619729cb8de16d88c7e7c70ab86120c3c91bcfd1
Author: Bill Bejeck <bill@confluent.io>
AuthorDate: Wed Sep 4 11:08:05 2019 -0400

    HOTFIX: The cherry-pick for https://github.com/apache/kafka/pull/7207 to 2.2 causes a
failure in AssignedStreamsTasksTest
---
 .../kafka/streams/processor/internals/AssignedStreamsTasksTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
index ca51a3b..1833052 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
@@ -519,7 +519,8 @@ public class AssignedStreamsTasksTest {
             stateDirectory,
             null,
             time,
-            () -> producer);
+            () -> producer,
+            metrics.sensor("dummy"));
 
         assignedTasks.addNewTask(task);
         assignedTasks.initializeNewTasks();


Mime
View raw message