Skip to content

Instantly share code, notes, and snippets.

@ryanking
Created July 22, 2009 20:24
Show Gist options
  • Save ryanking/152251 to your computer and use it in GitHub Desktop.
Save ryanking/152251 to your computer and use it in GitHub Desktop.
DEBUG - batch_insert
DEBUG - insertBlocking writing key 2783412020 to 366568@[127.0.0.1:7000]
DEBUG - Applying RowMutation(table='Twitter', key='2783412020', modifications=[ColumnFamily(Statuses [created_at:false:32@1248290653252056, favorited:false:7@1248290653252056, id:false:12@1248290653252056, in_reply_to_screen_name:false:8@1248290653252056, in_reply_to_status_id:false:12@1248290653252056, in_reply_to_user_id:false:10@1248290653252056, source:false:51@1248290653252056, text:false:138@1248290653252056, truncated:false:7@1248290653252056])])
DEBUG - RowMutation(table='Twitter', key='2783412020', modifications=[ColumnFamily(Statuses [created_at:false:32@1248290653252056, favorited:false:7@1248290653252056, id:false:12@1248290653252056, in_reply_to_screen_name:false:8@1248290653252056, in_reply_to_status_id:false:12@1248290653252056, in_reply_to_user_id:false:10@1248290653252056, source:false:51@1248290653252056, text:false:138@1248290653252056, truncated:false:7@1248290653252056])]) applied. Sending response to 366568@127.0.0.1:7000
DEBUG - Processing response on a callback from 366568@127.0.0.1:7000
ERROR - error writing key 2783412020
java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:86)
at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:176)
at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:296)
at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:277)
at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:957)
at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:796)
at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:252)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:637)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment