redis-lib/src/main/java/com/streamsets/pipeline/stage/origin/redis/BaseRedisSource.java
@Override
  public void destroy() {
    // Clean up any open resources.
    if (null != redisClient) {
      redisClient.disconnect();
      redisClient.close();
      redisClient = null;
    }
    super.destroy();
  }
@Override
  public void destroy() {
    // Clean up any open resources.
    if (null != redisClient) {
      redisClient.disconnect();
      redisClient.close();
      redisClient = null;
    }
    super.destroy();
  }
{@inheritDoc}