metron-platform/metron-common-streaming/metron-common-storm/src/main/java/org/apache/metron/storm/common/bolt/ConfiguredEnrichmentBolt.java [37:46]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void cleanup() {
    // This method may not be called in production.
    // See https://storm.apache.org/releases/1.0.6/javadocs/org/apache/storm/task/IBolt.html#cleanup-- for more detail.
    super.cleanup();
    try {
      StellarFunctions.close();
    } catch (IOException e) {
      LOG.error(e.getMessage(), e);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



metron-platform/metron-common-streaming/metron-common-storm/src/main/java/org/apache/metron/storm/common/bolt/ConfiguredParserBolt.java [42:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void cleanup() {
    // This method may not be called in production.
    // See https://storm.apache.org/releases/1.0.6/javadocs/org/apache/storm/task/IBolt.html#cleanup-- for more detail.
    super.cleanup();
    try {
      StellarFunctions.close();
    } catch (IOException e) {
      LOG.error(e.getMessage(), e);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -