[PR] KAFKA-17929: Handle spurious wakeups while awaiting processable tasks [kafka]

["RohithDevarshetty (via GitHub)" <gi...@apache.org>]

RohithDevarshetty opened a new pull request, #23238:
URL: https://github.com/apache/kafka/pull/23238

   ### Summary
   
     `DefaultTaskManager.awaitProcessableTasks` used a single `Condition.await()` call after checking for processable tasks. Since condition waits may wake spuriously, the method could return even when there were still no processable tasks available.
   
     This change keeps awaiting in a loop until one of these is true:
     - a task can make progress
     - shutdown is requested
     - the waiter is interrupted
   
     A regression test verifies that a signal without any processable task does not release the waiter.
   
     ### Testing
   
     ```bash
     ./gradlew :streams:spotlessApply :streams:test --tests org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManagerTest
   
     Result: BUILD SUCCESSFUL.


-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] KAFKA-17929: Handle spurious wakeups while awaiting processable tasks [kafka]

["github-actions[bot] (via GitHub)" <gi...@apache.org>]

github-actions[bot] commented on PR #23238:
URL: https://github.com/apache/kafka/pull/23238#issuecomment-5466440310

   A label of 'needs-attention' was automatically added to this PR in order to raise the
   attention of the committers. Once this issue has been triaged, the `triage` label
   should be removed to prevent this automation from happening again.


-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org