You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/09/24 19:56:58 UTC
[31/50] git commit: Fix bug - reference undefined variable self
Fix bug - reference undefined variable self
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7391d32d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7391d32d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7391d32d
Branch: refs/heads/security
Commit: 7391d32d978c906c80343fa8f59d31a64b8170ab
Parents: 8f6fbda
Author: anya <an...@forter.com>
Authored: Wed Sep 3 09:53:06 2014 +0300
Committer: anya <an...@forter.com>
Committed: Wed Sep 3 09:53:06 2014 +0300
----------------------------------------------------------------------
examples/storm-starter/multilang/resources/randomsentence.js | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/7391d32d/examples/storm-starter/multilang/resources/randomsentence.js
----------------------------------------------------------------------
diff --git a/examples/storm-starter/multilang/resources/randomsentence.js b/examples/storm-starter/multilang/resources/randomsentence.js
index 40ab474..57cec00 100644
--- a/examples/storm-starter/multilang/resources/randomsentence.js
+++ b/examples/storm-starter/multilang/resources/randomsentence.js
@@ -54,9 +54,10 @@ RandomSentenceSpout.prototype.ack = function(id, done) {
}
RandomSentenceSpout.prototype.fail = function(id, done) {
+ var self = this;
this.log('Received fail for - ' + id + '. Retrying.');
this.emit({tuple: this.pending[id], id:id}, function(taskIds) {
- self.log(this.pending[id] + ' sent to task ids - ' + taskIds);
+ self.log(self.pending[id] + ' sent to task ids - ' + taskIds);
});
done();
}