cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Viet (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CASSANDRA-6524) Trigger
Date Wed, 25 Dec 2013 05:27:51 GMT

     [ https://issues.apache.org/jira/browse/CASSANDRA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

David Viet updated CASSANDRA-6524:
----------------------------------

    Description: 
I follow the Trigger example of Cassandra.
My test Column Family
CREATE TABLE test (
  key text,
  value text,
  PRIMARY KEY (key)
)

My index for test Column Family 
CREATE TABLE index (
  name text,
  value text,
  PRIMARY KEY (name)
)

I try to add (key, key) to this index CF.
*mutation.add("sampleindex", key, key ,System.currentTimeMillis());*


 WARN 14:19:00,854 Exception
java.lang.IllegalArgumentException
        at java.nio.Buffer.limit(Buffer.java:267)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:55)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:64)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:82)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:35)
        at java.util.TreeMap.compare(TreeMap.java:1188)
        at java.util.TreeMap.put(TreeMap.java:531)
        at org.apache.cassandra.db.TreeMapBackedSortedColumns.addColumn(TreeMapBackedSortedColumns.java:90)
        at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:116)
        at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:128)
        at org.apache.cassandra.db.RowMutation.add(RowMutation.java:144)
        at org.apache.cassandra.db.RowMutation.add(RowMutation.java:154)
        at org.apache.cassandra.triggers.InvertedIndex.augment(InvertedIndex.java:83)
        at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:123)
        at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:73)
        at org.apache.cassandra.service.StorageProxy.mutateWithTriggers(StorageProxy.java:567)
        at org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition(ModificationStatement.java:379)
        at org.apache.cassandra.cql3.statements.ModificationStatement.execute(ModificationStatement.java:363)
        at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:129)
        at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:145)
        at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:136)
        at org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1936)
        at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4394)
        at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4378)
        at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
        at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:194)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
        at java.lang.Thread.run(Thread.java:722)

  was:
I follow the Trigger example of Cassandra.
My test Column Family
CREATE TABLE test (
  key text,
  value text,
  PRIMARY KEY (key)
)

My index for test Column Family 
CREATE TABLE index (
  name text,
  value text,
  PRIMARY KEY (name)
)

I try to add (key, key) to this index CF.
mutation.add("sampleindex", key, key ,System.currentTimeMillis());


 WARN 14:19:00,854 Exception
java.lang.IllegalArgumentException
        at java.nio.Buffer.limit(Buffer.java:267)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:55)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:64)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:82)
        at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:35)
        at java.util.TreeMap.compare(TreeMap.java:1188)
        at java.util.TreeMap.put(TreeMap.java:531)
        at org.apache.cassandra.db.TreeMapBackedSortedColumns.addColumn(TreeMapBackedSortedColumns.java:90)
        at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:116)
        at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:128)
        at org.apache.cassandra.db.RowMutation.add(RowMutation.java:144)
        at org.apache.cassandra.db.RowMutation.add(RowMutation.java:154)
        at org.apache.cassandra.triggers.InvertedIndex.augment(InvertedIndex.java:83)
        at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:123)
        at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:73)
        at org.apache.cassandra.service.StorageProxy.mutateWithTriggers(StorageProxy.java:567)
        at org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition(ModificationStatement.java:379)
        at org.apache.cassandra.cql3.statements.ModificationStatement.execute(ModificationStatement.java:363)
        at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:129)
        at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:145)
        at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:136)
        at org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1936)
        at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4394)
        at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4378)
        at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
        at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:194)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
        at java.lang.Thread.run(Thread.java:722)


> Trigger 
> --------
>
>                 Key: CASSANDRA-6524
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-6524
>             Project: Cassandra
>          Issue Type: Bug
>         Environment: Cassandra 2.0.2 - Windows 7 64bit
>            Reporter: David Viet
>
> I follow the Trigger example of Cassandra.
> My test Column Family
> CREATE TABLE test (
>   key text,
>   value text,
>   PRIMARY KEY (key)
> )
> My index for test Column Family 
> CREATE TABLE index (
>   name text,
>   value text,
>   PRIMARY KEY (name)
> )
> I try to add (key, key) to this index CF.
> *mutation.add("sampleindex", key, key ,System.currentTimeMillis());*
>  WARN 14:19:00,854 Exception
> java.lang.IllegalArgumentException
>         at java.nio.Buffer.limit(Buffer.java:267)
>         at org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:55)
>         at org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:64)
>         at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:82)
>         at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:35)
>         at java.util.TreeMap.compare(TreeMap.java:1188)
>         at java.util.TreeMap.put(TreeMap.java:531)
>         at org.apache.cassandra.db.TreeMapBackedSortedColumns.addColumn(TreeMapBackedSortedColumns.java:90)
>         at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:116)
>         at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:128)
>         at org.apache.cassandra.db.RowMutation.add(RowMutation.java:144)
>         at org.apache.cassandra.db.RowMutation.add(RowMutation.java:154)
>         at org.apache.cassandra.triggers.InvertedIndex.augment(InvertedIndex.java:83)
>         at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:123)
>         at org.apache.cassandra.triggers.TriggerExecutor.execute(TriggerExecutor.java:73)
>         at org.apache.cassandra.service.StorageProxy.mutateWithTriggers(StorageProxy.java:567)
>         at org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition(ModificationStatement.java:379)
>         at org.apache.cassandra.cql3.statements.ModificationStatement.execute(ModificationStatement.java:363)
>         at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:129)
>         at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:145)
>         at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:136)
>         at org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1936)
>         at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4394)
>         at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4378)
>         at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
>         at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
>         at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:194)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>         at java.lang.Thread.run(Thread.java:722)



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Mime
View raw message