Skip to content

Commit 9ac697c

Browse files
committed
Remove double write of field to binary entry
1 parent ddabd49 commit 9ac697c

File tree

2 files changed

+5
-8
lines changed

2 files changed

+5
-8
lines changed

server/src/main/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesConsumer.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,6 @@ final class ES819TSDBDocValuesConsumer extends XDocValuesConsumer {
6969
private final int skipIndexIntervalSize;
7070
final boolean enableOptimizedMerge;
7171
private final BinaryDVCompressionMode binaryDVCompressionMode;
72-
private final SegmentWriteState state;
7372

7473
ES819TSDBDocValuesConsumer(
7574
SegmentWriteState state,
@@ -83,7 +82,6 @@ final class ES819TSDBDocValuesConsumer extends XDocValuesConsumer {
8382
) throws IOException {
8483
this.termsDictBuffer = new byte[1 << 14];
8584
this.binaryDVCompressionMode = binaryDVCompressionMode;
86-
this.state = state;
8785
this.dir = state.directory;
8886
this.context = state.context;
8987
boolean success = false;
@@ -290,9 +288,6 @@ public void addBinaryField(FieldInfo field, DocValuesProducer valuesProducer) th
290288
}
291289

292290
public void doAddUncompressedBinary(FieldInfo field, DocValuesProducer valuesProducer) throws IOException {
293-
meta.writeInt(field.number);
294-
meta.writeByte(ES819TSDBDocValuesFormat.BINARY);
295-
296291
if (valuesProducer instanceof TsdbDocValuesProducer tsdbValuesProducer && tsdbValuesProducer.mergeStats.supported()) {
297292
final int numDocsWithField = tsdbValuesProducer.mergeStats.sumNumDocsWithField();
298293
final int minLength = tsdbValuesProducer.mergeStats.minLength();
@@ -530,6 +525,8 @@ public void doAddCompressedBinaryFSST(FieldInfo field, DocValuesProducer valuesP
530525
sampler.processLine(v.bytes, v.offset, v.length);
531526
}
532527

528+
assert maxLength >= minLength : "maxLength [" + maxLength + "] < minLength [" + minLength + "]";
529+
533530
// Build encoder from sample
534531
FSST.SymbolTable symbolTable = FSST.SymbolTable.buildSymbolTable(sampler.getSample());
535532

@@ -539,7 +536,6 @@ public void doAddCompressedBinaryFSST(FieldInfo field, DocValuesProducer valuesP
539536
if (numDocsWithField > 0 && numDocsWithField < maxDoc) {
540537
disiAccumulator = new DISIAccumulator(dir, context, data, IndexedDISI.DEFAULT_DENSE_RANK_POWER);
541538
}
542-
assert maxLength >= minLength;
543539
offsetsAccumulator = new OffsetsAccumulator(dir, context, data, numDocsWithField);
544540
CompressedOffsetWriter offsetWriter = new CompressedOffsetWriter(offsetsAccumulator);
545541

server/src/main/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesProducer.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1566,13 +1566,14 @@ static class BinaryEntry {
15661566
long addressesLength;
15671567
DirectMonotonicReader.Meta addressesMeta;
15681568

1569+
// Compression
1570+
final BinaryDVCompressionMode compression;
1571+
15691572
// FSST
15701573
int minCompressedLength;
15711574
int maxCompressedLength;
15721575
FSST.Decoder decoder;
15731576

1574-
// Compression
1575-
final BinaryDVCompressionMode compression;
15761577

15771578
private BinaryEntry(BinaryDVCompressionMode compression) {
15781579
this.compression = compression;

0 commit comments

Comments
 (0)