[
https://issues.apache.org/jira/browse/CASSANDRA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benjamin Lerer updated CASSANDRA-8018:
--------------------------------------
Attachment: CASSANDRA-8018.txt
The problem came from the fact that {{NodeBuilder}} was performing 2 calls to
{{UpdateFunction.apply}}.
The patch removes one of this call and add some unit tests to verify the
behavior.
> Cassandra seems to insert twice in custom PerColumnSecondaryIndex
> -----------------------------------------------------------------
>
> Key: CASSANDRA-8018
> URL: https://issues.apache.org/jira/browse/CASSANDRA-8018
> Project: Cassandra
> Issue Type: Bug
> Components: Core
> Reporter: Pavel Chlupacek
> Assignee: Benjamin Lerer
> Fix For: 2.1.3
>
> Attachments: CASSANDRA-8018.txt
>
>
> When inserting data into Cassandra 2.1.0 into table with custom secondary
> index, the Cell is inserted twice, if inserting new entry into row with same
> rowId, but different cluster index columns.
> ====
> CREATE KEYSPACE fulltext WITH replication = {'class': 'SimpleStrategy',
> 'replication_factor' : 1};
> CREATE TABLE fulltext.test ( id uuid, name text, name2 text, json varchar,
> lucene text, primary key ( id , name));
> s"CREATE CUSTOM INDEX lucene_idx on fulltext.test(lucene) using
> 'com.spinoco.fulltext.cassandra.TestIndex'; "
> // this causes only one insert
> insertInto("fulltext","test")
> .value("id", id1.uuid)
> .value("name", "goosh1")
> .value("json", TestContent.message1.asJson)
> // this causes 2 inserts to be done
> insertInto("fulltext","test")
> .value("id", id1.uuid)
> .value("name", "goosh2")
> .value("json", TestContent.message2.asJson)
> /// stacktraces for inserts (always same, for 1st and 2nd insert)
> <custom indexer stacktraces> and then
> at
> org.apache.cassandra.db.index.SecondaryIndexManager$StandardUpdater.insert(SecondaryIndexManager.java:707)
> at
> org.apache.cassandra.db.AtomicBTreeColumns$ColumnUpdater.apply(AtomicBTreeColumns.java:344)
> at
> org.apache.cassandra.db.AtomicBTreeColumns$ColumnUpdater.apply(AtomicBTreeColumns.java:319)
> at
> org.apache.cassandra.utils.btree.NodeBuilder.addNewKey(NodeBuilder.java:323)
> at
> org.apache.cassandra.utils.btree.NodeBuilder.update(NodeBuilder.java:191)
> at org.apache.cassandra.utils.btree.Builder.update(Builder.java:74)
> at org.apache.cassandra.utils.btree.BTree.update(BTree.java:186)
> at
> org.apache.cassandra.db.AtomicBTreeColumns.addAllWithSizeDelta(AtomicBTreeColumns.java:189)
> at org.apache.cassandra.db.Memtable.put(Memtable.java:194)
> at
> org.apache.cassandra.db.ColumnFamilyStore.apply(ColumnFamilyStore.java:1142)
> at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:394)
> at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:351)
> at org.apache.cassandra.db.Mutation.apply(Mutation.java:214)
> at
> org.apache.cassandra.service.StorageProxy$7.runMayThrow(StorageProxy.java:970)
> at
> org.apache.cassandra.service.StorageProxy$LocalMutationRunnable.run(StorageProxy.java:2080)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at
> org.apache.cassandra.concurrent.AbstractTracingAwareExecutorService$FutureTask.run(AbstractTracingAwareExecutorService.java:163)
> at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:103)
> at java.lang.Thread.run(Thread.java:744)
> //// Note that cell, rowkey and Group in public abstract void
> insert(ByteBuffer rowKey, Cell col, OpOrder.Group opGroup); are having for
> both successive calls same identity
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
