You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Ao Li (Jira)" <ji...@apache.org> on 2024/11/03 17:06:00 UTC

[jira] [Updated] (KAFKA-17929) `awaitProcessableTasks` is not safe in the presence of spurious wakeups.”

     [ https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ao Li updated KAFKA-17929:
--------------------------
    Component/s: streams

> `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
>          Components: streams
>            Reporter: Ao Li
>            Priority: Major
>
> 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)