Conditionally update index build status Patch by Corentin Chary; reviewed by Sam Tunnicliffe for CASSANDRA-12969
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/afbc2e85 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/afbc2e85 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/afbc2e85 Branch: refs/heads/trunk Commit: afbc2e8502a8a8d1d6a319017dfc3c2a45bebaca Parents: 918a062 Author: Corentin Chary <c.ch...@criteo.com> Authored: Mon Nov 28 16:23:01 2016 +0100 Committer: Sam Tunnicliffe <s...@beobal.com> Committed: Mon Dec 5 11:20:51 2016 +0000 ---------------------------------------------------------------------- CHANGES.txt | 1 + src/java/org/apache/cassandra/db/SystemKeyspace.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/afbc2e85/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 5a3fedf..3d27690 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.12 + * Conditionally update index built status to avoid unnecessary flushes (CASSANDRA-12969) * NoReplicationTokenAllocator should work with zero replication factor (CASSANDRA-12983) * cqlsh auto completion: refactor definition of compaction strategy options (CASSANDRA-12946) * Add support for arithmetic operators (CASSANDRA-11935) http://git-wip-us.apache.org/repos/asf/cassandra/blob/afbc2e85/src/java/org/apache/cassandra/db/SystemKeyspace.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/SystemKeyspace.java b/src/java/org/apache/cassandra/db/SystemKeyspace.java index 31a461b..aac424d 100644 --- a/src/java/org/apache/cassandra/db/SystemKeyspace.java +++ b/src/java/org/apache/cassandra/db/SystemKeyspace.java @@ -1043,7 +1043,7 @@ public final class SystemKeyspace public static void setIndexBuilt(String keyspaceName, String indexName) { - String req = "INSERT INTO %s.\"%s\" (table_name, index_name) VALUES (?, ?)"; + String req = "INSERT INTO %s.\"%s\" (table_name, index_name) VALUES (?, ?) IF NOT EXISTS;"; executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_INDEXES), keyspaceName, indexName); forceBlockingFlush(BUILT_INDEXES); }