cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tharindu Mathew <mcclou...@gmail.com>
Subject Re: Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF exceptions when the CF is present
Date Mon, 25 Jun 2012 05:42:49 GMT
Yes, it seems an error on our side.

Sorry for the noise.

On Sun, Jun 24, 2012 at 11:38 PM, aaron morton <aaron@thelastpickle.com>wrote:

> 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/
>
>
>


-- 
Regards,

Tharindu

blog: http://mackiemathew.com/

Mime
View raw message