Jason Gustafson created KAFKA-3211: -------------------------------------- Summary: Handle WorkerTask shutdown before startup correctly Key: KAFKA-3211 URL: https://issues.apache.org/jira/browse/KAFKA-3211 Project: Kafka Issue Type: Bug Components: copycat Reporter: Jason Gustafson Assignee: Jason Gustafson
This is a follow-up from KAFKA-3092. The shortcut exit from awaitShutdown() in WorkerTask can lead to an inconsistent state if the task has not actually begun execution yet. Although the caller will believe the task has completed shutdown, nothing stops it from starting afterwards. This could happen if there is a long delay between the time a task is submitted to an Executor and the time it begins execution. -- This message was sent by Atlassian JIRA (v6.3.4#6332)