Data Agent Ready Warehouse : One for Analytics, Search, AI, Python Sandbox. — rebuilt from scratch. Unified architecture on your S3.
This report presents the forensic synthetic code analysis of databendlabs/databend, a Rust project with 9,384 GitHub stars. SynthScan v2.0 examined 1,074,363 lines of code across 4957 source files, recording 4871 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 5.3 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 4871 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ruff.toml | 61 | COMMENT | |
| LOW | docker/it-iceberg-catalogs/docker-compose.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | docker/it-iceberg-catalogs/docker-compose.yaml | 61 | /bin/sh -c " until (/usr/bin/mc config host add minio http://minio:9000 admin password) do echo '...waiting...' && | COMMENT |
| LOW | tests/compat_fuse/test_cases.yaml | 1 | # Fuse table compatibility test matrix. | COMMENT |
| LOW | tests/cloud_control_server/udf_env.toml | 1 | # UDF sandbox environment variables for the cloud-control mock server. | COMMENT |
| LOW | …ttach_read_only/02_0006_attach_table_ro_issue_16121.sh | 21 | # AI configurations (provider url, ak/sk) are not ready for CI, thus the following test case is commented out | COMMENT |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 21 | COMMENT | |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 41 | # ) | COMMENT |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 61 | # mycursor.execute("select * from data_mask_test") | COMMENT |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 81 | # # set column a masking policy | COMMENT |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 101 | COMMENT | |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 121 | # print(data) | COMMENT |
| LOW | …ul/08_select_stage/08_00_parquet/08_00_05_query_uri.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …sts/suites/1_stateful/02_query/02_0006_set_priority.py | 21 | with NativeClient(name="client1>") as client1: | COMMENT |
| LOW | …sts/suites/1_stateful/02_query/02_0006_set_priority.py | 41 | # time.sleep(0.2) | COMMENT |
| LOW | …0_stateless/20+_others/20_0008_mysql_client_command.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | …suites/0_stateless/19_fuzz/19_0006_fuzz_random_join.sh | 181 | ); | COMMENT |
| LOW | …/sqllogictests/scripts/docker-compose-iceberg-tpch.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | tests/sqllogictests/src/diagnostics.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/util.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/util.rs | 561 | COMMENT | |
| LOW | tests/sqllogictests/src/error.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/lib.rs | 1 | // Licensed under the Apache License, Version 2.0 (the "License"); | COMMENT |
| LOW | tests/sqllogictests/src/report.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/arg.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/main.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/client/ttc_client.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/client/mysql_client.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/client/http_client.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/client/global_cookie_store.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/client/mod.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/udf/udf_server.py | 1 | # Copyright 2023 RisingWave Labs | COMMENT |
| LOW | tests/helpers/uexpect.py | 1 | # Copyright (c) 2019 Vitaliy Zakaznikov | COMMENT |
| LOW | scripts/benchmark/proxy_table_routing_bench.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | scripts/ci/ci-run-proxy-routing-benchmark.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-1.toml | 61 | COMMENT | |
| LOW | scripts/ci/deploy/config/databend-query-node-1.toml | 121 | # [storage.s3] | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-1.toml | 141 | COMMENT | |
| LOW | …/deploy/config/databend-query-node-system-managed.toml | 81 | # Type of storage to keep the table data cache | COMMENT |
| LOW | scripts/distribution/configs/databend-query.toml | 81 | # bucket = "<your-bucket-name>" | COMMENT |
| LOW | scripts/distribution/configs/databend-query.toml | 101 | # [storage.oss] | COMMENT |
| LOW | scripts/distribution/configs/databend-query.toml | 121 | COMMENT | |
| LOW | .github/workflows/typos.yml | 1 | # Copyright 2023 Datafuse Labs | COMMENT |
| LOW | .github/workflows/reuse.linux.yml | 421 | with: | COMMENT |
| LOW | .github/workflows/reuse.linux.yml | 441 | # name: test_stateful_hive_standalone | COMMENT |
| LOW | .github/workflows/reuse.linux.yml | 481 | # | COMMENT |
| LOW | .github/actions/pack_binaries/action.yml | 61 | with: | COMMENT |
| LOW | src/bendpy/build.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/python/databend/__init__.py | 1 | ## Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/tests/test_basic.py | 1 | ## Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/tests/test_connections.py | 1 | ## Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/examples/sql-stage-s3.py | 1 | # Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/examples/sql-parquet-s3.py | 1 | # Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/examples/sql-to-pandas.py | 1 | # Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/examples/sql-table-s3.py | 1 | # Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/scripts/local_publish.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | src/bendpy/src/dataframe.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/src/datablock.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/src/lib.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | src/bendpy/src/schema.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| 4165 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …0_stateless/20+_others/20_0008_mysql_client_command.py | 10 | # -------------- | COMMENT |
| MEDIUM | …0_stateless/20+_others/20_0008_mysql_client_command.py | 29 | # -------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 22 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 24 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 116 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 118 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 187 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 189 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 222 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 224 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 499 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 501 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 585 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/security_policy/security_policy_bench.py | 587 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 61 | // ┌─────────────────────────┐ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 63 | // │ └─────────────────────────┘ │ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 65 | // ┌─────────────────────┐ │ ┌─────────────────────────┐ │ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 67 | // └─────────────────────┘ │ └─────────────────────────┘ │ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 69 | // │ ┌─────────────────────────┐ │ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 71 | // └─────────────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 40 | // ┌──────────────────────┐ ┌──────────────────┐ ┌────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 41 | // │ ├──┬────────►│ SerializeBlock ├──────────────►│SerializeSegment├─── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 42 | // ┌─────────────┐ │ ├──┘ └──────────────────┘ └────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 43 | // │ UpsertSource├─────►│ ReplaceIntoProcessor │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 44 | // └─────────────┘ │ ├──┐ ┌───────────────────┐ ┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 45 | // │ ├──┴────────►│ ├──┬──────────►│MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 46 | // └──────────────────────┘ │ ├──┘ └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 47 | // │ BroadcastProcessor│ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 48 | // │ ├──┐ ┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 49 | // │ ├──┴──────────►│MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 50 | // │ │ └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 52 | // │ ├──┴──────────►┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 53 | // └───────────────────┘ │MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 54 | // └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 61 | // ┌──────────────────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 64 | // │ ┌───────────────────┐ ┌───────────────────────┐ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 65 | // └─────►│ResizeProcessor(1) ├──────►│TableMutationAggregator├────────►│ CommitSink │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 66 | // └───────────────────┘ └───────────────────────┘ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 72 | // ┌──────────────────────┐ ┌─────────────────┐ ┌─────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 73 | // │ ├──┬────────►│ SerializeBlock ├────────►│SerializeSegment ├───────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 74 | // ┌─────────────┐ │ ├──┘ └─────────────────┘ └─────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 75 | // │ UpsertSource├─────►│ ReplaceIntoProcessor │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 76 | // └─────────────┘ │ ├──┐ ┌─────────────────┐ ┌─────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 77 | // │ ├──┴────────►│ DummyTransform ├────────►│ DummyTransform ├───────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 78 | // └──────────────────────┘ └─────────────────┘ └─────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 82 | // ┌─────────────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 85 | // │ ┌───────────────────┐ ┌───────────────────────┐ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 86 | // └─────►│ResizeProcessor(1) ├──────►│TableMutationAggregator├────────►│ CommitSink │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 87 | // └───────────────────┘ └───────────────────────┘ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 43 | // ┌────────┐ ┌────────┐ ┌────────┐ ┌────────┐ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 45 | // └────────┘ └────────┘ └────────┘ └────────┘ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 48 | // ┌────────┐ ┌────────┐ ┌────────┐ ┌────────┐ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 50 | // └────────┘ └────────┘ └────────┘ └────────┘ | COMMENT |
| MEDIUM⚡ | …mmon/index/src/hnsw_index/common/bitpacking_ordered.rs | 40 | //! ┌───────┬───────┬───────┬ ┬───────┬────────┐ | COMMENT |
| MEDIUM⚡ | …mmon/index/src/hnsw_index/common/bitpacking_ordered.rs | 42 | //! └───────┤ ├───────┴ ┴───────┴────────┘ | COMMENT |
| MEDIUM⚡ | …mmon/index/src/hnsw_index/common/bitpacking_ordered.rs | 43 | //! ╭───────╯ ╰────────────────╮ | COMMENT |
| MEDIUM⚡ | …mmon/index/src/hnsw_index/common/bitpacking_ordered.rs | 45 | //! ├────┬──┬──┬──┬──┬ ┬────┬──────┤ | COMMENT |
| MEDIUM⚡ | …mmon/index/src/hnsw_index/common/bitpacking_ordered.rs | 47 | //! └────┴──┴──┴──┴──┴ ┴────┴──────┘ | COMMENT |
| MEDIUM | …rages/common/index/src/hnsw_index/common/bitpacking.rs | 90 | // └[2]┘└─────────────[1]──────────────┘ | COMMENT |
| MEDIUM⚡ | …rages/common/index/src/hnsw_index/common/bitpacking.rs | 189 | // ┌───────────new_buf────────────┐┌─self.buf─┐ | COMMENT |
| 65 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 56 | # client1.send("create table data_mask_test(a int not null, b string not null);") | COMMENT |
| HIGH | …/suites/0_stateless/02_ddl/02_0000_create_drop_view.py | 32 | "CREATE TABLE t_issue_16188 (a int not null, b int not null)" | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 54 | ["raft_log",{"Purged":null}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 60 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":5},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 61 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":6},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 62 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":7},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 67 | ["state_machine/0",{"GenericKV":{"key":"app/config/timeout","value":{"seq":3,"meta":null,"data":[51,48]}}}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 68 | ["state_machine/0",{"GenericKV":{"key":"app/db/host","value":{"seq":1,"meta":null,"data":[108,111,99,97,108,104,111,115, | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 69 | ["state_machine/0",{"GenericKV":{"key":"app/db/port","value":{"seq":2,"meta":null,"data":[53,52,51,50]}}}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 49 | ["raft_log",{"Purged":null}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 55 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":5},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 56 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":6},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 57 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":7},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 62 | ["state_machine/0",{"GenericKV":{"key":"app/config/timeout","value":{"seq":3,"meta":null,"data":[51,48]}}}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 63 | ["state_machine/0",{"GenericKV":{"key":"app/db/host","value":{"seq":1,"meta":null,"data":[108,111,99,97,108,104,111,115, | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_export_from_grpc.py | 64 | ["state_machine/0",{"GenericKV":{"key":"app/db/port","value":{"seq":2,"meta":null,"data":[53,52,51,50]}}}]""".strip().sp | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 26 | ["raft_log",{"Purged":null}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 32 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":5},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 33 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":6},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 34 | ["raft_log",{"LogEntry":{"log_id":{"leader_id":{"term":1,"node_id":1},"index":7},"payload":{"Normal":{"time_ms":17535082 | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 39 | ["state_machine/0",{"GenericKV":{"key":"app/config/timeout","value":{"seq":3,"meta":null,"data":[51,48]}}}] | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 40 | ["state_machine/0",{"GenericKV":{"key":"app/db/host","value":{"seq":1,"meta":null,"data":[108,111,99,97,108,104,111,115, | CODE |
| HIGH⚡ | tests/metactl/subcommands/cmd_import.py | 41 | ["state_machine/0",{"GenericKV":{"key":"app/db/port","value":{"seq":2,"meta":null,"data":[53,52,51,50]}}}]""" | CODE |
| HIGH | tests/nox/suites/copy/test_metadata.py | 170 | f"metadata$file_content_key is not null, " | CODE |
| HIGH | tests/nox/suites/copy/test_text.py | 60 | conn.exec("create or replace table t_header (a int, b int null)") | CODE |
| HIGH | tests/nox/suites/copy/test_text.py | 81 | conn.exec("create or replace table t_null_display (a string null, b int)") | CODE |
| HIGH | tests/nox/suites/copy/test_text.py | 241 | conn.exec("create or replace table t_trim_text (a int, b string, c string null)") | CODE |
| HIGH | tests/nox/suites/copy/test_csv.py | 197 | conn.exec("create or replace table t_trim_csv (a int, b string, c string null)") | CODE |
| HIGH | …sts/sqllogictests/scripts/prepare_iceberg_test_data.py | 48 | f"""INSERT INTO iceberg.test.t1 VALUES (0, 0, 'a'), (1, 1, 'b'), (2, 2, 'c'), (3, 3, 'd'), (4, null, null);""" | STRING |
| HIGH | …sts/sqllogictests/scripts/prepare_iceberg_test_data.py | 65 | f"""INSERT INTO iceberg.test.t1_orc VALUES (0, 0, 'a'), (1, 1, 'b'), (2, 2, 'c'), (3, 3, 'd'), (4, null, null);""" | STRING |
| HIGH | scripts/recluster/recluster_bench.py | 199 | a int not null, | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | src/meta/plugins/cache/tests/it/grpc_cache.rs | 50 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/cache/tests/it/grpc_cache.rs | 112 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 50 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 101 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 145 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 196 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 229 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 274 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 308 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 380 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 417 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 453 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 499 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 544 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 584 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/plugins/semaphore/tests/it/grpc_semaphore.rs | 653 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/runtime/src/lib.rs | 19 | //! `databend-common-base`. This allows meta-service to leverage Databend's advanced | COMMENT |
| MEDIUM | src/meta/admin/tests/it/features.rs | 33 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/admin/tests/it/transfer_leader.rs | 31 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/admin/tests/it/metrics.rs | 34 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/admin/tests/it/http_service.rs | 46 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/admin/tests/it/http_service.rs | 92 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/admin/tests/it/http_service.rs | 148 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/schema-api-tests/tests/it/test_schema_api.rs | 27 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | src/meta/schema-api-tests/tests/it/test_schema_api.rs | 39 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | …a/schema-api-tests/tests/it/test_auto_increment_api.rs | 27 | #[test(harness = meta_service_test_harness::<DatabendRuntime, _, _>)] | COMMENT |
| MEDIUM | …se/src/io/read/inverted_index/inverted_index_reader.rs | 127 | // The first and third versions utilize tantivy's search function, | COMMENT |
| MEDIUM | src/query/storages/parquet/src/parquet_part.rs | 174 | /// 1. to fully utilize the IO, multiple small files are loaded in one part. | COMMENT |
| MEDIUM | …ery/service/tests/it/indexes/inverted_index/pruning.rs | 170 | jsonb::parse_value(r#"{"title":"The Art of Programming","metadata":{"author":"Alice","publishedDate":"2022-0 | CODE |
| MEDIUM | …ery/service/tests/it/indexes/inverted_index/pruning.rs | 195 | jsonb::parse_value(r#"{"title":"Front-End Development Best Practices","metadata":{"author":"Grace","publishe | CODE |
| MEDIUM | src/query/service/src/servers/http/v1/streaming_load.rs | 338 | // resolve the ability to utilize name | COMMENT |
| MEDIUM | src/query/sql/src/planner/plans/join.rs | 744 | // utilize the distribution on the probe side. | COMMENT |
| MEDIUM | src/query/sql/src/planner/plans/aggregate.rs | 263 | // `Hash(group_items)`. Because of this we cannot leverage the distribution key to | COMMENT |
| MEDIUM | src/query/sql/src/planner/semantic/lowering.rs | 181 | /// Lowering `Scalar` into `RawExpr` to utilize with `common_expression::types::type_check`. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/cloud_control_server/simple_server.py | 186 | def _get_resource_service_port(resource_type): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 197 | def _docker_container_running(container_name): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 226 | def _start_resource_container( | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 276 | def _ensure_resource_endpoint(resource_type, script, env_vars): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 370 | def create_task_request_to_task(id, create_task_request): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 403 | def create_notification_request_to_notification(id, create_notification_request): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 440 | def create_task_run_from_task(task): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 464 | def create_mock_task_runs_from_task(task, num): | CODE |
| LOW | tests/compat/meta_meta/test_meta_meta.py | 193 | def filter_and_compare_exports( | CODE |
| LOW | tests/compat/meta_meta/test_meta_meta.py | 382 | def test_snapshot_replication(ctx: TestContext) -> None: | CODE |
| LOW | …2_query/02_0012_temp_table_external_session_cleanup.py | 38 | def test_external_temp_table_cleanup(): | CODE |
| LOW | tests/metactl/subcommands/cmd_transfer_leader.py | 46 | def test_transfer_leader_subcommand(): | CODE |
| LOW | tests/metactl/subcommands/cmd_transfer_leader.py | 104 | def test_transfer_leader_with_target(): | CODE |
| LOW | tests/metactl/subcommands/cmd_transfer_leader.py | 165 | def test_transfer_leader_help(): | CODE |
| LOW | tests/metactl/subcommands/cmd_keys_layout.py | 9 | def test_keys_layout_from_grpc(): | CODE |
| LOW | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 11 | def test_export_from_raft_dir(): | CODE |
| LOW | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 10 | def test_lua_admin_client_creation(): | CODE |
| LOW | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 34 | def test_lua_admin_client_metrics_error_handling(): | STRING |
| LOW | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 66 | def test_lua_admin_client_all_methods(): | STRING |
| LOW | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 125 | def test_lua_admin_client_file(): | STRING |
| LOW | tests/metactl/subcommands/cmd_dump_raft_log_wal.py | 152 | def test_dump_raft_log_wal_decode_values(): | CODE |
| LOW | tests/nox/noxfile.py | 69 | def resolve_latest_release_tag(latest_release_url, expected_prefix="v"): | CODE |
| LOW | tests/nox/noxfile.py | 146 | def resolve_python_driver_version(driver_version): | CODE |
| LOW | tests/nox/noxfile.py | 153 | def prepare_python_client_source(): | CODE |
| LOW | tests/nox/noxfile.py | 260 | def prepare_jdbc_release_artifacts(source_ref): | CODE |
| LOW | tests/nox/noxfile.py | 286 | def discover_jdbc_test_classes(test_jar): | CODE |
| LOW | tests/nox/noxfile.py | 326 | def prepare_jdbc_test_output_dir(resolved_ref): | CODE |
| LOW | tests/nox/suites/http_handler/test_upload_missing_at.py | 22 | def test_upload_to_stage_requires_file_upload(): | CODE |
| LOW | tests/nox/suites/http_handler/test_upload_missing_at.py | 43 | def test_streaming_load_requires_file_upload(): | CODE |
| LOW | tests/nox/suites/http_handler/test_cookie.py | 96 | def test_no_cookie_if_not_enabled(): | CODE |
| LOW | tests/nox/suites/http_handler/test_retry_start_query.py | 26 | def test_result_format_settings(): | CODE |
| LOW | tests/nox/suites/http_handler/test_session.py | 108 | def set_fake_last_refresh_time(self): | CODE |
| LOW | tests/nox/suites/http_handler/test_json_response.py | 21 | def test_json_response_errors(): | CODE |
| LOW | tests/nox/suites/http_handler/test_concurrent_query.py | 10 | def execute_query_with_cookies(query_id, payload, session_data=None): | CODE |
| LOW | tests/nox/suites/http_handler/test_concurrent_query.py | 37 | def test_concurrent_queries_with_session(): | CODE |
| LOW | tests/nox/suites/http_handler/test_result_spill.py | 24 | def test_disable_result_spill(): | CODE |
| LOW | tests/nox/suites/http_handler/test_arrow_ipc.py | 89 | def test_result_format_settings(): | CODE |
| LOW | tests/nox/suites/http_handler/test_query_lifecycle.py | 111 | def test_query_lifecycle_finalized(rows): | CODE |
| LOW | tests/nox/suites/http_handler/test_query_lifecycle.py | 304 | def test_query_lifecycle_canceled(): | CODE |
| LOW | tests/nox/suites/http_handler/test_query_lifecycle.py | 357 | def test_query_lifecycle_timeout(rows): | CODE |
| LOW | tests/nox/suites/http_handler/test_query_lifecycle.py | 415 | def test_query_lifecycle_timeout_polling(): | CODE |
| LOW | …sts/nox/suites/http_handler/test_sql_ends_semicolon.py | 31 | def test_sql_ends_with_semicolon(): | CODE |
| LOW | tests/nox/suites/copy/test_avro.py | 1 | def test_avro_unload_max_file_size(copy_env): | CODE |
| LOW | tests/nox/suites/copy/test_orc.py | 4 | def test_orc_unload_roundtrip(copy_env): | CODE |
| LOW | tests/nox/suites/copy/test_orc.py | 35 | def test_orc_unload_max_file_size(copy_env): | CODE |
| LOW | tests/nox/suites/copy/test_orc.py | 58 | def test_orc_unload_unsupported_type_reports_databend_type(copy_env): | CODE |
| LOW | tests/nox/suites/copy/test_encoding.py | 115 | def test_copy_into_location_with_unmappable_encoding(copy_env, tmp_path, format_name): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 53 | def test_metadata_file_path_equals_filename(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 71 | def test_metadata_file_basename(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 89 | def test_metadata_file_row_number(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 108 | def test_metadata_file_content_key(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 135 | def test_metadata_file_last_modified(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/test_metadata.py | 155 | def test_metadata_all_columns_together(copy_env, fmt): | CODE |
| LOW | tests/nox/suites/copy/copy_utils.py | 54 | def unload_and_read_stage_text(copy_env, path, query, file_format_clause): | CODE |
| LOW | tests/nox/suites/copy/test_text.py | 100 | def test_text_missing_columns_matrix( | CODE |
| LOW | tests/nox/suites/copy/test_text.py | 250 | def test_text_trim_space_after_escape_decode(copy_env, tmp_path): | CODE |
| LOW | tests/nox/suites/copy/test_lance.py | 16 | def _build_lance_storage_options(): | CODE |
| LOW | tests/nox/suites/copy/test_lance.py | 50 | def test_copy_into_lance_parallel_manifest_complete(): | CODE |
| LOW | tests/nox/suites/copy/test_lance.py | 97 | def test_copy_into_lance_overwrite_raw_path_cleanup_prefix(): | CODE |
| LOW | tests/nox/suites/copy/test_lance.py | 156 | def test_copy_into_lance_default_path_with_query_id_directory(): | CODE |
| 37 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/selfhost/restore_logs.sh | 510 | # Step 1: Generate download URL | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 521 | # Step 2: Download backup | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 534 | # Step 3: Extract archive | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 543 | # Step 4: Detect path prefix | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 566 | # Step 5: Upload files | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 613 | # Step 6: Restore database | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 639 | # Step 1: Create table by inferring schema from parquet files | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 647 | # Step 2: Copy data with error checking | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 655 | # Step 3: Verify and report row count | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 177 | // Step 1: Create a new semaphore entry with the key format `{prefix}/queue/{seq:020}`. | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 192 | // Step 2: The sem entry is inserted, keep it alive by extending the lease. | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 214 | // Step 3: Wait for the semaphore to be acquired or removed. | COMMENT |
| LOW⚡ | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 288 | // Step 1: Get a new globally unique sequence number. | COMMENT |
| LOW⚡ | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 293 | // Step 2: Create a new semaphore entry with the key format `{prefix}/queue/{seq:020}`. | COMMENT |
| LOW | …s/src/processors/transforms/window/transform_window.rs | 141 | // NULL frame is a special RANGE frame, we need to check if the frame is a null frame. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 126 | // Step 1: validate carried windows against the fresh snapshot. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 159 | // Step 2: scan this fixed range, excluding still-carried windows. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 328 | // Step 3: choose task candidates. If early accept fills the budget, | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 382 | // Step 4: build ReclusterParts from selected candidates. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 401 | // Step 5: stable range, advance to the next fixed scan range. | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1344 | // Step 1: Build probe and build sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1349 | // Step 2: Prepare column projections | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1353 | // Step 3: unify exchange keys | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1356 | // Step 4: Prepare schemas for both sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1360 | // Step 5: Process join conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1376 | // Step 6: Prepare projections and cache info | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1386 | // Step 7: Create merged fields | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1396 | // Step 8: Create merged schema for non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1399 | // Step 9: Create output schema | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1403 | // Step 10: Process non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1406 | // Step 11: Build runtime filter | COMMENT |
| LOW | …query/service/src/physical_plans/physical_hash_join.rs | 1421 | // Step 12: Create and return the HashJoin | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 130 | // Step 1: Tokenize the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 168 | // Step 2: Parse the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 250 | // Step 3: Bind AST with catalog, and generate a pure logical SExpr | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 283 | // Step 4: Optimize the SExpr with optimizers, and generate optimized physical SExpr | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 50 | // Step 1: Set the initial distribution requirement (Any) | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 55 | // Step 2: Enforce the property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 59 | // Step 3: Apply the sort and limit push down optimization | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 62 | // Step 4: Check if the result satisfies the required distribution property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 69 | // Step 5: If not satisfied, manually enforce serial distribution | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 256 | // Step 1: Check if we need an original input CTE | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 273 | // Step 2: Create CTEs for grouping sets, organizing by dependency levels for parallelization | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 396 | // Step 3: Build final union branches | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 405 | // Step 4: Assemble the complete plan | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 409 | // Step 5: Chain all CTEs in correct dependency order | COMMENT |
| LOW | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 581 | // Step 1: replace column bindings in join conditions. | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 598 | // Step 2: rebuild a join tree from remaining relations (structure only). | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 608 | // Step 3: put all conditions into a single Filter above the join tree. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/selfhost/restore_logs.sh | 510 | # Step 1: Generate download URL | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 521 | # Step 2: Download backup | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 534 | # Step 3: Extract archive | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 543 | # Step 4: Detect path prefix | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 566 | # Step 5: Upload files | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 613 | # Step 6: Restore database | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 639 | # Step 1: Create table by inferring schema from parquet files | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 647 | # Step 2: Copy data with error checking | COMMENT |
| LOW⚡ | scripts/selfhost/restore_logs.sh | 655 | # Step 3: Verify and report row count | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 177 | // Step 1: Create a new semaphore entry with the key format `{prefix}/queue/{seq:020}`. | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 192 | // Step 2: The sem entry is inserted, keep it alive by extending the lease. | COMMENT |
| LOW | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 214 | // Step 3: Wait for the semaphore to be acquired or removed. | COMMENT |
| LOW⚡ | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 288 | // Step 1: Get a new globally unique sequence number. | COMMENT |
| LOW⚡ | src/meta/plugins/semaphore/src/acquirer/acquirer.rs | 293 | // Step 2: Create a new semaphore entry with the key format `{prefix}/queue/{seq:020}`. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 126 | // Step 1: validate carried windows against the fresh snapshot. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 159 | // Step 2: scan this fixed range, excluding still-carried windows. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 328 | // Step 3: choose task candidates. If early accept fills the budget, | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 382 | // Step 4: build ReclusterParts from selected candidates. | COMMENT |
| LOW | src/query/storages/fuse/src/operations/recluster.rs | 401 | // Step 5: stable range, advance to the next fixed scan range. | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1344 | // Step 1: Build probe and build sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1349 | // Step 2: Prepare column projections | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1353 | // Step 3: unify exchange keys | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1356 | // Step 4: Prepare schemas for both sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1360 | // Step 5: Process join conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1376 | // Step 6: Prepare projections and cache info | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1386 | // Step 7: Create merged fields | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1396 | // Step 8: Create merged schema for non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1399 | // Step 9: Create output schema | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1403 | // Step 10: Process non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1406 | // Step 11: Build runtime filter | COMMENT |
| LOW | …query/service/src/physical_plans/physical_hash_join.rs | 1421 | // Step 12: Create and return the HashJoin | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 130 | // Step 1: Tokenize the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 168 | // Step 2: Parse the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 250 | // Step 3: Bind AST with catalog, and generate a pure logical SExpr | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 283 | // Step 4: Optimize the SExpr with optimizers, and generate optimized physical SExpr | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 50 | // Step 1: Set the initial distribution requirement (Any) | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 55 | // Step 2: Enforce the property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 59 | // Step 3: Apply the sort and limit push down optimization | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 62 | // Step 4: Check if the result satisfies the required distribution property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 69 | // Step 5: If not satisfied, manually enforce serial distribution | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 256 | // Step 1: Check if we need an original input CTE | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 273 | // Step 2: Create CTEs for grouping sets, organizing by dependency levels for parallelization | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 396 | // Step 3: Build final union branches | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 405 | // Step 4: Assemble the complete plan | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 409 | // Step 5: Chain all CTEs in correct dependency order | COMMENT |
| LOW | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 581 | // Step 1: replace column bindings in join conditions. | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 598 | // Step 2: rebuild a join tree from remaining relations (structure only). | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 608 | // Step 3: put all conditions into a single Filter above the join tree. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/cloud_control_server/resource_pb2_grpc.py | 4 | CODE | |
| LOW | tests/cloud_control_server/timestamp_pb2_grpc.py | 4 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2.py | 16 | CODE | |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 10 | CODE | |
| LOW | tests/suites/5_ee/02_data_mask/02_0000_data_mask.py | 11 | CODE | |
| LOW | …2_query/02_0012_temp_table_external_session_cleanup.py | 13 | CODE | |
| LOW | …2_query/02_0012_temp_table_external_session_cleanup.py | 14 | CODE | |
| LOW | …sts/suites/1_stateful/02_query/02_0006_set_priority.py | 4 | CODE | |
| LOW | …sts/suites/1_stateful/02_query/02_0006_set_priority.py | 7 | CODE | |
| LOW | tests/suites/1_stateful/02_query/02_0000_kill_query.py | 7 | CODE | |
| LOW | …stateful/02_query/02_0011_explain_analyze_part_info.py | 11 | CODE | |
| LOW | …0_stateless/20+_others/20_0008_mysql_client_command.py | 5 | CODE | |
| LOW | …suites/0_stateless/00_dummy/00_0002_dummy_select_py.py | 5 | CODE | |
| LOW | …ites/0_stateless/03_dml/03_0015_insert_into_select2.py | 5 | CODE | |
| LOW | tests/metactl/metactl_utils.py | 8 | CODE | |
| LOW | tests/metactl/utils.py | 6 | CODE | |
| LOW | tests/metactl/subcommands/cmd_status.py | 5 | CODE | |
| LOW | tests/metactl/subcommands/cmd_upsert.py | 6 | CODE | |
| LOW | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 6 | CODE | |
| LOW | tests/metactl/subcommands/cmd_lua.py | 5 | CODE | |
| LOW | tests/nox/suites/http_handler/test_large_row.py | 2 | CODE | |
| LOW | tests/nox/suites/http_handler/test_retry_start_query.py | 5 | CODE | |
| LOW | tests/nox/suites/http_handler/test_forward.py | 2 | CODE | |
| LOW | tests/sqllogictests/suites/tpcds/validate_duckdb.py | 5 | CODE | |
| LOW | tests/sqllogictests/suites/tpch/validate_duckdb.py | 3 | CODE | |
| LOW | …sts/sqllogictests/scripts/prepare_iceberg_tpch_data.py | 2 | CODE | |
| LOW | tests/udf/sandbox_udf.py | 7 | CODE | |
| LOW | tests/data/avro/gen_logical.py | 2 | CODE | |
| LOW | tests/data/parquet/timestamp/gen.py | 1 | CODE | |
| LOW | tests/helpers/client.py | 3 | CODE | |
| LOW | tests/helpers/client.py | 5 | CODE | |
| LOW | tests/helpers/client.py | 8 | CODE | |
| LOW | tests/helpers/client.py | 9 | CODE | |
| LOW | tests/helpers/uexpect.py | 17 | CODE | |
| LOW | scripts/benchmark/analyze_histogram_bench.py | 13 | CODE | |
| LOW | scripts/benchmark/analyze_frequency_stats_bench.py | 14 | CODE | |
| LOW | …/security_policy/run_security_policy_bench_with_bin.py | 10 | CODE | |
| LOW | …/security_policy/run_security_policy_bench_with_bin.py | 20 | CODE | |
| LOW | scripts/security_policy/security_policy_bench.py | 9 | CODE | |
| LOW | scripts/security_policy/security_policy_bench.py | 19 | CODE | |
| LOW | scripts/security_policy/security_policy_bench.py | 19 | CODE | |
| LOW | scripts/ci/ci-check-query-log-duplicates.py | 10 | CODE | |
| LOW | scripts/bench_common/runner.py | 4 | CODE | |
| LOW | scripts/bench_common/bendsql.py | 4 | CODE | |
| LOW | scripts/bench_common/bendsql.py | 12 | CODE | |
| LOW | scripts/bench_common/__init__.py | 4 | CODE | |
| LOW | scripts/bench_common/__init__.py | 5 | CODE | |
| LOW | scripts/bench_common/__init__.py | 6 | CODE | |
| LOW | scripts/bench_common/__init__.py | 7 | CODE | |
| LOW | scripts/bench_common/__init__.py | 8 | CODE | |
| LOW | scripts/bench_common/__init__.py | 9 | CODE | |
| LOW | scripts/bench_common/__init__.py | 10 | CODE | |
| LOW | scripts/bench_common/__init__.py | 11 | CODE | |
| LOW | scripts/bench_common/__init__.py | 12 | CODE | |
| LOW | scripts/bench_common/__init__.py | 13 | CODE | |
| LOW | scripts/bench_common/__init__.py | 14 | CODE | |
| LOW | scripts/bench_common/__init__.py | 15 | CODE | |
| LOW | …abend_test_helper/src/databend_test_helper/__init__.py | 15 | CODE | |
| LOW | …abend_test_helper/src/databend_test_helper/__init__.py | 16 | CODE | |
| LOW | …abend_test_helper/src/databend_test_helper/__init__.py | 17 | CODE | |
| 21 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/cloud_control_server/notification_pb2_grpc.py | 129 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | tests/cloud_control_server/task_pb2_grpc.py | 177 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | tests/cloud_control_server/resource_pb2_grpc.py | 116 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | tests/metactl/test_all_subcommands.py | 70 | # Create a mapping for easier lookup | COMMENT |
| MEDIUM | tests/metactl/subcommands/cmd_lua.py | 14 | # Create a temporary Lua script | COMMENT |
| MEDIUM | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 129 | # Create a temporary Lua script | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_large_row.py | 4 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_session.py | 12 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_json_response.py | 5 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_error_detail.py | 5 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_invalid_utf8.py | 3 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_concurrent_query.py | 4 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_kill.py | 4 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_token.py | 15 | # Define the URLs and credentials | COMMENT |
| MEDIUM | tests/nox/suites/http_handler/test_route_error.py | 6 | # Define the URLs and credentials | COMMENT |
| MEDIUM | …sts/nox/suites/http_handler/test_sql_ends_semicolon.py | 5 | # Define the URLs and credentials | COMMENT |
| MEDIUM | …sts/sqllogictests/scripts/prepare_iceberg_test_data.py | 119 | # Create an Iceberg v3 table with a physical variant column. Databend should be | COMMENT |
| MEDIUM | src/bendpy/examples/sql-to-pandas.py | 43 | # Create a chart | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tests/cloud_control_server/notification_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | tests/cloud_control_server/task_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | tests/cloud_control_server/resource_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | tests/cloud_control_server/timestamp_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | tests/cloud_control_server/notification_pb2_grpc.py | 0 | missing associated documentation comment in .proto file. | STRING |
| HIGH | tests/cloud_control_server/task_pb2_grpc.py | 0 | missing associated documentation comment in .proto file. | STRING |
| HIGH | tests/cloud_control_server/resource_pb2_grpc.py | 0 | missing associated documentation comment in .proto file. | STRING |
| HIGH | …databend_test_helper/src/databend_test_helper/query.py | 0 | parse config file to extract settings, applying cli overrides. | STRING |
| HIGH | …databend_test_helper/src/databend_test_helper/utils.py | 0 | parse config file to extract settings, applying cli overrides. | STRING |
| HIGH | …/databend_test_helper/src/databend_test_helper/meta.py | 0 | parse config file to extract settings, applying cli overrides. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | benchmark/wait_tcp.py | 19 | except Exception: | CODE |
| LOW | tests/compat_fuse/test_compat_fuse.py | 382 | except Exception as e: | CODE |
| LOW | tests/compat_fuse/test_compat_fuse.py | 516 | except Exception as e: | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 816 | except Exception as exc: | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 831 | except Exception as exc: | CODE |
| LOW | tests/compat/meta_meta/test_meta_meta.py | 523 | except Exception as e: | CODE |
| LOW | …2_query/02_0012_temp_table_external_session_cleanup.py | 110 | except Exception as e: | CODE |
| LOW | …suites/1_stateful/02_query/02_0013_async_table_hook.py | 304 | except Exception: | STRING |
| LOW | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 65 | except Exception: | CODE |
| LOW | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 69 | except Exception: | CODE |
| LOW | tests/metactl/utils.py | 50 | except Exception: | CODE |
| LOW | tests/metactl/test_all_subcommands.py | 98 | except Exception as e: | CODE |
| LOW | tests/metactl/test_all_subcommands.py | 128 | except Exception as e: | CODE |
| MEDIUM | tests/metactl/run_lua_benchmark.py | 64 | print(f"Error running Lua script: {e}") | CODE |
| MEDIUM | tests/metactl/subcommands/cmd_lua_admin_metrics.py | 44 | print("Error handling works correctly") | CODE |
| LOW | tests/longrun/longrun.py | 66 | except Exception as e: | CODE |
| LOW | tests/metaverifier/chaos-meta.py | 51 | except Exception as e: | CODE |
| LOW | tests/metaverifier/chaos-meta.py | 62 | except Exception as e: | CODE |
| LOW | tests/nox/suites/copy/copy_utils.py | 30 | except Exception as ex: | CODE |
| MEDIUM | tests/nox/suites/copy/copy_utils.py | 18 | def run(conn, sql): | CODE |
| LOW | tests/nox/suites/copy/test_csv.py | 48 | except Exception as e: | CODE |
| LOW | tests/nox/suites/copy/test_csv.py | 92 | except Exception as e: | CODE |
| LOW | tests/fuzz/fuzz.py | 41 | except Exception as err: | CODE |
| LOW | tests/logging/check_logs.py | 25 | except Exception: | CODE |
| LOW | tests/logging/check_logs.py | 48 | except Exception: | CODE |
| LOW | scripts/benchmark/meta-cluster-bench.py | 296 | except Exception as e: | STRING |
| LOW | scripts/benchmark/meta-cluster-bench.py | 501 | except Exception as e: | STRING |
| LOW | scripts/benchmark/meta-cluster-bench.py | 519 | except Exception as e: | STRING |
| LOW | scripts/ci/wait_tcp.py | 20 | except Exception: | CODE |
| LOW | scripts/devops-meta/collect_meta_logs.py | 97 | except Exception as e: | CODE |
| LOW | scripts/devops-meta/collect_meta_logs.py | 162 | except Exception as e: | CODE |
| LOW | scripts/devops-meta/collect_meta_logs.py | 252 | except Exception as e: | CODE |
| MEDIUM | scripts/devops-meta/collect_meta_logs.py | 253 | print(f"Error: {e}", file=sys.stderr) | CODE |
| LOW | …_test_helper/src/databend_test_helper/query_cluster.py | 144 | except Exception as e: | CODE |
| LOW | …databend_test_helper/src/databend_test_helper/utils.py | 25 | except Exception as e: | CODE |
| LOW | …/databend_test_helper/src/databend_test_helper/meta.py | 83 | except Exception as e: | CODE |
| LOW | scripts/test-bend-tests/concurrent_sql_test.py | 115 | except Exception as e: | CODE |
| LOW | scripts/test-bend-tests/concurrent_sql_test.py | 300 | except Exception as e: | CODE |
| LOW | src/bendpy/python/databend/__init__.py | 238 | except Exception as exc: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 134 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 163 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 192 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 221 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 250 | CODE | |
| LOW | tests/cloud_control_server/notification_pb2_grpc.py | 279 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 182 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 211 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 240 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 269 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 298 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 327 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 356 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 385 | CODE | |
| LOW | tests/cloud_control_server/task_pb2_grpc.py | 414 | CODE | |
| LOW | tests/cloud_control_server/resource_pb2_grpc.py | 121 | CODE | |
| LOW | tests/cloud_control_server/resource_pb2_grpc.py | 148 | CODE | |
| LOW | tests/cloud_control_server/resource_pb2_grpc.py | 175 | CODE | |
| LOW | tests/cloud_control_server/resource_pb2_grpc.py | 202 | CODE | |
| LOW | tests/metactl/metactl_utils.py | 28 | CODE | |
| LOW | tests/metactl/metactl_utils.py | 36 | CODE | |
| LOW | tests/nox/suites/http_handler/test_cookie.py | 35 | CODE | |
| LOW | tests/nox/suites/http_handler/test_session.py | 79 | CODE | |
| LOW | tests/nox/suites/http_handler/test_session.py | 91 | CODE | |
| LOW | tests/nox/suites/http_handler/test_session.py | 106 | CODE | |
| LOW | tests/nox/suites/http_handler/test_forward.py | 23 | CODE | |
| LOW | tests/nox/suites/http_handler/test_token.py | 63 | CODE | |
| LOW | tests/nox/suites/http_handler/test_token.py | 72 | CODE | |
| LOW | tests/nox/suites/http_handler/test_token.py | 113 | CODE | |
| LOW | tests/nox/suites/http_handler/test_token.py | 127 | CODE | |
| LOW | tests/nox/suites/http_handler/test_query_lifecycle.py | 94 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/metactl/config/databend-meta-node-2.toml | 1 | # Usage: | COMMENT |
| LOW | tests/metactl/config/new-databend-meta-node-3.toml | 1 | # Usage: | COMMENT |
| LOW | tests/metactl/config/new-databend-meta-node-2.toml | 1 | # Usage: | COMMENT |
| LOW | tests/metactl/config/databend-meta-node-3.toml | 1 | # Usage: | COMMENT |
| LOW | tests/metactl/config/new-databend-meta-node-1.toml | 1 | # Usage: | COMMENT |
| LOW | tests/metactl/config/databend-meta-node-1.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-meta-node-2.toml | 1 | # Usage: | COMMENT |
| LOW | …s/ci/deploy/config/databend-query-management-mode.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-1.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-meta-node-3.toml | 1 | # Usage: | COMMENT |
| LOW | …/ci/deploy/config/databend-meta-node-for-bendsave.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-hive.toml | 1 | # Usage: | COMMENT |
| LOW | …ts/ci/deploy/config/databend-query-node-otlp-logs.toml | 1 | # Usage: | COMMENT |
| LOW | …/deploy/config/databend-query-node-system-managed.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-2.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-meta-node-1.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/ci/deploy/config/databend-query-node-3.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/distribution/configs/databend-meta.toml | 1 | # Usage: | COMMENT |
| LOW | scripts/distribution/configs/databend-query.toml | 1 | # Usage: | COMMENT |
| LOW | src/query/sql/src/planner/optimizer/ir/expr/visitor.rs | 83 | //! // Usage example: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/compat_fuse/test_compat_fuse.py | 352 | CODE | |
| LOW | tests/cloud_control_server/simple_server.py | 509 | CODE | |
| LOW | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 41 | CODE | |
| LOW | tests/metactl/run_lua_benchmark.py | 24 | CODE | |
| LOW | tests/metactl/subcommands/cmd_transfer_leader.py | 10 | CODE | |
| LOW | tests/metactl/subcommands/cmd_status.py | 9 | CODE | |
| LOW | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 11 | CODE | |
| LOW | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 82 | CODE | |
| LOW | tests/metactl/subcommands/cmd_export_from_grpc.py | 10 | CODE | |
| LOW | tests/metactl/subcommands/cmd_export_from_grpc.py | 78 | CODE | |
| LOW | tests/metaverifier/chaos-meta.py | 262 | CODE | |
| LOW | tests/sqllogictests/suites/tpcds/validate_duckdb.py | 51 | CODE | |
| LOW | tests/sqllogictests/suites/tpch/validate_duckdb.py | 48 | CODE | |
| LOW | tests/logging/check_logs.py | 16 | CODE | |
| LOW | tests/logging/check_logs.py | 37 | CODE | |
| LOW | scripts/benchmark/meta-cluster-bench.py | 455 | CODE | |
| LOW | scripts/benchmark/meta-cluster-bench.py | 509 | CODE | |
| LOW | scripts/benchmark/meta-cluster-bench.py | 525 | CODE | |
| LOW | scripts/benchmark/analyze_frequency_stats_bench.py | 226 | CODE | |
| LOW | scripts/security_policy/security_policy_bench.py | 503 | CODE | |
| LOW | scripts/ci/ci-check-query-log-duplicates.py | 23 | CODE | |
| LOW | scripts/devops-meta/collect_meta_logs.py | 53 | CODE | |
| LOW | …_test_helper/src/databend_test_helper/query_cluster.py | 41 | CODE | |
| LOW | scripts/test-bend-tests/test_cluster.py | 15 | CODE | |
| LOW | scripts/recluster/recluster_bench.py | 208 | CODE | |
| LOW | src/bendpy/python/databend/__init__.py | 128 | CODE | |
| LOW | src/meta/ver/compat_docs/scripts/extract_from_git.py | 87 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/compat_fuse/test_compat_fuse.py | 363 | # Check if binaries already exist | COMMENT |
| LOW | …2_query/02_0012_temp_table_external_session_cleanup.py | 90 | # Check if files were cleaned up | COMMENT |
| LOW | …/suites/1_stateful/02_query/02_0009_explain_profile.sh | 24 | # Check if statistics has enough data (17 elements) | COMMENT |
| LOW | …ts/suites/9_faked_time/00_dummy_cases/00_0001_dummy.sh | 24 | # Check if time difference is greater than 2 days | COMMENT |
| LOW | …ts/suites/0_stateless/20+_others/20_0022_agg_memory.sh | 41 | # Check if the difference is less than 5% | STRING |
| LOW | tests/metactl/subcommands/cmd_status.py | 50 | # Check if Node info exists with expected format | COMMENT |
| LOW | scripts/selfhost/upload_log.sh | 106 | # Check if file exists | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 291 | # Check if it's time for auto-refresh (30 seconds) | COMMENT |
| LOW | scripts/selfhost/restore_logs.sh | 494 | # Check if local file exists | COMMENT |
| LOW | scripts/devops-meta/databend-meta-diagnostics.sh | 103 | # Check if databend processes were killed by OOM | COMMENT |
| LOW | scripts/devops-meta/databend-meta-diagnostics.sh | 318 | # Check if processes are running | COMMENT |
| LOW | scripts/test-bend-tests/test_cluster.py | 20 | # Check if configs exist | COMMENT |
| LOW | scripts/test-bend-tests/test_cluster.py | 29 | # Check if config subdirectories exist | COMMENT |
| LOW | scripts/test-bend-tests/test_cluster.py | 83 | # Check if dry-run argument is passed | COMMENT |
| LOW | scripts/test-bend-tests/test_cluster.py | 153 | # Check if cluster is still healthy (every 10 seconds) | COMMENT |
| LOW | src/common/column/src/binview/view.rs | 328 | /// # Check if any slice of `values` between two consecutive pairs from `offsets` is invalid `utf8` | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/common/base/tests/it/string.rs | 116 | + &"(1, 'John Doe', 'john@example.com'), ".repeat(5); // Make sure this creates a string longer than 128 charact | CODE |
| LOW | src/common/base/tests/it/string.rs | 141 | " INSERT INTO users (id, name, email) VALUES (1, 'John Doe', 'john@example.com');" | CODE |
| LOW | …le_functions/function_template/simple_func_template.rs | 45 | #[typetag::serde(name = "placeholder")] | COMMENT |
| LOW | src/query/functions/tests/it/scalars/regexp.rs | 707 | "regexp_extract('John Doe', '([A-Za-z]+) ([A-Za-z]+)', 1)", | CODE |
| LOW | src/query/functions/tests/it/scalars/regexp.rs | 714 | StringType::from_data(vec!["John Doe", "James Davis", "Lisa Taylor"]), | CODE |
| LOW⚡ | …c/query/functions/tests/it/scalars/testdata/regexp.txt | 1036 | ast : regexp_extract('John Doe', '([A-Za-z]+) ([A-Za-z]+)', 1) | CODE |
| LOW⚡ | …c/query/functions/tests/it/scalars/testdata/regexp.txt | 1037 | raw expr : regexp_extract('John Doe', '([A-Za-z]+) ([A-Za-z]+)', 1) | CODE |
| LOW⚡ | …c/query/functions/tests/it/scalars/testdata/regexp.txt | 1038 | checked expr : regexp_extract<String, String, UInt32>("John Doe", "([A-Za-z]+) ([A-Za-z]+)", CAST<UInt8>(1_u8 AS UInt3 | CODE |
| LOW | …c/query/functions/tests/it/scalars/testdata/regexp.txt | 1055 | | Row 0 | 'John Doe' | 'John' | | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | .github/scripts/check_pr_title.js | 37 | if (context.payload.pull_request.base.ref.startsWith("backport/")) { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | benchmark/update_results.py | 15 | logger = logging.getLogger(__name__) | CODE |
| LOW | benchmark/benchmark_cloud_load.py | 17 | logger = logging.getLogger(__name__) | CODE |
| LOW | benchmark/benchmark_cloud_load.py | 64 | def set_dsn(self, dsn: str) -> None: | CODE |
| LOW | tests/logging/check_logs.py | 12 | logger = logging.getLogger(__name__) | CODE |
| LOW | scripts/bench_common/__init__.py | 17 | __all__ = [ | CODE |
| LOW | …abend_test_helper/src/databend_test_helper/__init__.py | 23 | __all__ = [ | CODE |
| LOW | …abend_test_helper/src/databend_test_helper/progress.py | 12 | def set_enabled(cls, enabled: bool) -> None: | CODE |
| LOW | src/bendpy/python/databend/__init__.py | 261 | __all__ = [ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/meta/app/src/tenant/uninit_tenant.rs | 40 | // TODO: implement config | COMMENT |
| LOW | src/query/settings/src/settings.rs | 324 | // TODO: Handle error properly - for now, panic in case of error | COMMENT |