From 4088c68d38f5cbe8e86a7c6fa4630cb973f67d68 Mon Sep 17 00:00:00 2001 From: Ariel Weisberg Date: Thu, 15 Feb 2024 17:03:01 -0500 Subject: [PATCH] Add TODO for TxnQuery using wrong cluster metadata --- src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java b/src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java index 0742071b10..7afa75de16 100644 --- a/src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java +++ b/src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java @@ -216,6 +216,7 @@ public abstract class TxnQuery implements Query // and transaction statement will generate an error when it sees // the RetryOnNewProtocolResult PartitionKey partitionKey = (PartitionKey)keys.get(0); + // TODO (required): This is looking at ClusterMetadata, but not the ClusterMetadata for the specified epoch, just that epoch or later. Need to store ConsensusMigrationState in the global Topologies Accord stores for itself. return ConsensusRequestRouter.instance.isKeyInMigratingOrMigratedRangeFromAccord(epoch, partitionKey.table(), partitionKey.partitionKey()); } }