This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch cassandra-3.11
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cassandra-3.11 by this push:
new 02840c9 Don't validate index keys
02840c9 is described below
commit 02840c9006d382929a04c6b9891a5d5076199a0c
Author: Brandon Williams <[email protected]>
AuthorDate: Thu Sep 23 06:26:54 2021 -0500
Don't validate index keys
Patch by brandonwilliams; reviewed by bereng for CASSANDRA-16969
---
src/java/org/apache/cassandra/db/compaction/Scrubber.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/java/org/apache/cassandra/db/compaction/Scrubber.java
b/src/java/org/apache/cassandra/db/compaction/Scrubber.java
index c5c9d78..79f736b 100644
--- a/src/java/org/apache/cassandra/db/compaction/Scrubber.java
+++ b/src/java/org/apache/cassandra/db/compaction/Scrubber.java
@@ -190,7 +190,8 @@ public class Scrubber implements Closeable
try
{
ByteBuffer raw =
ByteBufferUtil.readWithShortLength(dataFile);
- cfs.metadata.getKeyValidator().validate(raw);
+ if (!cfs.metadata.isIndex())
+ cfs.metadata.getKeyValidator().validate(raw);
key = sstable.decorateKey(raw);
}
catch (Throwable th)
@@ -249,7 +250,8 @@ public class Scrubber implements Closeable
key = sstable.decorateKey(currentIndexKey);
try
{
-
cfs.metadata.getKeyValidator().validate(key.getKey());
+ if (!cfs.metadata.isIndex())
+
cfs.metadata.getKeyValidator().validate(key.getKey());
dataFile.seek(dataStartFromIndex);
if (tryAppend(prevKey, key, writer))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
