diff --git a/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java b/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java index e27cdc20e7..a66dbc1adb 100644 --- a/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java +++ b/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java @@ -605,7 +605,10 @@ public class TxnRead extends AbstractKeySorted implements Read TxnNamedRead[] items = deserializeArray(tablesAndKeys, in, version, TxnNamedRead.serializer, TxnNamedRead[]::new); ConsistencyLevel consistencyLevel = deserializeNullable(in, consistencyLevelSerializer); ImportMetadata importMetadata = deserializeNullable(in, version, ImportMetadata.serializer); - return new TxnRead(tablesAndKeys.tables, items, consistencyLevel, importMetadata); + if (items.length == 0) + return new TxnRead(TableMetadatas.none(), Domain.Range, importMetadata); + else + return new TxnRead(tablesAndKeys.tables, items, consistencyLevel, importMetadata); } } }