cadonna commented on code in PR #12562:
URL: https://github.com/apache/kafka/pull/12562#discussion_r955892807
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##########
@@ -60,6 +60,7 @@ private class StateUpdaterThread extends Thread {
private final ChangelogReader changelogReader;
private final AtomicBoolean isRunning = new AtomicBoolean(true);
private final Map<TaskId, Task> updatingTasks = new
ConcurrentHashMap<>();
+ private final Map<TaskId, Task> pausedTasks = new
ConcurrentHashMap<>();
Review Comment:
I moved the map of paused tasks from the state update to the state updater
thread since it actually is -- as the map of updating tasks -- an internal data
structure of the thread.
--
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]
