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

Posted to dev@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/12/07 23:43:58 UTC

[jira] [Created] (KAFKA-4510) StreamThread must finish rebalance in state PENDING_SHUTDOWN

Matthias J. Sax created KAFKA-4510:
--------------------------------------

             Summary: StreamThread must finish rebalance in state PENDING_SHUTDOWN
                 Key: KAFKA-4510
                 URL: https://issues.apache.org/jira/browse/KAFKA-4510
             Project: Kafka
          Issue Type: Bug
          Components: streams
            Reporter: Matthias J. Sax
            Assignee: Matthias J. Sax


If a Streams application runs with multiple threads within one JVM and the application gets stopped. this can triggers a rebalance when the first threads finishes processing because not all thread shut down at the same time.

Because we try to reuse tasks, on rebalance task are not closed immediately in order for a potential reuse (if a task gets assigned the its original thread). However, if a thread is in state {{PENDING_SHUTDOWN}} it does finish the rebalance operation completely and thus does not release the suspended task and the application exits with not all locks released.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)