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

Posted to jira@kafka.apache.org by "Roman Leventov (Jira)" <ji...@apache.org> on 2020/01/31 15:14:00 UTC

[jira] [Created] (KAFKA-9488) Dangling CountDownLatch.await(timeout)

Roman Leventov created KAFKA-9488:
-------------------------------------

             Summary: Dangling CountDownLatch.await(timeout)
                 Key: KAFKA-9488
                 URL: https://issues.apache.org/jira/browse/KAFKA-9488
             Project: Kafka
          Issue Type: Bug
            Reporter: Roman Leventov


There are 12 occurrences in the codebase (11 in tests and 1 in production code, in WorkerSourceTask class) when the result of CountDownLatch.await(timeout, TimeUnit) is not checked. It's like not checking the result of File.delete(). The common fix is to wrap CDL.await() call into assertTrue().

All 16 places could be found using the following structural search in IntelliJ:

$x$.await($y$, $z$);

With "CountDownLatch" type constraint on the $x$ variable.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)