Skip to content

Instantly share code, notes, and snippets.

@maraca
Created August 5, 2011 08:48
Show Gist options
  • Save maraca/1127145 to your computer and use it in GitHub Desktop.
Save maraca/1127145 to your computer and use it in GitHub Desktop.
Fun with Cassandra
time ./scripts/cassamine.py > record.txt
Traceback (most recent call last):
File "./scripts/cassamine.py", line 32, in <module>
main()
File "./scripts/cassamine.py", line 24, in main
'sha1': gen_hash(word, 'sha1'), })
File "/usr/local/lib/python2.6/dist-packages/pycassa/columnfamily.py", line 755, in insert
write_consistency_level=write_consistency_level)
File "/usr/local/lib/python2.6/dist-packages/pycassa/columnfamily.py", line 773, in batch_insert
batch.send()
File "/usr/local/lib/python2.6/dist-packages/pycassa/batch.py", line 130, in send
conn.batch_mutate(mutations, write_consistency_level)
File "/usr/local/lib/python2.6/dist-packages/pycassa/pool.py", line 384, in new_f
raise app_exc
thrift.Thrift.TApplicationException: Internal error processing batch_mutate
real 937m5.303s
user 572m44.940s
sys 68m51.080s
###########################################################
Generated 65940000 values in 56216 seconds
###########################################################
WARN 01:45:37,096 insufficient space to compact all requested files SSTableReader(path='/var/lib/cassandra/data/Lulzmine/Passwords-g-1234-Data.db'), SSTableReader(path='/var/lib/cassandra/data/Lulzmine/Passwords-g-787-Data.db'), SSTableReader(path='/var/lib/cassandra/data/Lulzmine/Passwords-g-1085-Data.db'), SSTableReader(path='/var/lib/cassandra/data/Lulzmine/Passwords-g-936-Data.db')
^CERROR 01:45:44,540 Internal error processing batch_mutate
java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut down
at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:81)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:816)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1337)
at org.apache.cassandra.service.StorageProxy.insertLocal(StorageProxy.java:360)
at org.apache.cassandra.service.StorageProxy.sendToHintedEndpoints(StorageProxy.java:241)
at org.apache.cassandra.service.StorageProxy.access$000(StorageProxy.java:62)
at org.apache.cassandra.service.StorageProxy$1.apply(StorageProxy.java:99)
at org.apache.cassandra.service.StorageProxy.performWrite(StorageProxy.java:210)
at org.apache.cassandra.service.StorageProxy.mutate(StorageProxy.java:154)
at org.apache.cassandra.thrift.CassandraServer.doInsert(CassandraServer.java:560)
at org.apache.cassandra.thrift.CassandraServer.internal_batch_mutate(CassandraServer.java:511)
at org.apache.cassandra.thrift.CassandraServer.batch_mutate(CassandraServer.java:519)
at org.apache.cassandra.thrift.Cassandra$Processor$batch_mutate.process(Cassandra.java:3454)
at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889)
at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:679)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment