cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jérémy SEVELLEC <jsevel...@gmail.com>
Subject Re: Column Family not able to be replicated between 2 nodes
Date Thu, 20 Oct 2011 09:15:57 GMT
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 32316535633164302d666166322d31**
> 3165302d303030302d313538346131**373038306266
> 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.**UnserializableColumnFamilyExce**ption: 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 32376666636361302d666166322d31**
> 3165302d303030302d313538346131**373038306266
> DEBUG [MigrationStage:1] 2011-10-20 10:04:47,673 Table.java (line 398)
> applying mutation of row 4d6967726174696f6e73204b6579
>  I*NFO [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

Mime
View raw message