salesforce / storm-dynamic-spout

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
BSD 3-Clause "New" or "Revised" License
41 stars 13 forks source link

Catch and swallow no-node exceptions (#93) #94

Closed Crim closed 6 years ago

Crim commented 6 years ago

Handle race condition between checking if a node exists, and removing the node.

Backporting bugfix to 0.9.x release: #92

Cuts bugfix version 0.9.2

Crim commented 6 years ago

@stanlemon backporting this to 0.9.x branch