Check for nulls and log accordingly, skip as appropriately

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

Check for nulls and log accordingly, skip as appropriately #88

Closed stanlemon closed 6 years ago

stanlemon commented 6 years ago

@c-mimms Zong-wen reported it over in the cold DC. I can definitely see it happening with stale data if a deploy happens with a change to a class that's serialized. Better safe than sorry I figure.

stanlemon commented 6 years ago

Cherry picked this onto master as well @Crim