eevans

java.lang.RuntimeException: java.lang.ArrayIndexOutOfBoundsException: -95
	at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:34)
	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:636)
Caused by: java.lang.ArrayIndexOutOfBoundsException: -95
	at org.apache.cassandra.db.Table.apply(Table.java:379)
	at org.apache.cassandra.db.RowMutation.apply(RowMutation.java:196)
	at org.apache.cassandra.service.StorageProxy$1.runMayThrow(StorageProxy.java:194)
	at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)

eevans

from fabric.api  import put, sudo
from os.path     import join, basename

HOME        = '/home'
SHELL       = '/bin/bash'
SUDO_GROUP  = 'sudo'

def adduser(username, sshpubkey=None, admin=False):
    sudo('adduser --gecos \',,,\' --home %s --shell %s --disabled-login %s' % \
        (join(HOME, username), SHELL, username))

eevans

Traceback (most recent call last):
  File "/usr/lib/pymodules/python2.6/nose/loader.py", line 379, in loadTestsFromName
    addr.filename, addr.module)
  File "/usr/lib/pymodules/python2.6/nose/importer.py", line 39, in importFromPath
    return self.importFromDir(dir_path, fqname)
  File "/usr/lib/pymodules/python2.6/nose/importer.py", line 86, in importFromDir
    mod = load_module(part_fqname, fh, filename, desc)
  File "/home/eevans/dev/src/git/cassandra/test/system/__init__.py", line 26, in <module>
    import avro.ipc as ipc
  File "/usr/local/lib/python2.6/dist-packages/avro-_AVRO_VERSION_-py2.6.egg/avro/ipc.py", line 35, in <module>

eevans

#!/usr/bin/python

from simplejson import loads

schema = loads(open('cassandra.avpr').read())

print """
class MissingFieldException(Exception):
    pass
"""

eevans

class MissingFieldException(Exception):
    pass

class ColumnPath(dict):
    def __init__(self, **kwargs):
        if not kwargs.has_key('column_family'):
            raise MissingFieldException('column_family')
        self['column_family'] = kwargs.get('column_family', None)

        self['super_column'] = kwargs.get('super_column', None)

eevans

from cassandra import Cassandra
from cassandra.atypes import *

client = Cassandra.Client()
client.set_keyspace(keyspace='Keyspace1')
client.insert(key='keyAAA',
              column_parent=ColumnParent(column_family='Standard2'),
              column=Column(name='colAAA',
                            value='valAAA',
                            clock=Clock(timestamp=1),

eevans

java -jar build/flewton-1.0.jar 9995 com.rackspace.flewton.backend.LoggingBackend,com.rackspace.flewton.backend.NullBackend
 INFO 14:04:50,490 Adding backend: com.rackspace.flewton.backend.LoggingBackend
 INFO 14:04:50,491 Adding backend: com.rackspace.flewton.backend.NullBackend
 INFO 14:04:50,534 Binding to UDP 0.0.0.0:9995
 INFO 14:05:05,029 source=localhost:8888, dest=127.0.0.2:80, bytes=100
 INFO 14:05:10,034 source=localhost:8888, dest=127.0.0.2:80, bytes=100

eevans

 INFO 17:43:01,763 Loading settings from file:/etc/cassandra/cassandra.yaml
DEBUG 17:43:01,958 Syncing log with a period of 10000
 INFO 17:43:01,958 DiskAccessMode 'auto' determined to be mmap, indexAccessMode is mmap
DEBUG 17:43:02,041 setting auto_bootstrap to false
 INFO 17:43:02,109 Starting up client gossip
DEBUG 17:43:02,197 attempting to connect to /10.1.9.32
 INFO 17:43:02,207 Node /10.1.9.32 is now part of the cluster
DEBUG 17:43:02,207 Resetting pool for /10.1.9.32
DEBUG 17:43:02,210 Node /10.1.9.32 state normal, token 76426229089211633986606168715786092138
DEBUG 17:43:02,210 clearing cached endpoints

eevans

[...]

DEBUG 18:14:39,837 Resetting pool for /10.1.9.31
DEBUG 18:14:39,838 Node /10.1.9.31 state normal, token 130422514498655458579966251475616909160
DEBUG 18:14:39,838 clearing cached endpoints
 INFO 18:14:39,838 Node /10.1.9.30 is now part of the cluster
DEBUG 18:14:39,839 Resetting pool for /10.1.9.30
DEBUG 18:14:39,839 Node /10.1.9.30 state normal, token 88558006740455176880390025766200390905
DEBUG 18:14:39,840 clearing cached endpoints
DEBUG 18:14:39,858 attempting to connect to /10.1.9.33

eevans

log4j.rootLogger=DEBUG,stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d{HH:mm:ss,SSS} %m%n

log4j.appender.R=org.apache.log4j.RollingFileAppender
log4j.appender.file.maxFileSize=20MB
log4j.appender.file.maxBackupIndex=50
log4j.appender.R.layout=org.apache.log4j.PatternLayout