incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aaron morton <aa...@thelastpickle.com>
Subject Re: Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF exceptions when the CF is present
Date Sun, 24 Jun 2012 18:08:07 GMT
I would check if the schema's have diverged, run describe cluster in the cli. 

Cheers

-----------------
Aaron Morton
Freelance Developer
@aaronmorton
http://www.thelastpickle.com

On 22/06/2012, at 12:22 AM, Tharindu Mathew wrote:

> Hi,
> 
> I'm having issues with Hector 1.1.0 and Cassandra 1.1.0.
> 
> I'm adding a column family dynamically, and after sleeping for some time and making sure
that the column family is created using keyspacedefinition.getCFs, I still get unconfigured
column family exceptions..
> 
> Even after some time if I try to insert data I still get unconfigured CF exceptions.
Below at [1], I have inserted logs to specifically print all the CFs before inserting data.
It is present in the CF list, but still it's failing. Note, that this does not happen for
all data. Some data does get inserted.
> 
> I'm baffled as to what could be the reason. Any help would be really appreciated.
> 
> [1] -
> 
> [2012-06-21 17:22:21,680]  INFO {org.wso2.carbon.eventbridge.streamdefn.cassandra.datastore.CassandraConnector}
-  Keyspace desc. : ThriftKsDef[name=EVENT_KS,strategyClass=org.apache.cassandra.locator.SimpleStrategy,strategyOptions={replication_factor=1},cfDefs=[ThriftCfDef[keyspace=EVENT_KS,name=org_wso2_bam_kp,columnType=STANDARD,comparatorType=me.prettyprint.hector.api.ddl.ComparatorType@c89abe1,subComparatorType=<null>,comparatorTypeAlias=,subComparatorTypeAlias=,comment=,rowCacheSize=0.0,rowCacheSavePeriodInSeconds=0,keyCacheSize=0.0,readRepairChance=1.0,columnMetadata=[],gcGraceSeconds=864000,keyValidationClass=org.apache.cassandra.db.marshal.BytesType,defaultValidationClass=org.apache.cassandra.db.marshal.BytesType,id=1004,maxCompactionThreshold=32,minCompactionThreshold=4,memtableOperationsInMillions=0.0,memtableThroughputInMb=0,memtableFlushAfterMins=0,keyCacheSavePeriodInSeconds=0,replicateOnWrite=true,compactionStrategy=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy,compactionStrategyOptions={},compressionOptions={sstable_compression=org.apache.cassandra.io.compress.SnappyCompressor},mergeShardsChance=0.0,rowCacheProvider=<null>,keyAlias=<null>,rowCacheKeysToSave=0]],durableWrites=true]
> 
> [2012-06-21 17:22:21,681]  INFO {org.wso2.carbon.eventbridge.streamdefn.cassandra.datastore.CassandraConnector}
-  CFs present 
> cf name : org_wso2_bam_kp
> 
> [2012-06-21 17:22:21,683] ERROR {org.wso2.carbon.eventbridge.streamdefn.cassandra.subscriber.BAMEventSubscriber}
-  Error processing event. Event{streamId='org.wso2.bam.kp-1.0.5-6b80ca6c-1ad9-4495-a872-8466c424c5d0',
timeStamp=1340279541606, metaData=[external], metaData=null, payloadData=[Orange, 1.0, 520.0,
Ivan]}
> me.prettyprint.hector.api.exceptions.HInvalidRequestException: InvalidRequestException(why:unconfigured
columnfamily org_wso2_bam_kp)
> 	at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:45)
> 	at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:264)
> 	at me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97)
> 	at me.prettyprint.cassandra.model.MutatorImpl.execute(MutatorImpl.java:243)
> 	at org.wso2.carbon.eventbridge.streamdefn.cassandra.datastore.CassandraConnector.insertEvent(CassandraConnector.java:361)
> 	at org.wso2.carbon.eventbridge.streamdefn.cassandra.subscriber.BAMEventSubscriber.receive(BAMEventSubscriber.java:42)
> 	at org.wso2.carbon.eventbridge.core.internal.queue.QueueWorker.run(QueueWorker.java:64)
> 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
> 	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> 	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> 	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:680)
> Caused by: InvalidRequestException(why:unconfigured columnfamily org_wso2_bam_kp)
> 	at org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20169)
> 	at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
> 	at org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:913)
> 	at org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:899)
> 	at me.prettyprint.cassandra.model.MutatorImpl$3.execute(MutatorImpl.java:246)
> 	at me.prettyprint.cassandra.model.MutatorImpl$3.execute(MutatorImpl.java:243)
> 	at me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:103)
> 	at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:258)
> 	... 11 more
> 
> -- 
> Regards,
> 
> Tharindu
> 
> blog: http://mackiemathew.com/
> 


Mime
View raw message