Skip to content

Commit af74e94

Browse files
committed
tweak
1 parent d594542 commit af74e94

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1830,6 +1830,7 @@ public long nextValue() throws IOException {
18301830
@Override
18311831
public void loadBlock(BlockLoader.LongBuilder builder, BlockLoader.Docs docs, int offset) throws IOException {
18321832
for (int i = offset; i < docs.count(); i++) {
1833+
set = false;
18331834
if (disi.advanceExact(docs.get(i))) {
18341835
set();
18351836
if (count == 1) {
@@ -1849,6 +1850,7 @@ public void loadBlock(BlockLoader.LongBuilder builder, BlockLoader.Docs docs, in
18491850

18501851
@Override
18511852
public void loadDoc(BlockLoader.LongBuilder builder, int docId) throws IOException {
1853+
set = false;
18521854
if (disi.advanceExact(docId)) {
18531855
set();
18541856
if (count == 1) {
@@ -1868,6 +1870,7 @@ public void loadDoc(BlockLoader.LongBuilder builder, int docId) throws IOExcepti
18681870
@Override
18691871
public void loadBlock(BlockLoader.IntBuilder builder, BlockLoader.Docs docs, int offset) throws IOException {
18701872
for (int i = offset; i < docs.count(); i++) {
1873+
set = false;
18711874
if (disi.advanceExact(docs.get(i))) {
18721875
set();
18731876
if (count == 1) {
@@ -1889,6 +1892,7 @@ public void loadBlock(BlockLoader.IntBuilder builder, BlockLoader.Docs docs, int
18891892

18901893
@Override
18911894
public void loadDoc(BlockLoader.IntBuilder builder, int docId) throws IOException {
1895+
set = false;
18921896
if (disi.advanceExact(docId)) {
18931897
set();
18941898
if (count == 1) {
@@ -1915,6 +1919,7 @@ public void loadBlock(
19151919
BlockDocValuesReader.ToDouble toDouble
19161920
) throws IOException {
19171921
for (int i = offset; i < docs.count(); i++) {
1922+
set = false;
19181923
if (disi.advanceExact(docs.get(i))) {
19191924
set();
19201925
if (count == 1) {
@@ -1935,6 +1940,7 @@ public void loadBlock(
19351940
@Override
19361941
public void loadDoc(BlockLoader.DoubleBuilder builder, int docId, BlockDocValuesReader.ToDouble toDouble)
19371942
throws IOException {
1943+
set = false;
19381944
if (disi.advanceExact(docId)) {
19391945
set();
19401946
if (count == 1) {

0 commit comments

Comments
 (0)