Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse code

for issue #145

  • Loading branch information...
commit c46db4f5e2239b964d746fc49f299972b07a7d5d 1 parent 93e731d
Kasper Grud Skat Madsen KasperMadsen authored
3  src/clj/backtype/storm/daemon/task.clj
@@ -305,6 +305,9 @@
305 305 (^void emitDirect [this ^int out-task-id ^String stream-id
306 306 ^List tuple ^Object message-id]
307 307 (send-spout-msg stream-id tuple message-id out-task-id)
  308 + )
  309 + (reportError [this error]
  310 + (report-error-fn error)
308 311 ))]
309 312 (log-message "Opening spout " component-id ":" task-id)
310 313 (.open spout storm-conf user-context (SpoutOutputCollector. output-collector))
1  src/jvm/backtype/storm/spout/ISpoutOutputCollector.java
@@ -8,5 +8,6 @@
8 8 */
9 9 List<Integer> emit(String streamId, List<Object> tuple, Object messageId);
10 10 void emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId);
  11 + void reportError(Throwable error);
11 12 }
12 13
5 src/jvm/backtype/storm/spout/SpoutOutputCollector.java
@@ -101,4 +101,9 @@ public void emitDirect(int taskId, String streamId, List<Object> tuple) {
101 101 public void emitDirect(int taskId, List<Object> tuple) {
102 102 emitDirect(taskId, tuple, null);
103 103 }
  104 +
  105 + @Override
  106 + public void reportError(Throwable error) {
  107 + _delegate.reportError(error);
  108 + }
104 109 }
5 src/jvm/backtype/storm/testing/SpoutTracker.java
@@ -43,6 +43,11 @@ public void emitDirect(int taskId, String streamId, List<Object> tuple, Object m
43 43 _collector.emitDirect(taskId, streamId, tuple, messageId);
44 44 recordSpoutEmit();
45 45 }
  46 +
  47 + @Override
  48 + public void reportError(Throwable error) {
  49 + _collector.reportError(error);
  50 + }
46 51 }
47 52
48 53

0 comments on commit c46db4f

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