You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/02/25 19:52:56 UTC
[08/13] storm git commit: STORM-539. Storm hive bolt and trident
state. Added reportError for HiveBolt.
STORM-539. Storm hive bolt and trident state. Added reportError for HiveBolt.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b0cbb493
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b0cbb493
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b0cbb493
Branch: refs/heads/master
Commit: b0cbb493e541b4b3762b1adfed695abbb39ec863
Parents: 674ceae
Author: Sriharsha Chintalapani <ma...@harsha.io>
Authored: Thu Feb 12 09:47:04 2015 -0800
Committer: Sriharsha Chintalapani <ma...@harsha.io>
Committed: Thu Feb 12 09:47:04 2015 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/storm/hive/bolt/HiveBolt.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/b0cbb493/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
----------------------------------------------------------------------
diff --git a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
index 849697d..4d9f5da 100644
--- a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
+++ b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/HiveBolt.java
@@ -111,9 +111,9 @@ public class HiveBolt extends BaseRichBolt {
}
collector.ack(tuple);
} catch(Exception e) {
+ this.collector.reportError(e);
collector.fail(tuple);
flushAndCloseWriters();
- LOG.warn("hive streaming failed. ",e);
}
}