This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new abe2a989736 branch-4.1: [test](ann) move ann index-only-scan to
deterministic debug-point tests (backport subset of #64525) (#64603)
abe2a989736 is described below
commit abe2a989736a3145e6accf4619ae38a4de998dae
Author: shuke <[email protected]>
AuthorDate: Wed Jun 17 20:56:20 2026 +0800
branch-4.1: [test](ann) move ann index-only-scan to deterministic
debug-point tests (backport subset of #64525) (#64603)
## What problem does this PR solve?
Back-ports the **ANN index-only-scan test rework** from branch-4.0
#64525 to
branch-4.1. On 4.1 Cloud-P0 the two ann cases are muted-but-flaky
because they
assert on **profile scan-bytes equality**, which is non-deterministic.
This rework (matching 4.0) **removes the flaky Cloud-P0 cases**
(`ann_index_only_scan`, `ann_index_only_scan_distance_expr`,
`ann_index_only_scan_metric_direction` + its `.out`) and replaces the
coverage
with **deterministic `nonConcurrent` debug-point tests** that force the
index-only path via
`GetDebugPoint().enableDebugPointForAllBEs("segment_iterator._read_columns_by_index",
...)`.
Verified the debug point `segment_iterator._read_columns_by_index`
already
exists on branch-4.1 (`be/src/storage/segment/segment_iterator.cpp`),
and the
ANN range-search product fix (#63965) is already on 4.1, so the new
tests are
runnable here. **Test-only change (no FE/BE code).**
Complements #64597 (the other Cloud-P0 deflake backports).
## Cherry-picked from branch-4.0 #64525 (with `-x` provenance)
- `[test](regression) Add debug point ANN index-only scan test (#63859)`
- `[fix](test) drop unsupported enable_condition_cache var in
ann_index_only_scan debug_point cases`
- `[fix](test) drop unsupported enable_condition_cache var in
ann_range_search cases`
## Not included (separate follow-up)
- `[fix](compaction) let time_series_level2_file_count debug point
bypass …` — touches BE
(`cumulative_compaction_time_series_policy.cpp`, which moved to
`be/src/storage/compaction/`
on 4.1 due to the BE dir refactor #61595), so it needs a manual port + a
remote compile
verification before submitting; handled separately.
## Release note
None
🤖 Generated with [Claude Code](https://claude.com/claude-code)
---------
Co-authored-by: zhiqiang <[email protected]>
Co-authored-by: morningman <[email protected]>
Co-authored-by: Claude Opus 4.8 <[email protected]>
---
.../data/ann_index_p0/ann_index_only_scan.out | 19 -
.../suites/ann_index_p0/ann_index_only_scan.groovy | 450 ---------------------
...ann_index_only_scan_compound_debug_point.groovy | 158 ++++++++
.../ann_index_only_scan_debug_point.groovy | 237 +++++++++++
.../ann_index_only_scan_distance_expr.groovy | 207 ----------
.../ann_index_only_scan_expr_debug_point.groovy | 104 +++++
.../ann_index_only_scan_metric_direction.groovy | 229 -----------
.../ann_range_search_pushdown_regression.groovy | 1 -
...ge_search_source_index_status_regression.groovy | 1 -
9 files changed, 499 insertions(+), 907 deletions(-)
diff --git a/regression-test/data/ann_index_p0/ann_index_only_scan.out
b/regression-test/data/ann_index_p0/ann_index_only_scan.out
deleted file mode 100644
index cb1c0d98a59..00000000000
--- a/regression-test/data/ann_index_p0/ann_index_only_scan.out
+++ /dev/null
@@ -1,19 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !q1 --
-0 ann_index_only_scan_q1
-5 ann_index_only_scan_q1
-6 ann_index_only_scan_q1
-2 ann_index_only_scan_q1
-9 ann_index_only_scan_q1
-8 ann_index_only_scan_q1
-4 ann_index_only_scan_q1
-
--- !q2 --
-0 ann_index_only_scan_q2 81.69191
-5 ann_index_only_scan_q2 90.8576
-6 ann_index_only_scan_q2 111.234
-2 ann_index_only_scan_q2 116.7573
-9 ann_index_only_scan_q2 122.1707
-8 ann_index_only_scan_q2 130.5337
-4 ann_index_only_scan_q2 136.0021
-
diff --git a/regression-test/suites/ann_index_p0/ann_index_only_scan.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan.groovy
deleted file mode 100644
index 743db656260..00000000000
--- a/regression-test/suites/ann_index_p0/ann_index_only_scan.groovy
+++ /dev/null
@@ -1,450 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import groovy.json.JsonSlurper
-
-
-def getProfileList = {
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst + "/rest/v1/query_profile").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-def getProfile = { id ->
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst +
"/api/profile/text/?query_id=$id").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-suite("ann_index_only_scan") {
- sql "drop table if exists ann_index_only_scan"
- sql "unset variable all;"
- sql "set profile_level=2;"
- sql "set enable_profile=true;"
- sql "set experimental_enable_virtual_slot_for_cse=true;"
- sql "set parallel_pipeline_task_num=1;"
- sql "set enable_sql_cache=false;"
-
-
- sql """
- create table ann_index_only_scan (
- id int not null,
- embedding array<float> not null,
- comment String not null,
- value int null,
- INDEX idx_comment(`comment`) USING INVERTED PROPERTIES("parser" =
"english") COMMENT 'inverted index for comment',
- INDEX ann_embedding(`embedding`) USING ANN
PROPERTIES("index_type"="hnsw","metric_type"="l2_distance","dim"="8")
- ) duplicate key (`id`)
- distributed by hash(`id`) buckets 1
- properties("replication_num"="1");
- """
-
- sql """
- INSERT INTO ann_index_only_scan (id, embedding, comment, value) VALUES
- (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687,
10.162686, 36.335983, 38.684258], "This example illustrates how subtle
differences can influence perception. It's more about interpretation than right
or wrong.", 100),
- (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715,
72.64085, 9.688437, 17.721428], "Thanks for all the comments, good and bad.
They help us refine our test. Keep in mind that we're attempting to figure you
out in 40 pairs of pictures. We did this so that lots of people could take it,
just to introduce the idea.<p>A <i>real</i> test would have more like 200
pairs, which is what the YC founders took when we assessed their attributes in
the first place.", 101),
- (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135,
72.080734, 85.71118, 99.35976], "At a glance, these might seem obvious, but
there’s nuance in every choice. Don’t rush.", 102),
- (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], "We're testing how consistent your judgments are over a
range of visual impressions. There's no single 'correct' answer.", 103),
- (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106,
79.39356, 63.014366, 68.67834], "Some pairs are meant to be tricky. Your
intuition is part of what we're analyzing.", 104),
- (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], "This data will help us identify patterns in how people
perceive attributes such as trustworthiness or confidence.", 105),
- (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], "Sometimes people see entirely different things in the
same image. That's part of the exploration.", 106),
- (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274,
40.286068, 11.943586, 3.69409], "Don't worry if you’re unsure. The ambiguity is
intentional — that’s what makes this interesting.", 107),
- (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627,
33.388138, 11.076194, 20.480877], "Your reactions help us understand which
features people subconsciously favor or avoid.", 108),
- (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595,
48.04684, 71.29212, 30.282396], "This task isn’t about right answers, but about
consistency in your judgments over time.", 109);
- """
-
- // Fetch profile text by token with small retries for robustness
- def getProfileWithToken = { token ->
- String profileId = ""
- int attempts = 0
- while (attempts < 10 && (profileId == null || profileId == "")) {
- List profileData = new
JsonSlurper().parseText(getProfileList()).data.rows
- for (def profileItem in profileData) {
- if (profileItem["Sql Statement"].toString().contains(token)) {
- profileId = profileItem["Profile ID"].toString()
- break
- }
- }
- if (profileId == null || profileId == "") {
- Thread.sleep(300)
- }
- attempts++
- }
- assertTrue(profileId != null && profileId != "")
- // ensure profile text is fully ready
- Thread.sleep(800)
- return getProfile(profileId).toString()
- }
-
- def extractScanBytesValue = { String profileText ->
- // Example line: "- ScanBytes: 80.00 B"
- def lines = profileText.split("\n")
- for (def line : lines) {
- if (line.contains("ScanBytes:")) {
- // allow optional unit (e.g. "B"); sometimes profile prints no
unit for 0 bytes
- def m = (line =~
/ScanBytes:\s*([0-9]+(?:\.[0-9]+)?)(?:\s*([A-Za-z]+))?/)
- if (m.find()) {
- return m.group(1)
- }
- }
- }
- return null
- }
-
- // Helper to execute two query shapes (one plain, one with embedding) and
return their ScanBytes values
- def runAndGetScanBytesPair = {
- def t1 = UUID.randomUUID().toString()
- sql """
- select id, "${t1}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- order by dist
- limit 7;
- """
- def t2 = UUID.randomUUID().toString()
- sql """
- select id, "${t2}", embedding,
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- order by dist
- limit 7;
- """
- def pA = getProfileWithToken(t1)
- def pB = getProfileWithToken(t2)
- def sA = extractScanBytesValue(pA)
- def sB = extractScanBytesValue(pB)
- assertTrue(sA != null && sB != null)
- return [sA, sB]
- }
-
- // enable index-only read path
- sql "set enable_no_need_read_data_opt=true;"
- def pair1 = runAndGetScanBytesPair()
- logger.info("ScanBytes enabled: q1=${pair1[0]}, q2=${pair1[1]}")
- // ScanBytes of q1 and q2 should not be same. since q2 reads embedding
column, q1 will not read embedding column in t
- assertTrue(pair1[0] != pair1[1])
-
- // disable index-only read path, expect different ScanBytes
- sql "set enable_no_need_read_data_opt=false;"
- def pair2 = runAndGetScanBytesPair()
- logger.info("ScanBytes disabled: q1=${pair2[0]}, q2=${pair2[1]}")
- assertTrue(pair2[0] == pair2[1])
-
- // 1) ANN range search: compare with/without selecting distance
- sql "set enable_no_need_read_data_opt=true;"
- sql "set experimental_enable_virtual_slot_for_cse=true;"
- def tR1 = UUID.randomUUID().toString()
- sql """
- select id, "${tR1}" from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 105.66439056396484
- order by id
- limit 20;
- """
- def tR2 = UUID.randomUUID().toString()
- sql """
- select id, "${tR2}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 105.66439056396484
- order by id
- limit 20;
- """
- def pR1 = getProfileWithToken(tR1)
- def pR2 = getProfileWithToken(tR2)
- def sR1 = extractScanBytesValue(pR1)
- def sR2 = extractScanBytesValue(pR2)
- logger.info("ScanBytes range enabled: q1=${sR1}, q2=${sR2}")
- assertTrue(sR1 == sR2)
-
- tR1 = UUID.randomUUID().toString()
- tR2 = UUID.randomUUID().toString()
- // No virtual slot. So result distance is not needed by any one, even if
it is calculated by index.
- // So we do not need to read embedding column.
- sql """
- select id, "${tR1}" from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 105.66439056396484
- order by id
- limit 20;
- """
- // if condition is not lt_or_le, index will only return rowid without
distance value
- // so we still need to read embedding column.
- sql """
- select id, "${tR2}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 105.66439056396484
- order by id
- limit 20;
- """
- pR1 = getProfileWithToken(tR1)
- pR2 = getProfileWithToken(tR2)
- sR1 = extractScanBytesValue(pR1)
- sR2 = extractScanBytesValue(pR2)
- logger.info("ScanBytes range enabled (neg): q1=${sR1}, q2=${sR2}")
- assertTrue(sR1 != sR2)
-
- // 2) ANN with inverted index together: add comment MATCH_ANY filter
- def tRI1 = UUID.randomUUID().toString()
- sql """
- select id, "${tRI1}" from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 150.0
- and comment match_any 'people'
- order by id
- limit 20;
- """
- def tRI2 = UUID.randomUUID().toString()
- sql """
- select id, "${tRI2}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 150.0
- and comment match_any 'people'
- order by id
- limit 20;
- """
- def pRI1 = getProfileWithToken(tRI1)
- def pRI2 = getProfileWithToken(tRI2)
- def sRI1 = extractScanBytesValue(pRI1)
- def sRI2 = extractScanBytesValue(pRI2)
- logger.info("ScanBytes range+inverted enabled: q1=${sRI1}, q2=${sRI2}")
- assertTrue(sRI1 == sRI2)
- // Negative: project non-index column to force base read
- def tRIN1 = UUID.randomUUID().toString()
- sql """
- select id, "${tRIN1}" from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 150.0
- and comment match_any 'people'
- order by id
- limit 20;
- """
- def tRIN2 = UUID.randomUUID().toString()
- sql """
- select id, "${tRIN2}", comment
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 150.0
- and comment match_any 'people'
- order by id
- limit 20;
- """
- def pRIN1 = getProfileWithToken(tRIN1)
- def pRIN2 = getProfileWithToken(tRIN2)
- def sRIN1 = extractScanBytesValue(pRIN1)
- def sRIN2 = extractScanBytesValue(pRIN2)
- logger.info("ScanBytes range+inverted neg: q1=${sRIN1}, q2=${sRIN2}")
- assertTrue(sRIN1 != sRIN2)
-
- // 3) Range + TopN simultaneously
- def tRT1 = UUID.randomUUID().toString()
- sql """
- select id, "${tRT1}" from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 200.0
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def tRT2 = UUID.randomUUID().toString()
- sql """
- select id, "${tRT2}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 200.0
- order by dist
- limit 5;
- """
- def pRT1 = getProfileWithToken(tRT1)
- def pRT2 = getProfileWithToken(tRT2)
- def sRT1 = extractScanBytesValue(pRT1)
- def sRT2 = extractScanBytesValue(pRT2)
- logger.info("ScanBytes range+topn enabled: q1=${sRT1}, q2=${sRT2}")
- assertTrue(sRT1 == sRT2)
-
- // 4) Ensure no index: same queries should not error on a table without
ANN index
- sql """
- DROP TABLE IF EXISTS ann_index_only_scan_no_ann;
- """
- sql """
- CREATE TABLE ann_index_only_scan_no_ann (
- id int not null,
- embedding array<float> not null,
- comment String not null,
- value int null
- ) duplicate key (`id`)
- distributed by hash(`id`) buckets 1
- properties("replication_num"="1");
- """
- sql """
- INSERT INTO ann_index_only_scan_no_ann (id, embedding, comment, value)
VALUES
- (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687,
10.162686, 36.335983, 38.684258], "A", 100),
- (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715,
72.64085, 9.688437, 17.721428], "B", 101),
- (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135,
72.080734, 85.71118, 99.35976], "C", 102);
- """
- // Just execute; if there is no error, it's fine
- sql """
- select id from ann_index_only_scan_no_ann
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
limit 2;
- """
- sql """
- select id from ann_index_only_scan_no_ann
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 999.0 order by id;
- """
-
- // 5) TopN + IndexFilter (inverted): index-only should apply when not
projecting non-index columns
- sql "set enable_no_need_read_data_opt=true;"
- def tTI1 = UUID.randomUUID().toString()
- sql """
- select id, "${tTI1}"
- from ann_index_only_scan
- where comment match_any 'people'
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def tTI2 = UUID.randomUUID().toString()
- sql """
- select id, "${tTI2}", comment
- from ann_index_only_scan
- where comment match_any 'people'
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def pTI1 = getProfileWithToken(tTI1)
- def pTI2 = getProfileWithToken(tTI2)
- def sTI1 = extractScanBytesValue(pTI1)
- def sTI2 = extractScanBytesValue(pTI2)
- logger.info("ScanBytes topn+inverted: q1=${sTI1}, q2=${sTI2}")
- assertTrue(sTI1 != sTI2)
-
- // 6) TopN + Range + IndexFilter
- def tTRI1 = UUID.randomUUID().toString()
- sql """
- select id, "${tTRI1}"
- from ann_index_only_scan
- where comment match_any 'people'
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 200.0
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def tTRI2 = UUID.randomUUID().toString()
- sql """
- select id, "${tTRI2}", comment
- from ann_index_only_scan
- where comment match_any 'people'
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
< 200.0
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def pTRI1 = getProfileWithToken(tTRI1)
- def pTRI2 = getProfileWithToken(tTRI2)
- def sTRI1 = extractScanBytesValue(pTRI1)
- def sTRI2 = extractScanBytesValue(pTRI2)
- logger.info("ScanBytes topn+range+inverted: q1=${sTRI1}, q2=${sTRI2}")
- assertTrue(sTRI1 != sTRI2)
-
- // 7) Range + proj + no-dist-from-index (gt/ ge): toggling the opt should
have no effect
- sql "set enable_no_need_read_data_opt=true;"
- def tRN1 = UUID.randomUUID().toString()
- sql """
- select id, "${tRN1}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 100.0
- order by id
- limit 20;
- """
- def pRN1 = getProfileWithToken(tRN1)
- def sRN1 = extractScanBytesValue(pRN1)
- sql "set enable_no_need_read_data_opt=false;"
- def tRN2 = UUID.randomUUID().toString()
- sql """
- select id, "${tRN2}",
- l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
as dist
- from ann_index_only_scan
- where l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 100.0
- order by id
- limit 20;
- """
- def pRN2 = getProfileWithToken(tRN2)
- def sRN2 = extractScanBytesValue(pRN2)
- logger.info("ScanBytes range(gt)+proj opt-toggle: on=${sRN1}, off=${sRN2}")
- assertTrue(sRN1 == sRN2)
-
- // 8) TopN + Range + CommonFilter (array_size on embedding): opt toggle
should have no effect
- sql "set enable_no_need_read_data_opt=true;"
- def tCF1 = UUID.randomUUID().toString()
- sql """
- select id, "${tCF1}"
- from ann_index_only_scan
- where array_size(embedding) > 5
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 100.0
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def pCF1 = getProfileWithToken(tCF1)
- def sCF1 = extractScanBytesValue(pCF1)
- sql "set enable_no_need_read_data_opt=false;"
- def tCF2 = UUID.randomUUID().toString()
- sql """
- select id, "${tCF2}"
- from ann_index_only_scan
- where array_size(embedding) > 5
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
> 100.0
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def pCF2 = getProfileWithToken(tCF2)
- def sCF2 = extractScanBytesValue(pCF2)
- logger.info("ScanBytes topn+range+common-filter opt-toggle: on=${sCF1},
off=${sCF2}")
- assertTrue(sCF1 == sCF2)
-
- // 9) CSE: multiple uses of distance in predicates should still allow
index-only
- sql "set enable_no_need_read_data_opt=true;"
- sql "set experimental_enable_virtual_slot_for_cse=true;"
- def tCSE1 = UUID.randomUUID().toString()
- sql """
- select id, "${tCSE1}"
- from ann_index_only_scan
- where abs(l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
+ 10) > 10
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
<= 150
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def tCSE2 = UUID.randomUUID().toString()
- sql """
- select id, "${tCSE2}", embedding
- from ann_index_only_scan
- where abs(l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
+ 10) > 10
- and l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
<= 150
- order by l2_distance_approximate(embedding,
[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031])
- limit 5;
- """
- def pCSE1 = getProfileWithToken(tCSE1)
- def pCSE2 = getProfileWithToken(tCSE2)
- def sCSE1 = extractScanBytesValue(pCSE1)
- def sCSE2 = extractScanBytesValue(pCSE2)
- logger.info("ScanBytes CSE (no-embed vs embed): q1=${sCSE1}, q2=${sCSE2}")
- // NOTE: currently, CSE with virtual slot still needs to read embedding
column when not projecting it.
- // Since we do not check if src column of some expr has been
materializated.
- // For example, althrough dist column has been calculated by
l2_distance_approximate < 150 in the form of virtual slot,
- // but when evaluating abs(dist + 10) > 10, we still need to read
embedding column, eventhough dist will not be calculated again.
- assertTrue(sCSE1 == sCSE2)
-}
\ No newline at end of file
diff --git
a/regression-test/suites/ann_index_p0/ann_index_only_scan_compound_debug_point.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan_compound_debug_point.groovy
new file mode 100644
index 00000000000..89482e14856
--- /dev/null
+++
b/regression-test/suites/ann_index_p0/ann_index_only_scan_compound_debug_point.groovy
@@ -0,0 +1,158 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("ann_index_only_scan_compound_debug_point", "nonConcurrent") {
+ sql "unset variable all;"
+ sql "set enable_common_expr_pushdown=true;"
+ sql "set experimental_enable_virtual_slot_for_cse=true;"
+ sql "set enable_no_need_read_data_opt=true;"
+ sql "set parallel_pipeline_task_num=1;"
+ sql "set enable_sql_cache=false;"
+
+ sql "drop table if exists ann_index_only_scan_compound_debug_point"
+ sql """
+ create table ann_index_only_scan_compound_debug_point (
+ id int not null,
+ embedding array<float> not null,
+ comment string not null,
+ value int null,
+ index idx_comment(`comment`) using inverted properties("parser" =
"english"),
+ index ann_embedding(`embedding`) using ann properties(
+ "index_type"="hnsw",
+ "metric_type"="l2_distance",
+ "dim"="8"
+ )
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_compound_debug_point values
+ (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687, 10.162686,
36.335983, 38.684258], 'alpha people', 100),
+ (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715, 72.64085,
9.688437, 17.721428], 'beta people', 101),
+ (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135, 72.080734,
85.71118, 99.35976], 'gamma', 102),
+ (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], 'delta', 103),
+ (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106, 79.39356,
63.014366, 68.67834], 'epsilon', 104),
+ (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], 'zeta people', 105),
+ (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], 'eta', 106),
+ (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274, 40.286068,
11.943586, 3.69409], 'theta', 107),
+ (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627, 33.388138,
11.076194, 20.480877], 'iota', 108),
+ (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595, 48.04684,
71.29212, 30.282396], 'kappa', 109);
+ """
+
+ def v =
"[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031]"
+
+ try {
+ GetDebugPoint().enableDebugPointForAllBEs(
+ "segment_iterator._read_columns_by_index", [column_name:
"embedding"])
+
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 200.0
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ sql """
+ select id, l2_distance_approximate(embedding, ${v}) as dist
+ from ann_index_only_scan_compound_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 200.0
+ order by dist
+ limit 5;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ and l2_distance_approximate(embedding, ${v}) < 200.0
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ test {
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where abs(l2_distance_approximate(embedding, ${v}) + 10) > 10
+ and l2_distance_approximate(embedding, ${v}) <= 150
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+ exception "does not need to read data"
+ }
+ } finally {
+
GetDebugPoint().disableDebugPointForAllBEs("segment_iterator._read_columns_by_index")
+ }
+
+ try {
+ GetDebugPoint().enableDebugPointForAllBEs(
+ "segment_iterator._read_columns_by_index", [column_name:
"comment"])
+
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ and l2_distance_approximate(embedding, ${v}) < 200.0
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ test {
+ sql """
+ select id, comment
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+ exception "does not need to read data"
+ }
+
+ test {
+ sql """
+ select id, comment
+ from ann_index_only_scan_compound_debug_point
+ where comment match_any 'people'
+ and l2_distance_approximate(embedding, ${v}) < 200.0
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+ exception "does not need to read data"
+ }
+ } finally {
+
GetDebugPoint().disableDebugPointForAllBEs("segment_iterator._read_columns_by_index")
+ }
+}
diff --git
a/regression-test/suites/ann_index_p0/ann_index_only_scan_debug_point.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan_debug_point.groovy
new file mode 100644
index 00000000000..96fb5514e7e
--- /dev/null
+++ b/regression-test/suites/ann_index_p0/ann_index_only_scan_debug_point.groovy
@@ -0,0 +1,237 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("ann_index_only_scan_debug_point", "nonConcurrent") {
+ sql "unset variable all;"
+ sql "set enable_common_expr_pushdown=true;"
+ sql "set experimental_enable_virtual_slot_for_cse=true;"
+ sql "set enable_no_need_read_data_opt=true;"
+ sql "set parallel_pipeline_task_num=1;"
+ sql "set enable_sql_cache=false;"
+
+ sql "drop table if exists ann_index_only_scan_debug_point"
+ sql """
+ create table ann_index_only_scan_debug_point (
+ id int not null,
+ embedding array<float> not null,
+ comment string not null,
+ value int null,
+ index idx_comment(`comment`) using inverted properties("parser" =
"english"),
+ index ann_embedding(`embedding`) using ann properties(
+ "index_type"="hnsw",
+ "metric_type"="l2_distance",
+ "dim"="8"
+ )
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_debug_point values
+ (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687, 10.162686,
36.335983, 38.684258], 'alpha people', 100),
+ (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715, 72.64085,
9.688437, 17.721428], 'beta people', 101),
+ (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135, 72.080734,
85.71118, 99.35976], 'gamma', 102),
+ (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], 'delta', 103),
+ (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106, 79.39356,
63.014366, 68.67834], 'epsilon', 104),
+ (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], 'zeta people', 105),
+ (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], 'eta', 106),
+ (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274, 40.286068,
11.943586, 3.69409], 'theta', 107),
+ (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627, 33.388138,
11.076194, 20.480877], 'iota', 108),
+ (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595, 48.04684,
71.29212, 30.282396], 'kappa', 109);
+ """
+
+ sql "drop table if exists ann_index_only_scan_remap_debug_point"
+ sql """
+ create table ann_index_only_scan_remap_debug_point (
+ id int not null,
+ pad_int int not null,
+ pad_text string not null,
+ embedding array<float> not null,
+ value int not null,
+ index ann_embedding(`embedding`) using ann properties(
+ "index_type"="hnsw",
+ "metric_type"="l2_distance",
+ "dim"="3"
+ )
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_remap_debug_point values
+ (1, 10, 'a', [0.0, 0.0, 0.0], 100),
+ (2, 20, 'b', [0.1, 0.0, 0.0], 200),
+ (3, 30, 'c', [0.2, 0.0, 0.0], 300),
+ (4, 40, 'd', [0.3, 0.0, 0.0], 400),
+ (5, 50, 'e', [0.4, 0.0, 0.0], 500),
+ (6, 60, 'f', [0.5, 0.0, 0.0], 600),
+ (7, 70, 'g', [0.6, 0.0, 0.0], 700),
+ (8, 80, 'h', [0.7, 0.0, 0.0], 800),
+ (9, 90, 'i', [0.8, 0.0, 0.0], 900),
+ (10, 100, 'j', [0.9, 0.0, 0.0], 1000);
+ """
+
+ sql "drop table if exists ann_index_only_scan_ip_debug_point"
+ sql """
+ create table ann_index_only_scan_ip_debug_point (
+ id int not null,
+ embedding array<float> not null,
+ value int null,
+ index ann_embedding(`embedding`) using ann properties(
+ "index_type"="hnsw",
+ "metric_type"="inner_product",
+ "dim"="8"
+ )
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_ip_debug_point
+ select id, embedding, value from ann_index_only_scan_debug_point;
+ """
+
+ def v =
"[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031]"
+
+ try {
+ GetDebugPoint().enableDebugPointForAllBEs(
+ "segment_iterator._read_columns_by_index", [column_name:
"embedding"])
+
+ sql """
+ select id
+ from ann_index_only_scan_debug_point
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ order by id;
+ """
+
+ sql """
+ select id, l2_distance_approximate(embedding, ${v}) as dist
+ from ann_index_only_scan_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ order by id;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ and comment match_any 'people'
+ order by id;
+ """
+
+ sql """
+ select id, inner_product_approximate(embedding, ${v}) as score
+ from ann_index_only_scan_ip_debug_point
+ where inner_product_approximate(embedding, ${v}) > 1000.0
+ order by id;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_remap_debug_point
+ where l2_distance_approximate(embedding, [0.0, 0.0, 0.0]) < 1.0
+ order by id;
+ """
+
+ test {
+ sql """
+ select id, embedding
+ from ann_index_only_scan_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ order by id;
+ """
+ exception "does not need to read data"
+ }
+
+ test {
+ sql """
+ select id, l2_distance_approximate(embedding, ${v}) as dist
+ from ann_index_only_scan_debug_point
+ where l2_distance_approximate(embedding, ${v}) > 120.0
+ order by id;
+ """
+ exception "does not need to read data"
+ }
+
+ test {
+ sql """
+ select id, inner_product_approximate(embedding, ${v}) as score
+ from ann_index_only_scan_ip_debug_point
+ where inner_product_approximate(embedding, ${v}) < 16175.99
+ order by id;
+ """
+ exception "does not need to read data"
+ }
+
+ test {
+ sql """
+ select id
+ from ann_index_only_scan_debug_point
+ where array_size(embedding) > 5
+ and l2_distance_approximate(embedding, ${v}) > 120.0
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+ exception "does not need to read data"
+ }
+ } finally {
+
GetDebugPoint().disableDebugPointForAllBEs("segment_iterator._read_columns_by_index")
+ }
+
+ sql "drop table if exists ann_index_only_scan_no_ann_debug_point"
+ sql """
+ create table ann_index_only_scan_no_ann_debug_point (
+ id int not null,
+ embedding array<float> not null,
+ value int null
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_no_ann_debug_point
+ select id, embedding, value from ann_index_only_scan_debug_point;
+ """
+
+ try {
+ GetDebugPoint().enableDebugPointForAllBEs(
+ "segment_iterator._read_columns_by_index", [column_name:
"embedding"])
+
+ test {
+ sql """
+ select id
+ from ann_index_only_scan_no_ann_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 999.0
+ order by id;
+ """
+ exception "does not need to read data"
+ }
+ } finally {
+
GetDebugPoint().disableDebugPointForAllBEs("segment_iterator._read_columns_by_index")
+ }
+}
diff --git
a/regression-test/suites/ann_index_p0/ann_index_only_scan_distance_expr.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan_distance_expr.groovy
deleted file mode 100644
index bf26009185e..00000000000
---
a/regression-test/suites/ann_index_p0/ann_index_only_scan_distance_expr.groovy
+++ /dev/null
@@ -1,207 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import groovy.json.JsonSlurper
-
-// Focus: whether distance is projected or used in expressions/predicates and
its impact on index-only scan.
-// Strategy: Compare ScanBytes with and without projecting/using distance
under different predicate directions.
-
-def getProfileList = {
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst + "/rest/v1/query_profile").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-def getProfile = { id ->
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst +
"/api/profile/text/?query_id=$id").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-// Note: define getProfileWithToken inside suite to use suite-level assertTrue
-
-def extractScanBytesValue = { String profileText ->
- def lines = profileText.split("\n")
- for (def line : lines) {
- if (line.contains("ScanBytes:")) {
- // allow optional unit (e.g. "B"); sometimes profile prints no
unit for 0 bytes
- def m = (line =~
/ScanBytes:\s*([0-9]+(?:\.[0-9]+)?)(?:\s*([A-Za-z]+))?/)
- if (m.find()) {
- return m.group(1)
- }
- }
- }
- return null
-}
-
-suite("ann_index_only_scan_distance_expr") {
- def getProfileWithToken = { token ->
- String profileId = ""
- int attempts = 0
- while (attempts < 10 && (profileId == null || profileId == "")) {
- List profileData = new
JsonSlurper().parseText(getProfileList()).data.rows
- for (def profileItem in profileData) {
- if (profileItem["Sql Statement"].toString().contains(token)) {
- profileId = profileItem["Profile ID"].toString()
- break
- }
- }
- if (profileId == null || profileId == "") {
- Thread.sleep(300)
- }
- attempts++
- }
- assertTrue(profileId != null && profileId != "")
- Thread.sleep(800)
- return getProfile(profileId).toString()
- }
- // session vars
- sql "unset variable all;"
- sql "set profile_level=2;"
- sql "set enable_profile=true;"
- sql "set experimental_enable_virtual_slot_for_cse=true;"
- sql "set enable_no_need_read_data_opt=true;"
- sql "set parallel_pipeline_task_num=1;" // make execution more
deterministic for test
-
-
- sql "drop table if exists ann_expr_l2"
- sql """
- create table ann_expr_l2 (
- id int not null,
- embedding array<float> not null,
- txt string not null,
- index ann_embedding(`embedding`) using ann properties(
- "index_type"="hnsw",
- "metric_type"="l2_distance",
- "dim"="8"
- )
- ) duplicate key(id)
- distributed by hash(id) buckets 1
- properties("replication_num"="1");
- """
-
- sql """
- insert into ann_expr_l2 values
- (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687, 10.162686,
36.335983, 38.684258], 'A'),
- (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715, 72.64085,
9.688437, 17.721428], 'B'),
- (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135, 72.080734,
85.71118, 99.35976], 'C'),
- (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], 'D'),
- (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106, 79.39356,
63.014366, 68.67834], 'E'),
- (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], 'F'),
- (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], 'G'),
- (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274, 40.286068,
11.943586, 3.69409], 'H'),
- (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627, 33.388138,
11.076194, 20.480877], 'I'),
- (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595, 48.04684,
71.29212, 30.282396], 'J');
- """
-
- def v =
"[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031]"
-
- // Case 1: Range < with distance used in projection arithmetic -> still
index-only
- def t1 = UUID.randomUUID().toString()
- sql """
- select id, "${t1}" from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) < 170.0
- order by id limit 20;
- """
- def t2 = UUID.randomUUID().toString()
- sql """
- select id, "${t2}", (l2_distance_approximate(embedding, ${v}) * 2.0)
as d2
- from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) < 170.0
- order by id limit 20;
- """
- def p1 = getProfileWithToken(t1)
- def p2 = getProfileWithToken(t2)
- def s1 = extractScanBytesValue(p1)
- def s2 = extractScanBytesValue(p2)
- logger.info("Expr L2 < threshold: no-proj=${s1}, proj(d*2)=${s2}")
- assertTrue(s1 == s2)
-
- // Case 2: Range > with distance used in projection arithmetic -> not
index-only (needs base read)
- def t3 = UUID.randomUUID().toString()
- sql """
- select id, "${t3}" from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) > 120.0
- order by id limit 20;
- """
- def t4 = UUID.randomUUID().toString()
- sql """
- select id, "${t4}", (l2_distance_approximate(embedding, ${v}) + 1.0)
as d2
- from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) > 120.0
- order by id limit 20;
- """
- def p3 = getProfileWithToken(t3)
- def p4 = getProfileWithToken(t4)
- def s3 = extractScanBytesValue(p3)
- def s4 = extractScanBytesValue(p4)
- logger.info("Expr L2 > threshold: no-proj=${s3}, proj(d+1)=${s4}")
- assertTrue(s3 != s4)
-
- // Case 3: Distance value reused in another predicate expression; still
index-only for <
- def t5 = UUID.randomUUID().toString()
- sql """
- select id, "${t5}" from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) < 170.0
- and (l2_distance_approximate(embedding, ${v}) + 0.5) < 200.0
- order by id limit 20;
- """
- def t6 = UUID.randomUUID().toString()
- sql """
- select id, "${t6}", l2_distance_approximate(embedding, ${v}) as dist
- from ann_expr_l2
- where l2_distance_approximate(embedding, ${v}) < 170.0
- and (l2_distance_approximate(embedding, ${v}) + 0.5) < 200.0
- order by id limit 20;
- """
- def p5 = getProfileWithToken(t5)
- def p6 = getProfileWithToken(t6)
- def s5 = extractScanBytesValue(p5)
- def s6 = extractScanBytesValue(p6)
- logger.info("Expr L2 < threshold with extra predicate: no-proj=${s5},
with-dist=${s6}")
- assertTrue(s5 == s6)
-
- // Case 4: TopN by distance with distance used in projection -> index-only
- def t7 = UUID.randomUUID().toString()
- sql """
- select id, "${t7}"
- from ann_expr_l2
- order by l2_distance_approximate(embedding, ${v})
- limit 5;
- """
- def t8 = UUID.randomUUID().toString()
- sql """
- select id, "${t8}", (l2_distance_approximate(embedding, ${v}) / 2.0)
as d2
- from ann_expr_l2
- order by l2_distance_approximate(embedding, ${v})
- limit 5;
- """
- def p7 = getProfileWithToken(t7)
- def p8 = getProfileWithToken(t8)
- def s7 = extractScanBytesValue(p7)
- def s8 = extractScanBytesValue(p8)
- logger.info("TopN L2 asc: no-proj=${s7}, proj(d/2)=${s8}")
- assertTrue(s7 == s8)
-}
diff --git
a/regression-test/suites/ann_index_p0/ann_index_only_scan_expr_debug_point.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan_expr_debug_point.groovy
new file mode 100644
index 00000000000..aea2d9ad3cc
--- /dev/null
+++
b/regression-test/suites/ann_index_p0/ann_index_only_scan_expr_debug_point.groovy
@@ -0,0 +1,104 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("ann_index_only_scan_expr_debug_point", "nonConcurrent") {
+ sql "unset variable all;"
+ sql "set enable_common_expr_pushdown=true;"
+ sql "set experimental_enable_virtual_slot_for_cse=true;"
+ sql "set enable_no_need_read_data_opt=true;"
+ sql "set parallel_pipeline_task_num=1;"
+ sql "set enable_sql_cache=false;"
+
+ sql "drop table if exists ann_index_only_scan_expr_debug_point"
+ sql """
+ create table ann_index_only_scan_expr_debug_point (
+ id int not null,
+ embedding array<float> not null,
+ txt string not null,
+ index ann_embedding(`embedding`) using ann properties(
+ "index_type"="hnsw",
+ "metric_type"="l2_distance",
+ "dim"="8"
+ )
+ ) duplicate key(id)
+ distributed by hash(id) buckets 1
+ properties("replication_num"="1");
+ """
+
+ sql """
+ insert into ann_index_only_scan_expr_debug_point values
+ (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687, 10.162686,
36.335983, 38.684258], 'A'),
+ (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715, 72.64085,
9.688437, 17.721428], 'B'),
+ (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135, 72.080734,
85.71118, 99.35976], 'C'),
+ (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], 'D'),
+ (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106, 79.39356,
63.014366, 68.67834], 'E'),
+ (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], 'F'),
+ (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], 'G'),
+ (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274, 40.286068,
11.943586, 3.69409], 'H'),
+ (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627, 33.388138,
11.076194, 20.480877], 'I'),
+ (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595, 48.04684,
71.29212, 30.282396], 'J');
+ """
+
+ def v =
"[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031]"
+
+ try {
+ GetDebugPoint().enableDebugPointForAllBEs(
+ "segment_iterator._read_columns_by_index", [column_name:
"embedding"])
+
+ sql """
+ select id, (l2_distance_approximate(embedding, ${v}) * 2.0) as d2
+ from ann_index_only_scan_expr_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ order by id;
+ """
+
+ sql """
+ select id
+ from ann_index_only_scan_expr_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ and (l2_distance_approximate(embedding, ${v}) + 0.5) < 200.0
+ order by id;
+ """
+
+ sql """
+ select id, l2_distance_approximate(embedding, ${v}) as dist
+ from ann_index_only_scan_expr_debug_point
+ where l2_distance_approximate(embedding, ${v}) < 170.0
+ and (l2_distance_approximate(embedding, ${v}) + 0.5) < 200.0
+ order by id;
+ """
+
+ sql """
+ select id, (l2_distance_approximate(embedding, ${v}) / 2.0) as d2
+ from ann_index_only_scan_expr_debug_point
+ order by l2_distance_approximate(embedding, ${v})
+ limit 5;
+ """
+
+ test {
+ sql """
+ select id, (l2_distance_approximate(embedding, ${v}) + 1.0) as
d2
+ from ann_index_only_scan_expr_debug_point
+ where l2_distance_approximate(embedding, ${v}) > 120.0
+ order by id;
+ """
+ exception "does not need to read data"
+ }
+ } finally {
+
GetDebugPoint().disableDebugPointForAllBEs("segment_iterator._read_columns_by_index")
+ }
+}
diff --git
a/regression-test/suites/ann_index_p0/ann_index_only_scan_metric_direction.groovy
b/regression-test/suites/ann_index_p0/ann_index_only_scan_metric_direction.groovy
deleted file mode 100644
index 757b71cd495..00000000000
---
a/regression-test/suites/ann_index_p0/ann_index_only_scan_metric_direction.groovy
+++ /dev/null
@@ -1,229 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import groovy.json.JsonSlurper
-
-// Focus: different metrics (l2 vs inner_product) and predicate directions (<
vs >)
-// Expectation:
-// - l2_distance: index returns distance on < (or <=) range; not on > (or >=)
-// - inner_product: index returns distance on > (or >=) range; not on < (or
<=)
-// We infer index-only read by comparing ScanBytes with and without
selecting/using distance.
-
-def getProfileList = {
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst + "/rest/v1/query_profile").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-def getProfile = { id ->
- def dst = 'http://' + context.config.feHttpAddress
- def conn = new URL(dst +
"/api/profile/text/?query_id=$id").openConnection()
- conn.setRequestMethod("GET")
- def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
- (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
- conn.setRequestProperty("Authorization", "Basic ${encoding}")
- return conn.getInputStream().getText()
-}
-
-// Note: define getProfileWithToken inside suite to use suite-level assertTrue
-
-def extractScanBytesValue = { String profileText ->
- def lines = profileText.split("\n")
- for (def line : lines) {
- if (line.contains("ScanBytes:")) {
- // allow optional unit (e.g. "B"); sometimes profile prints no
unit for 0 bytes
- def m = (line =~
/ScanBytes:\s*([0-9]+(?:\.[0-9]+)?)(?:\s*([A-Za-z]+))?/)
- if (m.find()) {
- return m.group(1)
- }
- }
- }
- return null
-}
-
-suite("ann_index_only_scan_metric_direction") {
- def getProfileWithToken = { token ->
- String profileId = ""
- int attempts = 0
- while (attempts < 10 && (profileId == null || profileId == "")) {
- List profileData = new
JsonSlurper().parseText(getProfileList()).data.rows
- for (def profileItem in profileData) {
- if (profileItem["Sql Statement"].toString().contains(token)) {
- profileId = profileItem["Profile ID"].toString()
- break
- }
- }
- if (profileId == null || profileId == "") {
- Thread.sleep(300)
- }
- attempts++
- }
- assertTrue(profileId != null && profileId != "")
- Thread.sleep(800)
- return getProfile(profileId).toString()
- }
- // session vars
- sql "unset variable all;"
- sql "set profile_level=2;"
- sql "set enable_profile=true;"
- sql "set experimental_enable_virtual_slot_for_cse=true;"
- sql "set enable_no_need_read_data_opt=true;"
- sql "set parallel_pipeline_task_num=1;" // make execution more
deterministic for test
-
-
- // l2 table
- sql "drop table if exists ann_md_l2"
- sql """
- create table ann_md_l2 (
- id int not null,
- embedding array<float> not null,
- comment string not null,
- value int null,
- index ann_embedding(`embedding`) using ann properties(
- "index_type"="hnsw",
- "metric_type"="l2_distance",
- "dim"="8"
- )
- ) duplicate key(id)
- distributed by hash(id) buckets 1
- properties("replication_num"="1");
- """
-
- // inner product table
- sql "drop table if exists ann_md_ip"
- sql """
- create table ann_md_ip (
- id int not null,
- embedding array<float> not null,
- comment string not null,
- value int null,
- index ann_embedding(`embedding`) using ann properties(
- "index_type"="hnsw",
- "metric_type"="inner_product",
- "dim"="8"
- )
- ) duplicate key(id)
- distributed by hash(id) buckets 1
- properties("replication_num"="1");
- """
-
- def rows = """
- (0, [39.906116, 10.495334, 54.08394, 88.67262, 55.243687, 10.162686,
36.335983, 38.684258], "A", 100),
- (1, [62.759315, 97.15586, 25.832521, 39.604908, 88.76715, 72.64085,
9.688437, 17.721428], "B", 101),
- (2, [15.447449, 59.7771, 65.54516, 12.973712, 99.685135, 72.080734,
85.71118, 99.35976], "C", 102),
- (3, [72.26747, 46.42257, 32.368374, 80.50209, 5.777631, 98.803314,
7.0915947, 68.62693], "D", 103),
- (4, [22.098177, 74.10027, 63.634556, 4.710955, 12.405106, 79.39356,
63.014366, 68.67834], "E", 104),
- (5, [27.53003, 72.1106, 50.891026, 38.459953, 68.30715, 20.610682,
94.806274, 45.181377], "F", 105),
- (6, [77.73215, 64.42907, 71.50025, 43.85641, 94.42648, 50.04773,
65.12575, 68.58207], "G", 106),
- (7, [2.1537063, 82.667885, 16.171143, 71.126656, 5.335274, 40.286068,
11.943586, 3.69409], "H", 107),
- (8, [54.435013, 56.800594, 59.335514, 55.829235, 85.46627, 33.388138,
11.076194, 20.480877], "I", 108),
- (9, [76.197945, 60.623528, 84.229805, 31.652937, 71.82595, 48.04684,
71.29212, 30.282396], "J", 109)
- """
- sql "insert into ann_md_l2 values ${rows};"
- sql "insert into ann_md_ip values ${rows};"
-
- // Common probe vector
- def v =
"[26.360261917114258,7.05784273147583,32.361351013183594,86.39714050292969,58.79527282714844,27.189321517944336,99.38946533203125,80.19270324707031]"
-
- // L2: < threshold -> expect index returns distance; projecting distance
should NOT increase ScanBytes
- def t1 = UUID.randomUUID().toString()
- sql """
- select id, "${t1}" from ann_md_l2
- where l2_distance_approximate(embedding, ${v}) < 160.0
- order by id limit 20;
- """
- def t2 = UUID.randomUUID().toString()
- sql """
- select id, "${t2}", l2_distance_approximate(embedding, ${v}) as dist
- from ann_md_l2
- where l2_distance_approximate(embedding, ${v}) < 160.0
- order by id limit 20;
- """
- def p1 = getProfileWithToken(t1)
- def p2 = getProfileWithToken(t2)
- def s1 = extractScanBytesValue(p1)
- def s2 = extractScanBytesValue(p2)
- logger.info("L2 < threshold ScanBytes: no-proj=${s1}, with-dist=${s2}")
- assertTrue(s1 == s2)
-
- // L2: > threshold -> index doesn't return distance; projecting distance
SHOULD increase ScanBytes
- def t3 = UUID.randomUUID().toString()
- sql """
- select id, "${t3}" from ann_md_l2
- where l2_distance_approximate(embedding, ${v}) > 120.0
- order by id limit 20;
- """
- def t4 = UUID.randomUUID().toString()
- sql """
- select id, "${t4}", l2_distance_approximate(embedding, ${v}) as dist
- from ann_md_l2
- where l2_distance_approximate(embedding, ${v}) > 120.0
- order by id limit 20;
- """
- def p3 = getProfileWithToken(t3)
- def p4 = getProfileWithToken(t4)
- def s3 = extractScanBytesValue(p3)
- def s4 = extractScanBytesValue(p4)
- logger.info("L2 > threshold ScanBytes: no-proj=${s3}, with-dist=${s4}")
- assertTrue(s3 != s4)
-
- // Inner Product: > threshold -> expect index returns distance
- def t5 = UUID.randomUUID().toString()
- sql """
- select id, "${t5}" from ann_md_ip
- where inner_product_approximate(embedding, ${v}) > 1000.0
- order by id limit 20;
- """
- def t6 = UUID.randomUUID().toString()
- sql """
- select id, "${t6}", inner_product_approximate(embedding, ${v}) as score
- from ann_md_ip
- where inner_product_approximate(embedding, ${v}) > 1000.0
- order by id limit 20;
- """
- def p5 = getProfileWithToken(t5)
- def p6 = getProfileWithToken(t6)
- def s5 = extractScanBytesValue(p5)
- def s6 = extractScanBytesValue(p6)
- logger.info("IP > threshold ScanBytes: no-proj=${s5}, with-score=${s6}")
- assertTrue(s5 == s6)
-
- // Inner Product: < threshold -> expect index doesn't return distance;
projecting distance increases ScanBytes
- def t7 = UUID.randomUUID().toString()
- sql """
- select id, "${t7}" from ann_md_ip
- where inner_product_approximate(embedding, ${v}) < 16175.99
- order by id limit 20;
- """
- def t8 = UUID.randomUUID().toString()
- sql """
- select id, "${t8}", inner_product_approximate(embedding, ${v}) as score
- from ann_md_ip
- where inner_product_approximate(embedding, ${v}) < 16175.99
- order by id limit 20;
- """
- def p7 = getProfileWithToken(t7)
- def p8 = getProfileWithToken(t8)
- def s7 = extractScanBytesValue(p7)
- def s8 = extractScanBytesValue(p8)
- logger.info("IP < threshold ScanBytes: no-proj=${s7}, with-score=${s8}")
- assertTrue(s7 != s8)
-}
diff --git
a/regression-test/suites/ann_index_p0/ann_range_search_pushdown_regression.groovy
b/regression-test/suites/ann_index_p0/ann_range_search_pushdown_regression.groovy
index c3122b9d1e6..93a9d5572e0 100644
---
a/regression-test/suites/ann_index_p0/ann_range_search_pushdown_regression.groovy
+++
b/regression-test/suites/ann_index_p0/ann_range_search_pushdown_regression.groovy
@@ -81,7 +81,6 @@ suite("ann_range_search_pushdown_regression",
"nonConcurrent") {
sql "set profile_level=2;"
sql "set parallel_pipeline_task_num=1;"
sql "set enable_sql_cache=false;"
- sql "set enable_condition_cache=false;"
// Case 1: one rowset has an IVF ANN index, while the surrounding small
// rowsets skip ANN index building because they have fewer rows than nlist.
diff --git
a/regression-test/suites/ann_index_p0/ann_range_search_source_index_status_regression.groovy
b/regression-test/suites/ann_index_p0/ann_range_search_source_index_status_regression.groovy
index f4a881e75ce..ea8fa0769f8 100644
---
a/regression-test/suites/ann_index_p0/ann_range_search_source_index_status_regression.groovy
+++
b/regression-test/suites/ann_index_p0/ann_range_search_source_index_status_regression.groovy
@@ -22,7 +22,6 @@ suite("ann_range_search_source_index_status_regression",
"nonConcurrent") {
sql "set enable_no_need_read_data_opt=true;"
sql "set parallel_pipeline_task_num=1;"
sql "set enable_sql_cache=false;"
- sql "set enable_condition_cache=false;"
// The source column's index in the scan block differs from its storage
// ColumnId. ANN range search should mark the common expression status by
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
