GitHub user shikhar opened a pull request:
https://github.com/apache/kafka/pull/1778
KAFKA-4042: Contain connector & task start/stop failures within the Worker
Invoke the statusListener.onFailure() callback on start failures so that
the statusBackingStore is updated. This involved a fix to the putSafe()
functionality which prevented any update that was not preceded by a (non-safe)
put() from completing, so here when a connector or task is transitioning
directly to FAILED.
Worker start methods can still throw if the same connector name or task ID
is already registered with the worker, as this condition should not happen.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shikhar/kafka distherder-stayup-take4
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1778.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1778
----
commit 050b80331f63ec71f16a644e7fa8006823c94ecc
Author: Shikhar Bhushan <[email protected]>
Date: 2016-08-23T23:00:10Z
KAFKA-4042: Contain connector & task start/stop failures within the Worker
Invoke the statusListener.onFailure() callback on start failures so that
the statusBackingStore is updated. This involved a fix to the putSafe()
functionality which prevented any update that was not preceded by a (non-safe)
put() from completing, so here when a connector or task is transitioning
directly to FAILED.
Worker start methods can still throw if the same connector name or task ID
is already registered with the worker, as this condition should not happen.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
