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();
     }
 
 }