Hi,

I think it's because you create a new columnFamily with hector and you don't wait the propagation of this modification in the cluster before writing.

Hector provide a method witjh a boolean to say "blockUntilComplete" when you create a columnFamily :
cluster.addColumnFamily(<your cf definition>, true);

Here is the hector javadoc about that : http://rantav.github.com/hector//source/content/API/core/0.8.0-2/me/prettyprint/hector/api/Cluster.html#addColumnFamily(me.prettyprint.hector.api.ddl.ColumnFamilyDefinition, boolean)

Regards,

Jérémy

2011/10/20 Renato Baceolar da Silveira <renatods@indabamobile.co.za>
Hi All and greetings from South Africa, a country with a sad Rugby team :(

I am processing a batch operation, that inserts a number of column families.

This batch operation is executed in a cluster with 2 nodes and replication of 2.

EACH NODE is installed in a  VMWARE ESSI virtual box, in a Ubuntu 9
server 64 bit. Both Nodes live in the same physical server, and communication between
them is through shared hardware.

 The virtual machines have 4gb of ram, and plenty hdd
space.

The version of Cassandra is 0.8.5.

Both nodes start empty before this batch process commences.

At the insertion of the first Column Family I receive this error in the log, which
tells me that for a number of times the specific column family is Replayed
for insertion, but it seems not to succeed. Without the insertion of this
first Column Family our validation process fails the batch process.

Can any one perhaps shed some light on this matter?


Kind Regards

Renato da Silveira

===============
error log - Applicaion Process
===============

me.prettyprint.hector.api.
exceptions.HectorException: SchemaDisagreementException()
    at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:68)
    at me.prettyprint.cassandra.service.ThriftCluster$4.execute(ThriftCluster.java:82)
    at me.prettyprint.cassandra.service.ThriftCluster$4.execute(ThriftCluster.java:76)
    at me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:101)
    at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:219)
    at me.prettyprint.cassandra.service.ThriftCluster.addColumnFamily(ThriftCluster.java:86)
    at com.xxx.xxx.hector.HectorManager.addColumnFamily(HectorManager.java:132)
    at com.xxx.xxx.facade.CassandraManager.addColumnFamily(CassandraManager.java:117)
    at com.xxx.xxx.model.xxx.createRegistryContainer(xxx.java:63)
    at com.xxx.xxx.model.xxx.buildRegistry(xxx.java:120)
    at com.xxx.xxx.facade.Process.articleLoaderDoInstance(Process.java:117)
    at com.xxx.xxx.facade.Process.articleLoader(Process.java:58)
Caused by: SchemaDisagreementException()
    at org.apache.cassandra.thrift.Cassandra$system_add_column_family_result.read(Cassandra.java:26119)
    at org.apache.cassandra.thrift.Cassandra$Client.recv_system_add_column_family(Cassandra.java:1455)
    at org.apache.cassandra.thrift.Cassandra$Client.system_add_column_family(Cassandra.java:1430)
    at me.prettyprint.cassandra.service.ThriftCluster$4.execute(ThriftCluster.java:80)
    ... 10 more


===============
error log - Cassandra Log
===============
INFO [MigrationStage:1] 2011-10-20 10:03:58,944 Migration.java (line 116) Applying migration 0aadb220-faf2-11e0-0000-1584a17080bf Add keyspace: MyKeyspace, rep strategy:SimpleStrategy{}, durable_writes: true
DEBUG [MigrationStage:1] 2011-10-20 10:03:58,945 Table.java (line 398) applying mutation of row 4c617374204d6967726174696f6e
DEBUG [MigrationStage:1] 2011-10-20 10:03:58,945 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=10486)
 INFO [MigrationStage:1] 2011-10-20 10:03:58,945 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Migrations@539124954(6675/8343 serialized/live bytes, 1 ops)
DEBUG [MigrationStage:1] 2011-10-20 10:03:58,946 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=10486)
 INFO [FlushWriter:3] 2011-10-20 10:03:58,946 Memtable.java (line 237) Writing Memtable-Migrations@539124954(6675/8343 serialized/live bytes, 1 ops)
 INFO [MigrationStage:1] 2011-10-20 10:03:58,946 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Schema@1225252094(2696/3370 serialized/live bytes, 3 ops)
DEBUG [FlushWriter:3] 2011-10-20 10:03:58,947 DatabaseDescriptor.java (line 821) expected data files size is 8043; largest free partition has 88471957504 bytes free
 INFO [FlushWriter:3] 2011-10-20 10:03:58,991 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Migrations-g-1-Data.db (6739 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:03:58,991 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Migrations-g-1 to list of files tracked for system.Migrations
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:03:58,992 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=10486), column family 2.
 INFO [FlushWriter:3] 2011-10-20 10:03:58,992 Memtable.java (line 237) Writing Memtable-Schema@1225252094(2696/3370 serialized/live bytes, 3 ops)
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:03:58,992 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is Schema (3), ; hasNext: false
DEBUG [CompactionExecutor:4] 2011-10-20 10:03:58,992 CompactionManager.java (line 124) Checking to see if compaction of Migrations would be useful
DEBUG [FlushWriter:3] 2011-10-20 10:03:58,993 DatabaseDescriptor.java (line 821) expected data files size is 3355; largest free partition has 88471932928 bytes free
 INFO [FlushWriter:3] 2011-10-20 10:03:59,026 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Schema-g-1-Data.db (2846 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:03:59,026 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Schema-g-1 to list of files tracked for system.Schema
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:03:59,027 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=10486), column family 3.
DEBUG [CompactionExecutor:5] 2011-10-20 10:03:59,027 CompactionManager.java (line 124) Checking to see if compaction of Schema would be useful
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:03:59,027 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is ; hasNext: false
DEBUG [MigrationStage:1] 2011-10-20 10:03:59,028 MigrationManager.java (line 137) Gossiping my schema version 0aadb220-faf2-11e0-0000-1584a17080bf
DEBUG [MigrationStage:1] 2011-10-20 10:03:59,029 SchemaCheckVerbHandler.java (line 36) Received schema check request.
DEBUG [ScheduledTasks:1] 2011-10-20 10:04:16,797 StorageLoadBalancer.java (line 336) Disseminating load info ...
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,373 SchemaCheckVerbHandler.java (line 36) Received schema check request.
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,444 DefinitionsUpdateVerbHandler.java (line 70) Applying AddColumnFamily from /192.168.1.30
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,444 Table.java (line 398) applying mutation of row 32316535633164302d666166322d313165302d303030302d313538346131373038306266
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,447 Table.java (line 398) applying mutation of row 4d6967726174696f6e73204b6579
 INFO [MigrationStage:1] 2011-10-20 10:04:37,456 Migration.java (line 116) Applying migration 21e5c1d0-faf2-11e0-0000-1584a17080bf Add column family: org.apache.cassandra.config.CFMetaData@7f1fc4b8[cfId=1000,ksName=MyKeyspace,cfName=a1307,cfType=Standard,comparator=org.apache.cassandra.db.marshal.AsciiType,subcolumncomparator=<null>,comment=,rowCacheSize=0.0,keyCacheSize=200000.0,readRepairChance=1.0,replicateOnWrite=true,gcGraceSeconds=864000,defaultValidator=org.apache.cassandra.db.marshal.BytesType,keyValidator=org.apache.cassandra.db.marshal.BytesType,minCompactionThreshold=4,maxCompactionThreshold=32,rowCacheSavePeriodInSeconds=0,keyCacheSavePeriodInSeconds=14400,memtableFlushAfterMins=1440,memtableThroughputInMb=55,memtableOperationsInMillions=0.2578125,mergeShardsChance=0.1,keyAlias=<null>,column_metadata={}]
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,456 Table.java (line 398) applying mutation of row 4c617374204d6967726174696f6e
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,456 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=20900)
 INFO [MigrationStage:1] 2011-10-20 10:04:37,457 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Migrations@2125221179(7183/8978 serialized/live bytes, 1 ops)
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,457 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=20900)
 INFO [FlushWriter:3] 2011-10-20 10:04:37,457 Memtable.java (line 237) Writing Memtable-Migrations@2125221179(7183/8978 serialized/live bytes, 1 ops)
 INFO [MigrationStage:1] 2011-10-20 10:04:37,458 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Schema@1644338549(2990/3737 serialized/live bytes, 3 ops)
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,459 DatabaseDescriptor.java (line 821) expected data files size is 8653; largest free partition has 88471896064 bytes free
 INFO [FlushWriter:3] 2011-10-20 10:04:37,513 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Migrations-g-2-Data.db (7247 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,514 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Migrations-g-2 to list of files tracked for system.Migrations
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,514 AutoSavingCache.java (line 175) KeyCache capacity for Migrations is 2
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:37,514 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=20900), column family 2.
 INFO [FlushWriter:3] 2011-10-20 10:04:37,515 Memtable.java (line 237) Writing Memtable-Schema@1644338549(2990/3737 serialized/live bytes, 3 ops)
DEBUG [CompactionExecutor:6] 2011-10-20 10:04:37,515 CompactionManager.java (line 124) Checking to see if compaction of Migrations would be useful
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:37,515 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is Schema (3), ; hasNext: false
 INFO [FlushWriter:3] 2011-10-20 10:04:37,515 Memtable.java (line 237) Writing Memtable-Schema@1644338549(2990/3737 serialized/live bytes, 3 ops)
DEBUG [CompactionExecutor:6] 2011-10-20 10:04:37,515 CompactionManager.java (line 124) Checking to see if compaction of Migrations would be useful
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:37,515 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is Schema (3), ; hasNext: false
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,515 DatabaseDescriptor.java (line 821) expected data files size is 3708; largest free partition has 88471871488 bytes free
ERROR [MutationStage:33] 2011-10-20 10:04:37,530 RowMutationVerbHandler.java (line 82) Error in row mutation
org.apache.cassandra.db.UnserializableColumnFamilyException: Couldn't find cfId=1000
    at org.apache.cassandra.db.ColumnFamilySerializer.deserialize(ColumnFamilySerializer.java:123)
    at org.apache.cassandra.db.RowMutation$RowMutationSerializer.deserialize(RowMutation.java:392)
    at org.apache.cassandra.db.RowMutation$RowMutationSerializer.deserialize(RowMutation.java:400)
    at org.apache.cassandra.db.RowMutation.fromBytes(RowMutation.java:329)
    at org.apache.cassandra.db.RowMutationVerbHandler.doVerb(RowMutationVerbHandler.java:46)
    at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:59)
    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:662)

 INFO [FlushWriter:3] 2011-10-20 10:04:37,553 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Schema-g-2-Data.db (3140 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,553 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Schema-g-2 to list of files tracked for system.Schema
DEBUG [FlushWriter:3] 2011-10-20 10:04:37,554 AutoSavingCache.java (line 175) KeyCache capacity for Schema is 2
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:37,555 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=20900), column family 3.
DEBUG [CompactionExecutor:7] 2011-10-20 10:04:37,555 CompactionManager.java (line 124) Checking to see if compaction of Schema would be useful
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:37,555 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is ; hasNext: false
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,556 ColumnFamilyStore.java (line 264) Starting CFS a1307
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,557 AutoSavingCache.java (line 175) KeyCache capacity for a1307 is 200000
DEBUG [MigrationStage:1] 2011-10-20 10:04:37,557 MigrationManager.java (line 137) Gossiping my schema version 21e5c1d0-faf2-11e0-0000-1584a17080bf
DEBUG [MutationStage:34] 2011-10-20 10:04:47,503 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333034', modifications=[ColumnFamily(a1307 [User:false:3@1319097867943000,])])
DEBUG [MutationStage:34] 2011-10-20 10:04:47,504 Table.java (line 398) applying mutation of row 6131333034
DEBUG [MutationStage:34] 2011-10-20 10:04:47,506 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333034', modifications=[ColumnFamily(a1307 [User:false:3@1319097867943000,])]) applied.  Sending response to 1490@/192.168.1.30
DEBUG [MutationStage:35] 2011-10-20 10:04:47,544 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333034', modifications=[ColumnFamily(a1307 [Group:false:3@1319097878019000,])])
DEBUG [MutationStage:35] 2011-10-20 10:04:47,546 Table.java (line 398) applying mutation of row 6131333034
DEBUG [MutationStage:35] 2011-10-20 10:04:47,546 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333034', modifications=[ColumnFamily(a1307 [Group:false:3@1319097878019000,])]) applied.  Sending response to 1491@/192.168.1.30
DEBUG [MutationStage:36] 2011-10-20 10:04:47,553 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegContent:false:5@1319097878059000,])])
DEBUG [MutationStage:36] 2011-10-20 10:04:47,554 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:36] 2011-10-20 10:04:47,554 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegContent:false:5@1319097878059000,])]) applied.  Sending response to 1492@/192.168.1.30
DEBUG [MutationStage:37] 2011-10-20 10:04:47,558 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegGroup:false:5@1319097878065000,])])
DEBUG [MutationStage:37] 2011-10-20 10:04:47,558 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:37] 2011-10-20 10:04:47,559 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegGroup:false:5@1319097878065000,])]) applied.  Sending response to 1493@/192.168.1.30
DEBUG [MutationStage:38] 2011-10-20 10:04:47,563 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegUser:false:5@1319097878070000,])])
DEBUG [MutationStage:38] 2011-10-20 10:04:47,563 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:38] 2011-10-20 10:04:47,563 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegUser:false:5@1319097878070000,])]) applied.  Sending response to 1494@/192.168.1.30
DEBUG [MutationStage:39] 2011-10-20 10:04:47,567 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegContentSched:false:5@1319097878074000,])])
DEBUG [MutationStage:39] 2011-10-20 10:04:47,567 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:39] 2011-10-20 10:04:47,567 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [RegContentSched:false:5@1319097878074000,])]) applied.  Sending response to 1495@/192.168.1.30
DEBUG [MutationStage:40] 2011-10-20 10:04:47,571 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [ActiveEntity:false:5@1319097878078000,])])
DEBUG [MutationStage:40] 2011-10-20 10:04:47,571 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:40] 2011-10-20 10:04:47,571 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [ActiveEntity:false:5@1319097878078000,])]) applied.  Sending response to 1496@/192.168.1.30
DEBUG [MutationStage:41] 2011-10-20 10:04:47,574 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [InactiveEntity:false:5@1319097878082000,])])
DEBUG [MutationStage:41] 2011-10-20 10:04:47,575 Table.java (line 398) applying mutation of row 6131333035
DEBUG [MutationStage:41] 2011-10-20 10:04:47,575 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333035', modifications=[ColumnFamily(a1307 [InactiveEntity:false:5@1319097878082000,])]) applied.  Sending response to 1497@/192.168.1.30
DEBUG [MutationStage:42] 2011-10-20 10:04:47,579 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Friend List:false:5@1319097878087000,])])
DEBUG [MutationStage:42] 2011-10-20 10:04:47,579 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:42] 2011-10-20 10:04:47,580 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Friend List:false:5@1319097878087000,])]) applied.  Sending response to 1498@/192.168.1.30
DEBUG [MutationStage:43] 2011-10-20 10:04:47,582 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Profile Items:false:5@1319097878090000,])])
DEBUG [MutationStage:43] 2011-10-20 10:04:47,583 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:43] 2011-10-20 10:04:47,583 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Profile Items:false:5@1319097878090000,])]) applied.  Sending response to 1499@/192.168.1.30
DEBUG [MutationStage:44] 2011-10-20 10:04:47,586 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Likes:false:5@1319097878094000,])])
DEBUG [MutationStage:44] 2011-10-20 10:04:47,586 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:44] 2011-10-20 10:04:47,587 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Likes:false:5@1319097878094000,])]) applied.  Sending response to 1500@/192.168.1.30
DEBUG [MutationStage:45] 2011-10-20 10:04:47,590 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Groups:false:5@1319097878097000,])])
DEBUG [MutationStage:45] 2011-10-20 10:04:47,590 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:45] 2011-10-20 10:04:47,591 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Groups:false:5@1319097878097000,])]) applied.  Sending response to 1501@/192.168.1.30
DEBUG [MutationStage:46] 2011-10-20 10:04:47,594 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Content:false:5@1319097878102000,])])
DEBUG [MutationStage:46] 2011-10-20 10:04:47,595 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:46] 2011-10-20 10:04:47,595 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Content:false:5@1319097878102000,])]) applied.  Sending response to 1502@/192.168.1.30
DEBUG [MutationStage:47] 2011-10-20 10:04:47,598 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Events:false:5@1319097878106000,])])
DEBUG [MutationStage:47] 2011-10-20 10:04:47,599 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:47] 2011-10-20 10:04:47,599 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Events:false:5@1319097878106000,])]) applied.  Sending response to 1503@/192.168.1.30
DEBUG [MutationStage:48] 2011-10-20 10:04:47,602 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Bespoke Containers:false:5@1319097878110000,])])
DEBUG [MutationStage:48] 2011-10-20 10:04:47,602 Table.java (line 398) applying mutation of row 6131333036
DEBUG [MutationStage:48] 2011-10-20 10:04:47,603 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131333036', modifications=[ColumnFamily(a1307 [Bespoke Containers:false:5@1319097878110000,])]) applied.  Sending response to 1504@/192.168.1.30
DEBUG [MutationStage:49] 2011-10-20 10:04:47,605 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131323231', modifications=[ColumnFamily(a1307 [Entity ID Field:false:5@1319097878113000,])])
DEBUG [MutationStage:49] 2011-10-20 10:04:47,606 Table.java (line 398) applying mutation of row 6131323231
DEBUG [MutationStage:49] 2011-10-20 10:04:47,606 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131323231', modifications=[ColumnFamily(a1307 [Entity ID Field:false:5@1319097878113000,])]) applied.  Sending response to 1505@/192.168.1.30
DEBUG [MutationStage:50] 2011-10-20 10:04:47,609 RowMutationVerbHandler.java (line 48) Applying RowMutation(keyspace='MyKeyspace', key='6131323231', modifications=[ColumnFamily(a1307 [Entity Type Field:false:5@1319097878117000,])])
DEBUG [MutationStage:50] 2011-10-20 10:04:47,609 Table.java (line 398) applying mutation of row 6131323231
DEBUG [MutationStage:50] 2011-10-20 10:04:47,610 RowMutationVerbHandler.java (line 77) RowMutation(keyspace='MyKeyspace', key='6131323231', modifications=[ColumnFamily(a1307 [Entity Type Field:false:5@1319097878117000,])]) applied.  Sending response to 1506@/192.168.1.30
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,612 SchemaCheckVerbHandler.java (line 36) Received schema check request.
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,655 SchemaCheckVerbHandler.java (line 36) Received schema check request.
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,671 DefinitionsUpdateVerbHandler.java (line 70) Applying AddColumnFamily from /192.168.1.30
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,671 Table.java (line 398) applying mutation of row 32376666636361302d666166322d313165302d303030302d313538346131373038306266
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,673 Table.java (line 398) applying mutation of row 4d6967726174696f6e73204b6579
 INFO [MigrationStage:1] 2011-10-20 10:04:47,673 Migration.java (line 116) Applying migration 27ffcca0-faf2-11e0-0000-1584a17080bf Add column family: org.apache.cassandra.config.CFMetaData@33a998c7[cfId=1001,ksName=MyKeyspace,cfName=a1101,cfType=Standard,comparator=org.apache.cassandra.db.marshal.AsciiType,subcolumncomparator=<null>,comment=,rowCacheSize=0.0,keyCacheSize=200000.0,readRepairChance=1.0,replicateOnWrite=true,gcGraceSeconds=864000,defaultValidator=org.apache.cassandra.db.marshal.BytesType,keyValidator=org.apache.cassandra.db.marshal.BytesType,minCompactionThreshold=4,maxCompactionThreshold=32,rowCacheSavePeriodInSeconds=0,keyCacheSavePeriodInSeconds=14400,memtableFlushAfterMins=1440,memtableThroughputInMb=55,memtableOperationsInMillions=0.2578125,mergeShardsChance=0.1,keyAlias=<null>,column_metadata={}]
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,673 Table.java (line 398) applying mutation of row 4c617374204d6967726174696f6e
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,674 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=33582)
 INFO [MigrationStage:1] 2011-10-20 10:04:47,674 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Migrations@1131236176(7476/9345 serialized/live bytes, 1 ops)
DEBUG [MigrationStage:1] 2011-10-20 10:04:47,674 ColumnFamilyStore.java (line 765) flush position is ReplayPosition(segmentId=1319097494650, position=33582)
 INFO [FlushWriter:3] 2011-10-20 10:04:47,675 Memtable.java (line 237) Writing Memtable-Migrations@1131236176(7476/9345 serialized/live bytes, 1 ops)
 INFO [MigrationStage:1] 2011-10-20 10:04:47,676 ColumnFamilyStore.java (line 1128) Enqueuing flush of Memtable-Schema@1013683141(3283/4103 serialized/live bytes, 3 ops)
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,676 DatabaseDescriptor.java (line 821) expected data files size is 9004; largest free partition has 88471822336 bytes free
 INFO [FlushWriter:3] 2011-10-20 10:04:47,725 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Migrations-g-3-Data.db (7540 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,725 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Migrations-g-3 to list of files tracked for system.Migrations
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,726 AutoSavingCache.java (line 175) KeyCache capacity for Migrations is 3
DEBUG [CompactionExecutor:4] 2011-10-20 10:04:47,726 CompactionManager.java (line 124) Checking to see if compaction of Migrations would be useful
 INFO [FlushWriter:3] 2011-10-20 10:04:47,726 Memtable.java (line 237) Writing Memtable-Schema@1013683141(3283/4103 serialized/live bytes, 3 ops)
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:47,726 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=33582), column family 2.
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:47,727 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is a1307 (1000), Schema (3), ; hasNext: false
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,727 DatabaseDescriptor.java (line 821) expected data files size is 4059; largest free partition has 88471797760 bytes free
 INFO [FlushWriter:3] 2011-10-20 10:04:47,751 Memtable.java (line 254) Completed flushing /var/lib/cassandra/data/system/Schema-g-3-Data.db (3433 bytes)
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,752 DataTracker.java (line 264) adding /var/lib/cassandra/data/system/Schema-g-3 to list of files tracked for system.Schema
DEBUG [FlushWriter:3] 2011-10-20 10:04:47,752 AutoSavingCache.java (line 175) KeyCache capacity for Schema is 3
DEBUG [CompactionExecutor:5] 2011-10-20 10:04:47,752 CompactionManager.java (line 124) Checking to see if compaction of Schema would be useful
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:47,752 CommitLog.java (line 446) discard completed log segments for ReplayPosition(segmentId=1319097494650, position=33582), column family 3.
DEBUG [COMMIT-LOG-WRITER] 2011-10-20 10:04:47,753 CommitLog.java (line 486) Not safe to delete commit log CommitLogSegment(/var/lib/cassandra/commitlog/CommitLog-1319097494650.log); dirty is a1307 (1000), ; hasNext: false



--
Renato Bacelar da Silveira
Software Engineer (Java J2SE J2EE)



--
Jérémy