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?


---

Reply via email to