[kafka] branch trunk updated: KAFKA-10757: Fix compilation failure in StreamThreadTest (#9636)

[ij...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ijuma 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 502a544  KAFKA-10757: Fix compilation failure in StreamThreadTest (#9636)
502a544 is described below

commit 502a544ee7a179ef8d2042c3a9c0baf3ad362788
Author: dengziming <de...@gmail.com>
AuthorDate: Sat Nov 21 13:53:34 2020 +0800

    KAFKA-10757: Fix compilation failure in StreamThreadTest (#9636)
    
    Add missing `null` to `TaskManager` constructor.
    
    Reviewers: Ismael Juma <is...@juma.me.uk>
---
 .../org/apache/kafka/streams/processor/internals/StreamThreadTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
index a0a0e3a..1de4ed1 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
@@ -756,7 +756,7 @@ public class StreamThreadTest {
             new StreamsMetricsImpl(metrics, CLIENT_ID, StreamsConfig.METRICS_LATEST, mockTime);
 
         final AtomicBoolean committed = new AtomicBoolean(false);
-        final TaskManager taskManager = new TaskManager(
+        final TaskManager taskManager = new TaskManager(null,
             null,
             null,
             null,