From 6b6eda7a4b459448bd26e605674a8df973febb97 Mon Sep 17 00:00:00 2001
From: Jungtaek Lim <kabhwan@gmail.com>
Date: Thu, 26 Feb 2015 09:43:52 +0900
Subject: [PATCH] Return Jedis into JedisPool with marking 'broken' if
 connection is broken

---
 .../java/org/apache/storm/redis/trident/state/RedisState.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
index f2fd624640c..72b12672493 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
@@ -77,7 +77,7 @@ public Jedis getJedis() {
      * The state updater and querier return the Jedis instance
      * */
     public void returnJedis(Jedis jedis) {
-        this.jedisPool.returnResource(jedis);
+        jedis.close();
     }
 
 }