You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by Tharindu Mathew <mc...@gmail.com> on 2012/06/21 14:22:37 UTC
Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF
exceptions when the CF is present
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/
Re: Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF
exceptions when the CF is present
Posted by Tharindu Mathew <mc...@gmail.com>.
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/
Re: Weird behavior in Cassandra 1.1.0 - throwing unconfigured CF exceptions when the CF is present
Posted by aaron morton <aa...@thelastpickle.com>.
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/
>