Hi,
I’m trying to execute some couchbase scenario with storm.
My couchbase client is singleton.
I have 2 bolts that using this client.
During the execution I’m getting the following exception:
Caused by: java.lang.IllegalStateException: Interrupted while waiting to add Cmd: 1 Opaque: 2 Key: 592ff073-17c8-40d9-95d6-f6d2dec90e66 Cas: 0 Exp: 0 Flags: 0 Data Length: 80
at net.spy.memcached.protocol.TCPMemcachedNodeImpl.addOp(TCPMemcachedNodeImpl.java:351)
at net.spy.memcached.MemcachedConnection.addOperation(MemcachedConnection.java:1159)
at com.couchbase.client.CouchbaseConnection.addOperation(CouchbaseConnection.java:248)
at net.spy.memcached.MemcachedConnection.enqueueOperation(MemcachedConnection.java:1081)
at net.spy.memcached.MemcachedClient.asyncStore(MemcachedClient.java:315)
at net.spy.memcached.MemcachedClient.set(MemcachedClient.java:884)
at com.couchbase.client.CouchbaseClient.set(CouchbaseClient.java:1107)
Any idea?
Thanks,
Shay