Github user satishd commented on a diff in the pull request:
https://github.com/apache/storm/pull/2467#discussion_r157941502
--- Diff:
external/storm-solr/src/main/java/org/apache/storm/solr/bolt/SolrUpdateBolt.java
---
@@ -88,11 +92,14 @@ private int capacity() {
@Override
protected void process(Tuple tuple) {
try {
+ LOG.debug("Processing Tuple: {}", tuple);
SolrRequest request = solrMapper.toSolrRequest(tuple);
solrClient.request(request, solrMapper.getCollection());
ack(tuple);
+ LOG.debug("Acked Tuple: {}", tuple);
} catch (Exception e) {
fail(tuple, e);
+ LOG.debug("Failed Tuple: {}", tuple, e);
--- End diff --
nit: may want to push log statement to `fail` method.
---
