Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1702#discussion_r80775363
--- Diff:
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubSpout.java
---
@@ -152,7 +152,7 @@ public void open(Map config, TopologyContext context,
SpoutOutputCollector colle
try {
preparePartitions(config, totalTasks, taskIndex, collector);
} catch (Exception e) {
- logger.error(e.getMessage());
+ collector.reportError(e);
--- End diff --
It does log it, and puts it on the UI.
https://github.com/apache/storm/blob/28563ece16274bcd61827f38e960ce2d27a57dea/storm-core/src/jvm/org/apache/storm/executor/error/ReportError.java#L61
There is throttling around it so if we get too many errors too quickly they
will not all be logged and not all of them will be written to ZK.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
