1. Source can't connect to kafka\other resource - executor wait 10 sedonds (https://github.com/digitalocean/firebolt/blob/223d445912e74ffe1d039584a89df03a222ae954/executor/executor.go#L264) 2. During this period of time, a shutdown message is received by app (https://github.com/digitalocean/firebolt/blob/223d445912e74ffe1d039584a89df03a222ae954/executor/executor.go#L271) 3. Executor try to shutdown source, but old instance (https://github.com/digitalocean/firebolt/blob/223d445912e74ffe1d039584a89df03a222ae954/executor/executor.go#L274) 4. Executor continues to execute an infinite loop (https://github.com/digitalocean/firebolt/blob/223d445912e74ffe1d039584a89df03a222ae954/executor/executor.go#L250) 5. New source instance doesn't know anything about studown signal 6. Go to step 4 => App does not respond to system shutdown signals
firebolt/executor/executor.go
Line 264 in 223d445
firebolt/executor/executor.go
Line 271 in 223d445
firebolt/executor/executor.go
Line 274 in 223d445
firebolt/executor/executor.go
Line 250 in 223d445
=>
App does not respond to system shutdown signals