Major Description
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.
Attachments
Issue Links
- links to
