cadonna commented on code in PR #12562:
URL: https://github.com/apache/kafka/pull/12562#discussion_r957073457
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##########
@@ -86,6 +87,10 @@ public boolean onlyStandbyTasksLeft() {
return !updatingTasks.isEmpty() &&
updatingTasks.values().stream().noneMatch(Task::isActive);
}
+ public Collection<Task> getPausedTasks() {
Review Comment:
No, I just moved the map of paused tasks to the state updater thread. The
state updater does not have permissions to access private fields of the state
udater thread due to encapsulation, so I needed to add a getter for the tasks.
The behavior stays the same. You can see below in `getPausedTasks()` that the
call to `pausedTasks.values()` was replaced with a call to this method which
does exactly the same.
--
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]
