You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2014/08/19 15:20:14 UTC
[1/3] git commit: Fix PRSI handling of CQL3 row markers for row
cleanup
Repository: cassandra
Updated Branches:
refs/heads/cassandra-2.1 69abfaaec -> d4ac8d59b
Fix PRSI handling of CQL3 row markers for row cleanup
patch by Berenguer Blasi; reviewed by Aleksey Yeschenko for
CASSANDRA-7787
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7554eb53
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7554eb53
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7554eb53
Branch: refs/heads/cassandra-2.1
Commit: 7554eb5316c63ef3eeda652e84daabed705eb5a8
Parents: 36382e5
Author: Berenguer Blasi <bb...@jblasi.com>
Authored: Tue Aug 19 16:12:19 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Aug 19 16:12:19 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 1 +
.../db/index/SecondaryIndexManager.java | 27 +++++++++-----------
2 files changed, 13 insertions(+), 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7554eb53/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 6c2ba2c..0ac1fb6 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
2.0.10
+ * Fix PRSI handling of CQL3 row markers for row cleanup (CASSANDRA-7787)
* (cqlsh) enable CTRL-R history search with libedit (CASSANDRA-7577)
* Fix dropping collection when it's the last regular column (CASSANDRA-7744)
* Properly reject operations on list index with conditions (CASSANDRA-7499)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7554eb53/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java b/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
index a15464a..a54882d 100644
--- a/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
+++ b/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
@@ -454,22 +454,19 @@ public class SecondaryIndexManager
for (Column column : indexedColumnsInRow)
{
- ColumnDefinition cDef = baseCfs.metadata.getColumnDefinitionFromColumnName(column.name());
- SecondaryIndex index = indexesByColumn.get(cDef.name);
- if (index == null)
- continue;
-
- if (index instanceof PerRowSecondaryIndex)
- {
- if (cleanedRowLevelIndexes == null)
- cleanedRowLevelIndexes = new HashSet<>();
-
- if (cleanedRowLevelIndexes.add(index.getClass()))
- ((PerRowSecondaryIndex)index).delete(key);
- }
- else
+ for (SecondaryIndex index : indexFor(column.name()))
{
- ((PerColumnSecondaryIndex) index).delete(key.key, column);
+ if (index instanceof PerRowSecondaryIndex)
+ {
+ if (cleanedRowLevelIndexes == null)
+ cleanedRowLevelIndexes = new HashSet<>();
+ if (cleanedRowLevelIndexes.add(index.getClass()))
+ ((PerRowSecondaryIndex) index).delete(key);
+ }
+ else
+ {
+ ((PerColumnSecondaryIndex) index).delete(key.key, column);
+ }
}
}
}
[3/3] git commit: Merge branch 'cassandra-2.1.0' into cassandra-2.1
Posted by al...@apache.org.
Merge branch 'cassandra-2.1.0' into cassandra-2.1
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d4ac8d59
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d4ac8d59
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d4ac8d59
Branch: refs/heads/cassandra-2.1
Commit: d4ac8d59b028895daab8b4e549a3d2ffdc033f3e
Parents: 69abfaa 579222e
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Aug 19 16:19:54 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Aug 19 16:19:54 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 2 +-
.../db/index/SecondaryIndexManager.java | 28 +++++++++-----------
2 files changed, 13 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d4ac8d59/CHANGES.txt
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d4ac8d59/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
----------------------------------------------------------------------
[2/3] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1.0
Posted by al...@apache.org.
Merge branch 'cassandra-2.0' into cassandra-2.1.0
Conflicts:
CHANGES.txt
src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/579222e9
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/579222e9
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/579222e9
Branch: refs/heads/cassandra-2.1
Commit: 579222e9d5e37dacaeb5f82a58211cfe5b0a3855
Parents: fabdd43 7554eb5
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Aug 19 16:19:12 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Aug 19 16:19:12 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 2 +-
.../db/index/SecondaryIndexManager.java | 28 +++++++++-----------
2 files changed, 13 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/579222e9/CHANGES.txt
----------------------------------------------------------------------
diff --cc CHANGES.txt
index 8aafd98,0ac1fb6..ca58708
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@@ -1,33 -1,16 +1,33 @@@
-2.0.10
+2.1.0
+ * Fix ordering of static cells (CASSANDRA-7763)
+Merged from 2.0:
+ * Fix PRSI handling of CQL3 row markers for row cleanup (CASSANDRA-7787)
- * (cqlsh) enable CTRL-R history search with libedit (CASSANDRA-7577)
* Fix dropping collection when it's the last regular column (CASSANDRA-7744)
* Properly reject operations on list index with conditions (CASSANDRA-7499)
-- * (Hadoop) allow ACFRW to limit nodes to local DC (CASSANDRA-7252)
+
+
+2.1.0-rc6
+ * Fix OOM issue from netty caching over time (CASSANDRA-7743)
+ * json2sstable couldn't import JSON for CQL table (CASSANDRA-7477)
+ * Invalidate all caches on table drop (CASSANDRA-7561)
+ * Skip strict endpoint selection for ranges if RF == nodes (CASSANRA-7765)
+ * Fix Thrift range filtering without 2ary index lookups (CASSANDRA-7741)
+ * Add tracing entries about concurrent range requests (CASSANDRA-7599)
+ * (cqlsh) Fix DESCRIBE for NTS keyspaces (CASSANDRA-7729)
+ * Remove netty buffer ref-counting (CASSANDRA-7735)
+ * Pass mutated cf to index updater for use by PRSI (CASSANDRA-7742)
+ * Include stress yaml example in release and deb (CASSANDRA-7717)
+ * workaround for netty issue causing corrupted data off the wire (CASSANDRA-7695)
+ * cqlsh DESC CLUSTER fails retrieving ring information (CASSANDRA-7687)
+ * Fix binding null values inside UDT (CASSANDRA-7685)
+ * Fix UDT field selection with empty fields (CASSANDRA-7670)
+ * Bogus deserialization of static cells from sstable (CASSANDRA-7684)
+ * Fix NPE on compaction leftover cleanup for dropped table (CASSANDRA-7770)
+Merged from 2.0:
* (cqlsh) Wait up to 10 sec for a tracing session (CASSANDRA-7222)
* Fix NPE in FileCacheService.sizeInBytes (CASSANDRA-7756)
- * (cqlsh) cqlsh should automatically disable tracing when selecting
- from system_traces (CASSANDRA-7641)
- * (Hadoop) Add CqlOutputFormat (CASSANDRA-6927)
- * Don't depend on cassandra config for nodetool ring (CASSANDRA-7508)
- * (cqlsh) Fix failing cqlsh formatting tests (CASSANDRA-7703)
+ * Remove duplicates from StorageService.getJoiningNodes (CASSANDRA-7478)
+ * Clone token map outside of hot gossip loops (CASSANDRA-7758)
* Fix MS expiring map timeout for Paxos messages (CASSANDRA-7752)
* Do not flush on truncate if durable_writes is false (CASSANDRA-7750)
* Give CRR a default input_cql Statement (CASSANDRA-7226)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/579222e9/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
index c184097,a54882d..07fd568
--- a/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
+++ b/src/java/org/apache/cassandra/db/index/SecondaryIndexManager.java
@@@ -472,25 -452,21 +472,21 @@@ public class SecondaryIndexManage
// Update entire row only once per row level index
Set<Class<? extends SecondaryIndex>> cleanedRowLevelIndexes = null;
- for (Column column : indexedColumnsInRow)
+ for (Cell cell : indexedColumnsInRow)
{
- // TODO: this is probably incorrect, we should pull all indexes
- ColumnDefinition cDef = baseCfs.metadata.getColumnDefinition(cell.name());
- SecondaryIndex index = indexesByColumn.get(cDef.name.bytes);
- if (index == null)
- continue;
-
- if (index instanceof PerRowSecondaryIndex)
- {
- if (cleanedRowLevelIndexes == null)
- cleanedRowLevelIndexes = new HashSet<>();
-
- if (cleanedRowLevelIndexes.add(index.getClass()))
- ((PerRowSecondaryIndex)index).delete(key, opGroup);
- }
- else
- for (SecondaryIndex index : indexFor(column.name()))
++ for (SecondaryIndex index : indexFor(cell.name()))
{
- ((PerColumnSecondaryIndex) index).delete(key.getKey(), cell, opGroup);
+ if (index instanceof PerRowSecondaryIndex)
+ {
+ if (cleanedRowLevelIndexes == null)
+ cleanedRowLevelIndexes = new HashSet<>();
+ if (cleanedRowLevelIndexes.add(index.getClass()))
- ((PerRowSecondaryIndex) index).delete(key);
++ ((PerRowSecondaryIndex) index).delete(key, opGroup);
+ }
+ else
+ {
- ((PerColumnSecondaryIndex) index).delete(key.key, column);
++ ((PerColumnSecondaryIndex) index).delete(key.getKey(), cell, opGroup);
+ }
}
}
}