cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tharindu Mathew <mcclou...@gmail.com>
Subject Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF exceptions when the CF is present
Date Thu, 21 Jun 2012 12:22:37 GMT
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