Data Agent Ready Warehouse : One for Analytics, Search, AI, Python Sandbox. — rebuilt from scratch. Unified architecture on your S3.
This report summarizes scanner evidence for databendlabs/databend, a Rust project with 9,458 GitHub stars. SynthScan examined 1,225,782 lines of code across 5243 source files, recording 5142 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 4.9 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 4823 finding(s).
Are imports declared and package/API names verified? 126 finding(s).
Are wrappers, guards, and repeated structures necessary? 348 finding(s).
Which changes need focused human review? 5142 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 5142 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ruff.toml | 61 | COMMENT | |
| LOW | benchmark/mv_planner_cache/run.sh | 1 | #!/usr/bin/env bash | 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/scripts/gen_mutation_key_matrix.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tests/sqllogictests/scripts/gen_type_matrix.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tests/sqllogictests/scripts/docker-compose-paimon.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | tests/sqllogictests/scripts/gen_table_kind_matrix.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tests/sqllogictests/src/hook.rs | 1 | // Copyright 2021 Datafuse Labs | 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/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/settings_matrix.rs | 1 | // Copyright 2021 Datafuse Labs | COMMENT |
| LOW | tests/sqllogictests/src/settings_matrix.rs | 21 | //! # run-with-settings: enable_fixed_rows_sort=0 | 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/fuzz/tlp.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tests/helpers/uexpect.py | 1 | # Copyright (c) 2019 Vitaliy Zakaznikov | 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/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 |
| 4399 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 | 72 | // ┌─────────────────────────┐ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 74 | // │ └─────────────────────────┘ │ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 76 | // ┌─────────────────────┐ │ ┌─────────────────────────┐ │ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 78 | // └─────────────────────┘ │ └─────────────────────────┘ │ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 80 | // │ ┌─────────────────────────┐ │ | COMMENT |
| MEDIUM⚡ | …c/query/storages/fuse/src/operations/inverted_index.rs | 82 | // └─────────────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 37 | // ┌──────────────────────┐ ┌──────────────────┐ ┌────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 38 | // │ ├──┬────────►│ SerializeBlock ├──────────────►│SerializeSegment├─── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 39 | // ┌─────────────┐ │ ├──┘ └──────────────────┘ └────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 40 | // │ UpsertSource├─────►│ ReplaceIntoProcessor │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 41 | // └─────────────┘ │ ├──┐ ┌───────────────────┐ ┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 42 | // │ ├──┴────────►│ ├──┬──────────►│MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 43 | // └──────────────────────┘ │ ├──┘ └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 44 | // │ BroadcastProcessor│ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 45 | // │ ├──┐ ┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 46 | // │ ├──┴──────────►│MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 47 | // │ │ └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 49 | // │ ├──┴──────────►┌──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 50 | // └───────────────────┘ │MergeIntoOperationAg | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 51 | // └──────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 58 | // ┌──────────────────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 61 | // │ ┌───────────────────┐ ┌───────────────────────┐ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 62 | // └─────►│ResizeProcessor(1) ├──────►│TableMutationAggregator├────────►│ CommitSink │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 63 | // └───────────────────┘ └───────────────────────┘ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 69 | // ┌──────────────────────┐ ┌─────────────────┐ ┌─────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 70 | // │ ├──┬────────►│ SerializeBlock ├────────►│SerializeSegment ├───────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 71 | // ┌─────────────┐ │ ├──┘ └─────────────────┘ └─────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 72 | // │ UpsertSource├─────►│ ReplaceIntoProcessor │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 73 | // └─────────────┘ │ ├──┐ ┌─────────────────┐ ┌─────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 74 | // │ ├──┴────────►│ DummyTransform ├────────►│ DummyTransform ├───────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 75 | // └──────────────────────┘ └─────────────────┘ └─────────────────┘ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 79 | // ┌─────────────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 82 | // │ ┌───────────────────┐ ┌───────────────────────┐ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 83 | // └─────►│ResizeProcessor(1) ├──────►│TableMutationAggregator├────────►│ CommitSink │ | COMMENT |
| MEDIUM⚡ | src/query/storages/fuse/src/operations/replace.rs | 84 | // └───────────────────┘ └───────────────────────┘ └───────────────────┘ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 40 | // ┌────────┐ ┌────────┐ ┌────────┐ ┌────────┐ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 42 | // └────────┘ └────────┘ └────────┘ └────────┘ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 45 | // ┌────────┐ ┌────────┐ ┌────────┐ ┌────────┐ | COMMENT |
| MEDIUM⚡ | …ery/storages/fuse/src/pruning/inverted_index_pruner.rs | 47 | // └────────┘ └────────┘ └────────┘ └────────┘ | 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 |
| 61 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/sqllogic/hooks.py | 283 | "mysqladmin ping -h 127.0.0.1 --silent && break; sleep 1; done; " | CODE |
| HIGH | tests/nox/sqllogic/hooks.py | 284 | "mysqladmin ping -h 127.0.0.1 --silent || exit 1; " | CODE |
| HIGH⚡ | tests/nox/sqllogic/hooks.py | 301 | "for _ in $(seq 1 60); do redis-cli ping >/dev/null && break; " | CODE |
| HIGH⚡ | tests/nox/sqllogic/hooks.py | 302 | "sleep 1; done; redis-cli ping >/dev/null || exit 1; " | 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 |
|---|---|---|---|---|
| LOW | tests/compat_fuse/test_compat_fuse.py | 275 | def install_enterprise_license(self) -> None: | CODE |
| 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 | 444 | def create_task_run_from_task(task): | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 468 | 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_secured.py | 144 | def check_credential_rotation( | CODE |
| LOW | tests/metactl/subcommands/cmd_secured.py | 152 | def check_authentication_failures( | CODE |
| LOW | tests/metactl/subcommands/cmd_secured_consumers.py | 302 | def check_no_password_in_logs(node: QueryNode) -> None: | CODE |
| LOW | tests/metactl/subcommands/cmd_raft_tls.py | 133 | def check_peer_traffic_uses_tls(cluster: LocalMetaCluster) -> None: | 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.py | 58 | def test_lua_sources_in_order(): | 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 | 89 | def resolve_latest_release_tag(latest_release_url, expected_prefix="v"): | CODE |
| LOW | tests/nox/noxfile.py | 199 | def resolve_python_driver_version(driver_version): | CODE |
| LOW | tests/nox/noxfile.py | 206 | def prepare_python_client_source(): | CODE |
| LOW | tests/nox/noxfile.py | 313 | def prepare_jdbc_release_artifacts(source_ref): | CODE |
| LOW | tests/nox/noxfile.py | 339 | def discover_jdbc_test_classes(test_jar): | CODE |
| LOW | tests/nox/noxfile.py | 379 | def prepare_jdbc_test_output_dir(resolved_ref): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 36 | def test_duckdb_cache_requires_nonempty_table_files(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 48 | def test_generate_duckdb_data_reuses_valid_cache(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 60 | def test_generate_duckdb_data_rebuilds_invalid_cache(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 87 | def test_databend_dsn_uses_local_handler_environment(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 102 | def test_run_hook_closes_databend_connection(self): | CODE |
| LOW⚡ | tests/nox/sqllogic/test_hooks.py | 113 | def test_data_is_loaded_skips_queries_when_force_load_is_enabled(self): | CODE |
| LOW⚡ | tests/nox/sqllogic/test_hooks.py | 121 | def test_data_is_loaded_requires_an_existing_nonempty_table(self): | CODE |
| LOW⚡ | tests/nox/sqllogic/test_hooks.py | 131 | def test_prepare_tpch_uses_python_generated_data(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 150 | def test_prepare_tpcds_uses_python_generated_data(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 165 | def test_prepare_stage_maps_environment_to_sql(self): | CODE |
| LOW | tests/nox/sqllogic/test_hooks.py | 182 | def test_execute_script_sends_one_statement_at_a_time(self): | 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_active_temp_table_survives_vacuum(): | CODE |
| LOW | tests/nox/suites/http_handler/test_cookie.py | 124 | 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 | 419 | 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 |
| 64 more matches not shown… | ||||
| 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 | src/query/storages/parquet/src/parquet_part.rs | 175 | /// 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 | 172 | 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 | 197 | 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 | 332 | // resolve the ability to utilize name | COMMENT |
| MEDIUM | src/query/sql/src/planner/plans/join.rs | 584 | // utilize the distribution on the probe side. | COMMENT |
| MEDIUM | src/query/sql/src/planner/plans/aggregate.rs | 275 | // `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 | 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 | 144 | // NULL frame is a special RANGE frame, we need to check if the frame is a null frame. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 186 | // Step 1: validate carried windows against the fresh snapshot. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 227 | // Step 2: scan this fixed range, excluding still-carried windows. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 403 | // Step 3: choose task candidates. Preserve score-only ranking unless | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 455 | // Step 4: build ReclusterParts from selected candidates. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 487 | // Step 5: stable range, advance to the next scan range. | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1293 | // Step 1: Build probe and build sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1298 | // Step 2: Prepare column projections | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1302 | // Step 3: unify exchange keys | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1305 | // Step 4: Prepare schemas for both sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1309 | // Step 5: Process join conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1325 | // Step 6: Prepare projections and cache info | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1335 | // Step 7: Create merged fields | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1345 | // Step 8: Create merged schema for non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1348 | // Step 9: Create output schema | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1352 | // Step 10: Process non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1355 | // Step 11: Build runtime filter | COMMENT |
| LOW | …query/service/src/physical_plans/physical_hash_join.rs | 1370 | // Step 12: Create and return the HashJoin | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 156 | // Step 1: Tokenize the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 194 | // Step 2: Parse the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 306 | // Step 3: Bind AST with catalog, and generate a pure logical SExpr | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 349 | // Step 4: Optimize logical inputs, then select and finalize query implementations. | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 49 | // Step 1: Set the initial distribution requirement (Any) | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 54 | // Step 2: Enforce the property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 58 | // Step 3: Check if the result satisfies the required distribution property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 65 | // Step 4: If not satisfied, manually enforce serial distribution | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 264 | // Step 1: Check if we need an original input CTE | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 281 | // Step 2: Create CTEs for grouping sets, organizing by dependency levels for parallelization | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 404 | // Step 3: Build final union branches | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 413 | // Step 4: Assemble the complete plan | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 417 | // Step 5: Chain all CTEs in correct dependency order | COMMENT |
| LOW | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 664 | // Step 1: replace column bindings in join conditions. | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 681 | // Step 2: rebuild a join tree from remaining relations (structure only). | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 691 | // 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 | …rages/fuse/src/operations/recluster/recluster_table.rs | 186 | // Step 1: validate carried windows against the fresh snapshot. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 227 | // Step 2: scan this fixed range, excluding still-carried windows. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 403 | // Step 3: choose task candidates. Preserve score-only ranking unless | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 455 | // Step 4: build ReclusterParts from selected candidates. | COMMENT |
| LOW | …rages/fuse/src/operations/recluster/recluster_table.rs | 487 | // Step 5: stable range, advance to the next scan range. | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1293 | // Step 1: Build probe and build sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1298 | // Step 2: Prepare column projections | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1302 | // Step 3: unify exchange keys | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1305 | // Step 4: Prepare schemas for both sides | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1309 | // Step 5: Process join conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1325 | // Step 6: Prepare projections and cache info | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1335 | // Step 7: Create merged fields | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1345 | // Step 8: Create merged schema for non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1348 | // Step 9: Create output schema | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1352 | // Step 10: Process non-equi conditions | COMMENT |
| LOW⚡ | …query/service/src/physical_plans/physical_hash_join.rs | 1355 | // Step 11: Build runtime filter | COMMENT |
| LOW | …query/service/src/physical_plans/physical_hash_join.rs | 1370 | // Step 12: Create and return the HashJoin | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 156 | // Step 1: Tokenize the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 194 | // Step 2: Parse the SQL. | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 306 | // Step 3: Bind AST with catalog, and generate a pure logical SExpr | COMMENT |
| LOW | src/query/sql/src/planner/planner.rs | 349 | // Step 4: Optimize logical inputs, then select and finalize query implementations. | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 49 | // Step 1: Set the initial distribution requirement (Any) | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 54 | // Step 2: Enforce the property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 58 | // Step 3: Check if the result satisfies the required distribution property | COMMENT |
| LOW⚡ | …lanner/optimizer/optimizers/distributed/distributed.rs | 65 | // Step 4: If not satisfied, manually enforce serial distribution | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 264 | // Step 1: Check if we need an original input CTE | COMMENT |
| LOW | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 281 | // Step 2: Create CTEs for grouping sets, organizing by dependency levels for parallelization | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 404 | // Step 3: Build final union branches | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 413 | // Step 4: Assemble the complete plan | COMMENT |
| LOW⚡ | …zers/rule/agg_rules/rule_hierarchical_grouping_sets.rs | 417 | // Step 5: Chain all CTEs in correct dependency order | COMMENT |
| LOW | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 664 | // Step 1: replace column bindings in join conditions. | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 681 | // Step 2: rebuild a join tree from remaining relations (structure only). | COMMENT |
| LOW⚡ | …optimizers/rule/join_rules/rule_eliminate_self_join.rs | 691 | // 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 | …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/utils.py | 31 | CODE | |
| LOW | tests/metactl/utils.py | 31 | 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/nox/sqllogic/hooks.py | 7 | 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 | tests/sqllogictests/scripts/gen_type_matrix.py | 37 | CODE | |
| LOW | tests/sqllogictests/scripts/gen_table_kind_matrix.py | 38 | CODE | |
| LOW | …sts/sqllogictests/scripts/prepare_iceberg_tpch_data.py | 2 | CODE | |
| LOW | tests/sqllogictests/scripts/prepare_paimon_fs_data.py | 8 | CODE | |
| LOW | tests/udf/sandbox_udf.py | 7 | CODE | |
| LOW | tests/fuzz/tlp.py | 48 | 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 | |
| 16 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 37 | except mysql_errors.InterfaceError: | CODE |
| HIGH | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 69 | except Exception: | CODE |
| HIGH | tests/metactl/utils.py | 171 | except subprocess.CalledProcessError: | CODE |
| HIGH | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 87 | except: | CODE |
| HIGH | tests/metactl/subcommands/cmd_export_from_raft_dir.py | 99 | except: | CODE |
| HIGH | tests/metactl/subcommands/cmd_export_from_grpc.py | 83 | except: | CODE |
| HIGH | tests/metactl/subcommands/cmd_export_from_grpc.py | 95 | except: | CODE |
| HIGH | tests/udf/sandbox_udf.py | 134 | except FileNotFoundError: | CODE |
| HIGH | tests/logging/check_logs.py | 25 | except Exception: | CODE |
| HIGH | tests/logging/check_logs.py | 48 | except Exception: | CODE |
| HIGH | …_helper/src/databend_test_helper/local_meta_cluster.py | 404 | except ProcessLookupError: | CODE |
| HIGH | …databend_test_helper/src/databend_test_helper/utils.py | 162 | except FileNotFoundError: | CODE |
| HIGH | …databend_test_helper/src/databend_test_helper/utils.py | 213 | except ProcessLookupError: | CODE |
| HIGH | src/meta/ver/compat_docs/scripts/extract_from_git.py | 60 | except subprocess.TimeoutExpired: | CODE |
| 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 | 15 | # 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 | 449 | except Exception as e: | CODE |
| LOW | tests/compat_fuse/test_compat_fuse.py | 632 | except Exception as e: | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 827 | except Exception as exc: | CODE |
| LOW | tests/cloud_control_server/simple_server.py | 842 | 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 | 158 | 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/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/noxfile.py | 162 | except Exception as exc: # noqa: BLE001 - retry Maven/GitHub flakes | CODE |
| LOW | tests/nox/noxfile.py | 423 | except Exception as exc: # noqa: BLE001 - retry Maven Central flakes | CODE |
| LOW⚡ | tests/nox/sqllogic/hooks.py | 306 | except Exception: | 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/meta-cluster-bench.py | 93 | except Exception as e: | CODE |
| LOW | scripts/benchmark/meta/meta-cluster-bench.py | 277 | except Exception as e: | CODE |
| LOW | scripts/benchmark/meta/run_lua_benchmark.py | 124 | except Exception as e: | CODE |
| 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 | 39 | CODE | |
| LOW | tests/metactl/metactl_utils.py | 47 | 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 |
|---|---|---|---|---|
| CRITICAL | .github/scripts/check_pr_title.js | 37 | if (context.payload.pull_request.base.ref.startsWith("backport/")) { | CODE |
| CRITICAL | …/src/pruning_pipeline/runtime_top_n_segment_reorder.rs | 220 | meta.segments.0.location.0.clone() | CODE |
| CRITICAL | …/storages/common/index/src/inverted_index/directory.rs | 240 | .field("files", &self.inner.footer.file_ranges.files.len()) | 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/compat_fuse/test_compat_fuse.py | 419 | CODE | |
| LOW | tests/cloud_control_server/simple_server.py | 513 | CODE | |
| LOW | …0_stateless/01_transaction/01_04_txn_snapshot_retry.py | 41 | 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/nox/noxfile.py | 144 | CODE | |
| LOW | tests/nox/sqllogic/hooks.py | 322 | CODE | |
| LOW | tests/sqllogictests/suites/tpcds/validate_duckdb.py | 51 | CODE | |
| LOW | tests/sqllogictests/suites/tpch/validate_duckdb.py | 48 | CODE | |
| LOW | tests/sqllogictests/scripts/prepare_paimon_fs_data.py | 45 | CODE | |
| LOW | tests/logging/check_logs.py | 16 | CODE | |
| LOW | tests/logging/check_logs.py | 37 | CODE | |
| LOW | scripts/benchmark/analyze_frequency_stats_bench.py | 226 | CODE | |
| LOW | scripts/benchmark/meta/meta-cluster-bench.py | 239 | 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 | 430 | # 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/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/meta/api/src/api_impl/segment_claim_api.rs | 214 | let mut at_limit = create_req("at-limit", vec!["placeholder"]); | CODE |
| LOW | src/meta/api/src/api_impl/segment_claim_api.rs | 226 | let mut over_limit = create_req("over-limit", vec!["placeholder"]); | CODE |
| 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 |
| LOW | src/query/sql/src/planner/binder/ddl/notification.rs | 284 | r#"{"no":"placeholder"}"#, | 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/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 |