storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/3] storm git commit: Return Jedis into JedisPool with marking 'broken' if connection is broken
Date Wed, 11 Mar 2015 20:44:41 GMT
Repository: storm
Updated Branches:
  refs/heads/master 3113ae1ec -> 8c39e4c49


Return Jedis into JedisPool with marking 'broken' if connection is broken


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6b6eda7a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6b6eda7a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6b6eda7a

Branch: refs/heads/master
Commit: 6b6eda7a4b459448bd26e605674a8df973febb97
Parents: 64d7ac6
Author: Jungtaek Lim <kabhwan@gmail.com>
Authored: Thu Feb 26 09:43:52 2015 +0900
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Thu Feb 26 09:43:52 2015 +0900

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


http://git-wip-us.apache.org/repos/asf/storm/blob/6b6eda7a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java
----------------------------------------------------------------------
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 f2fd624..72b1267 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 class RedisState implements State {
      * The state updater and querier return the Jedis instance
      * */
     public void returnJedis(Jedis jedis) {
-        this.jedisPool.returnResource(jedis);
+        jedis.close();
     }
 
 }


Mime
View raw message