storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 이승진 <sweetest...@navercorp.com>
Subject storm with redis, java.lang.IllegalStateException: Returned object not currently part of this pool
Date Tue, 22 Jul 2014 05:22:30 GMT

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.
Mime
View raw message