Yes, right.
There seems to other case, instance returned to pool with broken state
(removed from pool), and returned to normal state.

2014년 7월 31일 목요일, 唐 思成<[email protected]>님이 작성한 메시지:

> what is you configure of Jedis pool?
> my guess is maybe there are more than one Jedis pool in your topology
> 在 2014年7月22日,下午1:22,이승진 <[email protected]
> <javascript:_e(%7B%7D,'cvml','[email protected]');>> 写道:
>
>
> java.lang.RuntimeException: redis.clients.jedis.exceptions.JedisException: 
> Could not return the resource to the pool
>       at 
> backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128)
>       at 
> backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99)
>       at 
> backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80)
>       at 
> backtype.storm.daemon.executor$fn__5641$fn__5653$fn__5700.invoke(executor.clj:746)
>       at backtype.storm.util$async_loop$fn__457.invoke(util.clj:431)
>       at clojure.lang.AFn.run(AFn.java:24)
>       at java.lang.Thread.run(Thread.java:745)
> Caused by: redis.clients.jedis.exceptions.JedisException: Could not return 
> the resource to the pool
>       at redis.clients.util.Pool.returnResourceObject(Pool.java:54)
>       at redis.clients.jedis.JedisPool.returnResource(JedisPool.java:98)
>       at 
> com.naver.labs.nelo2.notifier.bolt.ThresholdCheckBolt.execute(ThresholdCheckBolt.java:143)
>       at 
> backtype.storm.topology.BasicBoltExecutor.execute(BasicBoltExecutor.java:50)
>       at 
> backtype.storm.daemon.executor$fn__5641$tuple_action_fn__5643.invoke(executor.clj:631)
>       at 
> backtype.storm.daemon.executor$mk_task_receiver$fn__5564.invoke(executor.clj:399)
>       at 
> backtype.storm.disruptor$clojure_handler$reify__745.onEvent(disruptor.clj:58)
>       at 
> backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:120)
>       ... 6 more
> Caused by: java.lang.IllegalStateException: Returned object not currently 
> part of this pool
>       at 
> org.apache.commons.pool2.impl.GenericObjectPool.returnObject(GenericObjectPool.java:534)
>       at redis.clients.util.Pool.returnResourceObject(Pool.java:52)
>       ... 13 more
>
>
> Hi all,
>
>
> I'm seeing very weird error message like above.
>
>
> In certain bolt, it communicate with redis.
>
>
> When I set parallelism hint to 32, it works fine.
>
>
> but when I set parallelism hint to some number bigger than 32, that error
> occurs.
>
>
> currently I have 2 supervisor nodes of storm, each has 1 worker.
>
>
> Is it Storm's problem or Jedis's, any clue will be appreciated.
>
>
>

-- 
Name : 임 정택
Blog : http://www.heartsavior.net / http://dev.heartsavior.net
Twitter : http://twitter.com/heartsavior
LinkedIn : http://www.linkedin.com/in/heartsavior

Reply via email to