Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/2467#discussion_r159120398 --- Diff: external/storm-solr/src/main/java/org/apache/storm/solr/bolt/SolrUpdateBolt.java --- @@ -153,4 +160,15 @@ private void failQueuedTuples(List<Tuple> failedTuples) { @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { } + @Override + public void cleanup() { + if (solrClient != null) { + try { + solrClient.close(); + } catch (IOException e) { + LOG.debug("Error while closing solrClient", e); --- End diff -- should it be error level?
---