This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 6560203d20e818515d5b8c961fa648788c684cd6 Author: Bill Bejeck <b...@confluent.io> AuthorDate: Wed Sep 4 11:21:11 2019 -0400 HOTFIX: The cherry-pick for https://github.com/apache/kafka/pull/7207 to 2.1 causes a failure in AssignedStreamsTasksTest --- .../kafka/streams/processor/internals/AssignedStreamsTasksTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 349c463..3849047 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 @@ -503,8 +503,7 @@ public class AssignedStreamsTasksTest { final StateDirectory stateDirectory = new StateDirectory( StreamTaskTest.createConfig(true), - time, - true); + time); final StreamTask task = new StreamTask( new TaskId(0, 0), @@ -517,7 +516,8 @@ public class AssignedStreamsTasksTest { stateDirectory, null, time, - () -> producer); + () -> producer, + metrics.sensor("dummy")); assignedTasks.addNewTask(task); assignedTasks.initializeNewTasks();