Skip to content
Browse files

basic bolts check for reportedfailedexception

  • Loading branch information...
1 parent 4e6e668 commit 33eb6b05232d9c7a57b6438aceed1dfa50bc5ccf @nathanmarz committed Oct 25, 2012
Showing with 3 additions and 1 deletion.
  1. +3 −1 src/jvm/backtype/storm/topology/BasicBoltExecutor.java
View
4 src/jvm/backtype/storm/topology/BasicBoltExecutor.java
@@ -33,7 +33,9 @@ public void execute(Tuple input) {
_bolt.execute(input, _collector);
_collector.getOutputter().ack(input);
} catch(FailedException e) {
- LOG.warn("Failed to process tuple", e);
+ if(e instanceof ReportedFailedException) {
+ _collector.reportError(e);
+ }
_collector.getOutputter().fail(input);
}
}

0 comments on commit 33eb6b0

Please sign in to comment.
Something went wrong with that request. Please try again.