Yes, it seems an error on our side. Sorry for the noise.
On Sun, Jun 24, 2012 at 11:38 PM, aaron morton <aa...@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/
