OpenSearch/watcher
Martijn van Groningen c916c5e35b watcher: If during startup a watch record couldn't be saved because of a version conflict then overwrite it.
In certain cases this could cause Watcher to prevent from being started (either automatically or manually):
* The watch of the triggered watch doesn't exist
* The execution service rejected the execution the watch. (due to not enough threads in the thread pool)

If a watch record gets overwritten this means it has been executed before when watcher was running, but we were unable to delete the triggered watch. So we executed the a watch twice with the same trigger event. This can happen if watcher was stopped before because of the node running Watcher unexpectedly stopped (master left, power loss etc.)

In stead of failing to write the watch record, we overwrite it set the state 'executed_multiple_times'.

Closes elastic/elasticsearch#695

Original commit: elastic/x-pack-elasticsearch@20f805cb99
2015-11-10 09:24:15 +07:00
..
bin/watcher update CLI tools to work with spaces in the home path 2015-09-11 11:15:19 -04:00
dev-tools [maven] fix build issues with artifactId renaming 2015-08-18 18:03:40 +02:00
docs watcher: If during startup a watch record couldn't be saved because of a version conflict then overwrite it. 2015-11-10 09:24:15 +07:00
src watcher: If during startup a watch record couldn't be saved because of a version conflict then overwrite it. 2015-11-10 09:24:15 +07:00
LICENSE.txt Update LICENSE.txt for shield and watcher with new EULA 2015-10-20 15:47:00 +02:00
NOTICE.txt initial migration of watcher 2015-07-13 12:23:07 +02:00
README.asciidoc initial migration of watcher 2015-07-13 12:23:07 +02:00
build.gradle Build: Improve behavior and setup for attachment to elasticsearch 2015-11-06 11:08:03 -08:00

README.asciidoc

= Elasticsearch Watcher Plugin

This plugins adds conditioned scheduled tasks features to elasticsearch - such a task is called a `Watch`.

You can build the plugin with `mvn package`.

The documentation is put in the `docs/` directory.