lucasbru commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1016657214
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##########
@@ -277,6 +294,9 @@ private void addTask(final Task task) {
}
}
}
+ if (task.state() == Task.State.CREATED) {
+ tasksToInitialize.offer(task);
+ }
Review Comment:
Well, only that the order here doesn't matter because I use the queue for
the reason I mention above.
In principle, I can restore the original order (to be safe), but just moving
all the logic in this method to initializeTasksIfNeeded (except for the
addition to the queue of course). wdyt?
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
