adjust

Author: dnhatn

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

@@ -1566,7 +1566,8 @@ public BlockLoader.Block tryRead(
                     }
                     try (var doubles = factory.singletonDoubles(valueCount)) {
                         var longs = new SingletonLongToDoubleDelegate(doubles, toDouble);
-                        for (int index = firstIndex; index < lastIndex;) {
+                        for (int i = 0; i < valueCount; ) {
+                            final int index = firstIndex + i;
                             final int blockIndex = index >>> ES819TSDBDocValuesFormat.NUMERIC_BLOCK_SHIFT;
                             final int blockStartIndex = index & ES819TSDBDocValuesFormat.NUMERIC_BLOCK_MASK;
                             if (blockIndex != currentBlockIndex) {
@@ -1577,12 +1578,10 @@ public BlockLoader.Block tryRead(
                                 currentBlockIndex = blockIndex;
                                 decoder.decode(valuesData, currentBlock);
                             }
-                            final int count = Math.min(
-                                ES819TSDBDocValuesFormat.NUMERIC_BLOCK_SIZE - blockStartIndex,
-                                valueCount - (lastIndex - index)
-                            );
+                            // bulk convert from the
+                            final int count = Math.min(ES819TSDBDocValuesFormat.NUMERIC_BLOCK_SIZE - blockStartIndex, valueCount - i);
                             longs.appendLongs(currentBlock, blockStartIndex, count);
-                            index += count;
+                            i += count;
                         }
                         return doubles.build();
                     }

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/lucene/read/SingletonDoubleBuilder.java

@@ -65,6 +65,9 @@ public long estimatedBytes() {
 
     @Override
     public Block build() {
+        if (values.length != count) {
+            throw new IllegalStateException("expected " + values.length + " values but got " + count);
+        }
         return blockFactory.newDoubleArrayVector(values, count).asBlock();
     }