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)