mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-3.11' into cassandra-4.0
This commit is contained in:
commit
80dccde3cd
|
|
@ -200,7 +200,8 @@ public class Scrubber implements Closeable
|
|||
try
|
||||
{
|
||||
ByteBuffer raw = ByteBufferUtil.readWithShortLength(dataFile);
|
||||
cfs.metadata.getLocal().partitionKeyType.validate(raw);
|
||||
if (!cfs.metadata.getLocal().isIndex())
|
||||
cfs.metadata.getLocal().partitionKeyType.validate(raw);
|
||||
key = sstable.decorateKey(raw);
|
||||
}
|
||||
catch (Throwable th)
|
||||
|
|
@ -260,7 +261,8 @@ public class Scrubber implements Closeable
|
|||
key = sstable.decorateKey(currentIndexKey);
|
||||
try
|
||||
{
|
||||
cfs.metadata.getLocal().partitionKeyType.validate(key.getKey());
|
||||
if (!cfs.metadata.getLocal().isIndex())
|
||||
cfs.metadata.getLocal().partitionKeyType.validate(key.getKey());
|
||||
dataFile.seek(dataStartFromIndex);
|
||||
|
||||
if (tryAppend(prevKey, key, writer))
|
||||
|
|
|
|||
Loading…
Reference in New Issue