This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a commit to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cep-15-accord by this push:
new 0a20063f4c Accord: CassandraIndexTest failing after route to record
index rename
0a20063f4c is described below
commit 0a20063f4c29929cf247237e3f7f435f946b6e22
Author: David Capwell <[email protected]>
AuthorDate: Fri Jan 31 15:40:01 2025 -0800
Accord: CassandraIndexTest failing after route to record index rename
patch by David Capwell; reviewed by David Capwell, Jon Meredith for
CASSANDRA-20279
---
.../org/apache/cassandra/index/internal/CassandraIndexTest.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git
a/test/unit/org/apache/cassandra/index/internal/CassandraIndexTest.java
b/test/unit/org/apache/cassandra/index/internal/CassandraIndexTest.java
index 2fef97fd87..3b3ca94794 100644
--- a/test/unit/org/apache/cassandra/index/internal/CassandraIndexTest.java
+++ b/test/unit/org/apache/cassandra/index/internal/CassandraIndexTest.java
@@ -42,6 +42,7 @@ import
org.apache.cassandra.exceptions.InvalidRequestException;
import org.apache.cassandra.schema.ColumnMetadata;
import org.apache.cassandra.schema.SchemaConstants;
import org.apache.cassandra.schema.TableMetadata;
+import org.apache.cassandra.service.accord.AccordKeyspace;
import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.FBUtilities;
import org.awaitility.Awaitility;
@@ -569,25 +570,25 @@ public class CassandraIndexTest extends CQLTester
Awaitility.await()
.atMost(1, TimeUnit.MINUTES)
.pollDelay(1, TimeUnit.SECONDS)
- .untilAsserted(() ->
assertRows(execute(selectBuiltIndexesQuery), row("system",
"PaxosUncommittedIndex", null), row("system_accord", "route", null)));
+ .untilAsserted(() ->
assertRows(execute(selectBuiltIndexesQuery), row("system",
"PaxosUncommittedIndex", null), row("system_accord",
AccordKeyspace.JOURNAL_INDEX_NAME, null)));
String indexName = "build_remove_test_idx";
createTable("CREATE TABLE %s (a int, b int, c int, PRIMARY KEY (a,
b))");
createIndex(String.format("CREATE INDEX %s ON %%s(c)", indexName));
// check that there are no other rows in the built indexes table
- assertRows(execute(selectBuiltIndexesQuery), row(KEYSPACE, indexName,
null), row("system", "PaxosUncommittedIndex", null), row("system_accord",
"route", null));
+ assertRows(execute(selectBuiltIndexesQuery), row(KEYSPACE, indexName,
null), row("system", "PaxosUncommittedIndex", null), row("system_accord",
AccordKeyspace.JOURNAL_INDEX_NAME, null));
// rebuild the index and verify the built status table
getCurrentColumnFamilyStore().rebuildSecondaryIndex(indexName);
waitForIndexQueryable(indexName);
// check that there are no other rows in the built indexes table
- assertRows(execute(selectBuiltIndexesQuery), row(KEYSPACE, indexName,
null), row("system", "PaxosUncommittedIndex", null), row("system_accord",
"route", null));
+ assertRows(execute(selectBuiltIndexesQuery), row(KEYSPACE, indexName,
null), row("system", "PaxosUncommittedIndex", null), row("system_accord",
AccordKeyspace.JOURNAL_INDEX_NAME, null));
// check that dropping the index removes it from the built indexes
table
dropIndex("DROP INDEX %s." + indexName);
- assertRows(execute(selectBuiltIndexesQuery), row("system",
"PaxosUncommittedIndex", null), row("system_accord", "route", null));
+ assertRows(execute(selectBuiltIndexesQuery), row("system",
"PaxosUncommittedIndex", null), row("system_accord",
AccordKeyspace.JOURNAL_INDEX_NAME, null));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
