[
https://issues.apache.org/jira/browse/CASSANDRA-10591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksey Yeschenko resolved CASSANDRA-10591.
-------------------------------------------
Resolution: Invalid
Nothing wrong here, except your triggers code, sorry.
The better avenue would be to ask users@ mailing list, or look for trigger
examples.
> Get CellName from ColumnDefinition in Cassandra
> -----------------------------------------------
>
> Key: CASSANDRA-10591
> URL: https://issues.apache.org/jira/browse/CASSANDRA-10591
> Project: Cassandra
> Issue Type: Bug
> Components: API, Core, Tools
> Reporter: Ashraful Islam
>
> I am trying to delete a row of a columnFamily from The cassandra trigger
> augment method. here is what i have tried
> CFMetaData cfMetaData = Schema.instance.getCFMetaData(keySpace, columnFamily);
> for (ColumnDefinition columnDefinition : cfMetaData.allColumns()) {
> Mutation mutation = new Mutation(keySpace, key);
> mutation.delete(columnFamily,
> CellNames.simpleDense(columnDefinition.name.bytes),
> System.currentTimeMillis());
> mutations.add(mutation);
> }
> but its giving me this error
> org.apache.cassandra.serializers.MarshalException: Expected 4 or 0 byte int
> (8)
> at
> org.apache.cassandra.serializers.Int32Serializer.validate(Int32Serializer.java:42)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.db.marshal.AbstractType.validate(AbstractType.java:113)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.db.marshal.AbstractType.validateCollectionMember(AbstractType.java:246)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.db.composites.AbstractCType.validate(AbstractCType.java:210)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at org.apache.cassandra.db.AbstractCell.validateName(AbstractCell.java:159)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.db.BufferDeletedCell.validateFields(BufferDeletedCell.java:103)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.triggers.TriggerExecutor.validate(TriggerExecutor.java:198)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:129)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.service.StorageProxy.mutateWithTriggers(StorageProxy.java:632)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition(ModificationStatement.java:488)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.cql3.statements.ModificationStatement.execute(ModificationStatement.java:474)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:225)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:256)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:241)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:123)
> ~[apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:507)
> [apache-cassandra-2.2.2.jar:2.2.2]
> at
> org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:401)
> [apache-cassandra-2.2.2.jar:2.2.2]
> at
> io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.access$700(AbstractChannelHandlerContext.java:32)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext$8.run(AbstractChannelHandlerContext.java:324)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> [na:1.7.0_79]
> at
> org.apache.cassandra.concurrent.AbstractTracingAwareExecutorService$FutureTask.run(AbstractTracingAwareExecutorService.java:164)
> [apache-cassandra-2.2.2.jar:2.2.2]
> at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105)
> [apache-cassandra-2.2.2.jar:2.2.2]
> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
