Ao Li created KAFKA-17929:
-----------------------------

             Summary: `awaitProcessableTasks` is not safe in the presence of 
spurious wakeups.”
                 Key: KAFKA-17929
                 URL: https://issues.apache.org/jira/browse/KAFKA-17929
             Project: Kafka
          Issue Type: Bug
            Reporter: Ao Li


According to JDK, `await` can be unblocked due to spurious wakeups 
https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html

Currently `DefaultTaskManager::awaitProcessableTasks` does not handle this 
scenario. Branch https://github.com/aoli-al/kafka/tree/KAFKA-82 shows a failing 
test because of this 

Command: ./gradlew :streams:test --tests 
DefaultTaskManagerTest.shouldBlockOnAwait



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to