Nikita-Shupletsov commented on code in PR #21365:
URL: https://github.com/apache/kafka/pull/21365#discussion_r2771485439
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##########
@@ -312,12 +312,8 @@ public void shouldLockTasksOnClose() {
final StreamTask activeTask1 = statefulTask(taskId00,
taskId00ChangelogPartitions)
.inState(State.RUNNING)
.withInputPartitions(taskId00Partitions).build();
- final StreamTask activeTask2 = statefulTask(taskId01,
taskId01ChangelogPartitions)
Review Comment:
see the comment bellow.
tbh, I am not 100% sure why it had two tasks, as we don't check the second
task at all. it might have been copy pasted from another test
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
