[kafka] branch 2.3 updated: HOTFIX: AssignedStreamsTasksTest lacks one parameter
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new 2a38ae7 HOTFIX: AssignedStreamsTasksTest lacks one parameter
2a38ae7 is described below
commit 2a38ae7c492292282ed4c42845d4348e2eb166d5
Author: Guozhang Wang
AuthorDate: Thu Aug 29 18:18:31 2019 -0700
HOTFIX: AssignedStreamsTasksTest lacks one parameter
---
.../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();
[kafka] branch trunk updated (09ad6b8 -> fb381cb)
This is an automated email from the ASF dual-hosted git repository. jgus pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 09ad6b8 MINOR. Fix 2.3.0 streams systest dockerfile typo (#7272) add fb381cb MINOR: Fix integer overflow in LRUCacheBenchmark (#7270) No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[kafka] branch trunk updated (d2741e5 -> 09ad6b8)
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from d2741e5 MINOR: Remove `activeTaskCheckpointableOffsets` from `AbstractTask` (#7253) add 09ad6b8 MINOR. Fix 2.3.0 streams systest dockerfile typo (#7272) No new revisions were added by this update. Summary of changes: tests/docker/Dockerfile | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[kafka] branch trunk updated (fcfee61 -> d2741e5)
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from fcfee61 MINOR: Only send delete request if there are offsets in map (#7256) add d2741e5 MINOR: Remove `activeTaskCheckpointableOffsets` from `AbstractTask` (#7253) No new revisions were added by this update. Summary of changes: .../org/apache/kafka/streams/processor/internals/AbstractTask.java | 6 -- .../org/apache/kafka/streams/processor/internals/StreamTask.java | 7 ++- 2 files changed, 2 insertions(+), 11 deletions(-)
