The world's fastest open query engine for sub-second analytics both on and off the data lakehouse. With the flexibility to support nearly any scenario, StarRocks provides best-in-class performance for multi-dimensional analytics, real-time analytics, and ad-hoc queries. A Linux Foundation project.
This report summarizes scanner evidence for StarRocks/starrocks, a Java project with 12,165 GitHub stars. SynthScan examined 3,924,115 lines of code across 16727 source files, recording 19214 pattern matches distributed across 27 syntactic categories. The legacy adjusted pattern signal is 7.5 (Moderate 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? 17556 finding(s).
Are imports declared and package/API names verified? 1064 finding(s).
Are wrappers, guards, and repeated structures necessary? 1423 finding(s).
Which changes need focused human review? 19214 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 19214 distinct pattern matches across 27 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 | run-fe-ut.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | run-be-ut.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | build.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | build.sh | 21 | # Usage: | COMMENT |
| LOW | env.sh | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | build-in-docker.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | build-in-docker.sh | 21 | # Usage: | COMMENT |
| LOW | run-java-exts-ut.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | packaging/debian/build.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …va/com/starrocks/hudi/reader/TestHudiSliceScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …n/java/com/starrocks/hudi/reader/HudiScannerUtils.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …in/java/com/starrocks/hudi/reader/HudiColumnValue.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …n/java/com/starrocks/hudi/reader/HudiSliceScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …com/starrocks/hudi/reader/HudiSliceScannerFactory.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …st/java/com/starrocks/hive/reader/TestHiveScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …c/main/java/com/starrocks/hive/reader/HiveScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …java/com/starrocks/hive/reader/HiveScannerFactory.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …in/java/com/starrocks/hive/reader/HiveColumnValue.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …rocks/paimon/reader/TestPaimonIndexedSplitScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …om/starrocks/paimon/reader/TestPaimonSplitScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …va/com/starrocks/paimon/reader/PaimonScannerUtils.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ava/com/starrocks/paimon/reader/PaimonColumnValue.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …starrocks/paimon/reader/PaimonSplitScannerFactory.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …va/com/starrocks/paimon/reader/PaimonSplitScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/java/com/starrocks/paimon/reader/PaimonTypeUtils.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …rc/test/java/com/starrocks/udf/FunctionStatesTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/test/java/com/starrocks/udf/UDFHelperDecimalTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …src/test/java/com/starrocks/udf/UDFHelperDateTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/test/java/com/starrocks/udf/UDFClassAnalyzerTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …test/java/com/starrocks/udf/CallStubGeneratorTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/java/com/starrocks/udf/UDFHelperDirectBufferTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ns/src/main/java/com/starrocks/udf/UDFClassLoader.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …rc/main/java/com/starrocks/udf/UDFSecurityManager.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ns/src/main/java/com/starrocks/udf/FunctionStates.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/src/main/java/com/starrocks/udf/UDFClassAnalyzer.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ns/src/main/java/com/starrocks/udf/ArrowUDFHelper.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …src/main/java/com/starrocks/udf/CallStubGenerator.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …src/main/java/com/starrocks/udf/CallStubGenerator.java | 301 | // ----------------------------------------------------------------------- | COMMENT |
| LOW | …c/main/java/com/starrocks/udf/UdfTestStructRecord.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ns/src/main/java/com/starrocks/udf/UdfTestSupport.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …sions/src/main/java/com/starrocks/udf/UdfTypeDesc.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ons/src/main/java/com/starrocks/udf/ImmutableList.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ions/src/main/java/com/starrocks/udf/ImmutableMap.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ensions/src/main/java/com/starrocks/udf/UDFHelper.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ensions/src/main/java/com/starrocks/udf/UDFHelper.java | 1501 | COMMENT | |
| LOW | …/connector/iceberg/IcebergMetadataColumnValueTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …nnector/iceberg/IcebergPartitionsTableScannerTest.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ks/connector/iceberg/IcebergManifestsTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …s/connector/iceberg/IcebergPropertiesTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ocks/connector/iceberg/IcebergHistoryTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …tarrocks/connector/iceberg/IcebergMetadataScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/com/starrocks/connector/iceberg/TableFileIOCache.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …s/connector/iceberg/IcebergMetadataScannerFactory.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …nnector/iceberg/UnmodifiableCollectionsSerializer.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ocks/connector/iceberg/IcebergMetadataColumnValue.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …/connector/iceberg/AbstractIcebergMetadataScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …onnector/iceberg/IcebergMetadataLogEntriesScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …ks/connector/iceberg/IcebergSnapshotsTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …rrocks/connector/iceberg/IcebergFilesTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …arrocks/connector/iceberg/IcebergRefsTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| 15892 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 97 | Type metricsTyped = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 99 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 100 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 102 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 103 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.DOUBLE).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 107 | org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 109 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 110 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.DOUBLE) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 115 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 116 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 124 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 125 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT64) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 134 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 135 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.FIXED_LEN_BYTE_ARRAY) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 142 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 143 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 146 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 147 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 149 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 154 | Type eventObjectTyped = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 156 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 157 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 159 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 160 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 167 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 168 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value")); | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 171 | Type groupElementTyped = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 173 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 174 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 176 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 185 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 186 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT64).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 188 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 189 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 193 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 194 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT64) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 198 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 199 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 202 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 203 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 205 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 208 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 210 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 214 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 215 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.INT32).named("typed_value"))) | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 218 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 220 | org.apache.parquet.schema.Types.optional(PrimitiveTypeName.BINARY).named("value"), | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 246 | Type elementInList = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 250 | Type listGroup = org.apache.parquet.schema.Types.repeatedGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 253 | return org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 260 | Type elementGroup = org.apache.parquet.schema.Types.requiredGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 264 | Type listGroup = org.apache.parquet.schema.Types.repeatedGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 267 | return org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 290 | Type elementValueInList = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 294 | Type listGroup = org.apache.parquet.schema.Types.repeatedGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 297 | Type typedValue = org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL⚡ | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 301 | return org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL | …ats/parquet/test_data/IcebergVariantShreddingTest.java | 233 | return org.apache.parquet.schema.Types.optionalGroup() | CODE |
| CRITICAL | webroot/be/jquery-3.5.0.min.js | 2 | !function(e,t){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=e.document?t(e,!0):f | CODE |
| CRITICAL | webroot/static/jquery.dataTables.js | 14136 | * $.fn.dataTable.ext.type.detect.push( | COMMENT |
| 817 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | run-be-ut.sh | 475 | # =========================================================== | COMMENT |
| MEDIUM | tools/benchmark/table_sample.sh | 23 | # -------------- | COMMENT |
| MEDIUM | be/test/CMakeLists.txt | 445 | # ================================================= | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 123 | // ─── existing test ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 160 | // ─── build_variant_binding_from_node ──────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 304 | // ─── append_variant_binding_row ───────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 345 | // ─── encode_datum error paths ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 476 | // ─── VariantVirtualZoneMapReader tests ─────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 1221 | // ─── ARRAY nodes as ARRAY<VARIANT> batch columns ─────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/file_reader_test.cpp | 3925 | // ── Join runtime filter row-level pushdown (GroupReader stage 4.1) ────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 3328 | // ── Hidden variant source active/lazy classification ───────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 3778 | // ── _apply_deferred_variant_conjuncts ──────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 3912 | // ── _fill_dst_chunk error path ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4087 | // ── Decimal virtual column fallback tests ────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4226 | // ── LazyMaterializationContext tests ───────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4752 | // ── Temp Column Lifecycle Tests ────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4919 | // ── Logical-column bypass in emit_physical_columns ─────────────────────────── | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 50 | // ┌────────────────────────────────────────────────────────────┐ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 52 | // └────────────────────────────────────────────────────────────┘ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 88 | // ┌────────────────────────────────────────────────────────────┐ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 90 | // └────────────────────────────────────────────────────────────┘ | COMMENT |
| MEDIUM | be/src/compute_env/sorting/merge_path.h | 269 | // ┌────────── PENDING ◄──────────┐ | COMMENT |
| MEDIUM | be/src/compute_env/sorting/merge_path.h | 272 | // ├──────────────◄───────────────┤ | COMMENT |
| MEDIUM | be/src/formats/avro/cpp/avro_reader.cpp | 277 | // ── fixed-width non-nullable types ────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/avro/cpp/avro_reader.cpp | 301 | // ── variable-width non-nullable types ──────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/avro/cpp/avro_reader.cpp | 315 | // ── union ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 146 | // ── Initialization ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 157 | // ── get_next() pipeline phases ─────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 203 | // ── Member variables ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 223 | // ── Join runtime filter pushdown ─────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.h | 50 | // ── Free functions: variant projection utilities ──────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 80 | // ── Setup (called once during GroupReader::_create_column_readers) ────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 88 | // ── Classification (during _process_columns_and_conjunct_ctxs) ────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 97 | // ── Prepare (during GroupReader::prepare / _prepare_column_readers) ────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 104 | // ── Lazy→active promotion when active_chunk would be empty ─────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 107 | // ── IO range collection ────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 111 | // ── Read chunk initialisation ──────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 114 | // ── get_next() phases ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.h | 176 | // ── Timezone for variant projection ────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 49 | // ── Anonymous namespace: internal helpers (free functions) ───────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 394 | // ── VariantProjectionHandler ──────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 402 | // ── _build_shredded_hints ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 409 | // ── setup_readers ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 489 | // ── Classification helpers ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 555 | // ── Prepare ───────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 576 | // ── Promotion ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 721 | // ── Lazy→active promotion ─────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 736 | // ── IO range collection ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 746 | // ── Read chunk init ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 756 | // ── get_next() phases ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/group_reader.cpp | 747 | // ── Variant setup ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/group_reader.cpp | 751 | // ── Classify physical columns and conjuncts ─────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/group_reader.cpp | 755 | // ── Variant hidden source classification ────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/group_reader.cpp | 765 | // ── Promote lazy to active when no active columns exist ─────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/group_reader.cpp | 771 | // ── Join runtime filter pushdown ────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 56 | // ── GroupReader: construction / destruction ───────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 93 | // ── init / prepare ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 143 | // ── Simple accessors ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 173 | // ── get_next: materialise one chunk from the current row group ────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 258 | // ── 1. Prune deleted rows ────── | COMMENT |
| 328 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/show_segment_status/show_segment_status.py | 48 | def calc_table_and_be_summary(self, db_candidates, tbl_candidates, be_id): | CODE |
| LOW | tools/show_segment_status/be_tablet_reslover.py | 80 | def _decode_rs_metas_of_tablet(self, tablet_meta): | CODE |
| LOW | tools/show_segment_status/fe_meta_resolver.py | 152 | def _fetch_partitions_by_table(self, table): | CODE |
| LOW | tools/show_segment_status/fe_meta_resolver.py | 171 | def _fetch_idxes_by_partition(self, partition): | CODE |
| LOW | tools/show_segment_status/fe_meta_resolver.py | 190 | def _merge_schema_hash_to_idx_list(self): | CODE |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 147 | def detect_cluster_architecture(perf_dir): | CODE |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 353 | def check_partition_data_skew(conn, perf_dir): | STRING |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 416 | def check_too_many_versions_or_segments(conn, perf_dir): | STRING |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 499 | def check_large_unpartitioned_tables(conn, perf_dir): | STRING |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 536 | def check_single_bucket_large_tables(conn, perf_dir): | STRING |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 611 | def check_non_persistent_index_tables(conn, perf_dir): | STRING |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 651 | def check_abnormal_replica_status(conn, perf_dir): | STRING |
| LOW⚡ | be/extension/python-udf/src/flight_server.py | 118 | def get_imported_packages_ast(self, importer, module_name): | CODE |
| LOW | be/test/formats/test_data/avro/cpp/gen_avro_file.py | 78 | def write_direct_reader_matrix(out_path): | CODE |
| LOW | test/test_sql_cases.py | 122 | def _init_global_session_variables(self): | CODE |
| LOW | test/test_sql_cases.py | 243 | def _clear_db_and_resource_if_exists(self): | CODE |
| LOW | test/lib/choose_cases.py | 166 | def filter_cases_by_component_status(self): | CODE |
| LOW | test/lib/choose_cases.py | 250 | def filter_cases_by_data_status(self): | CODE |
| LOW | test/lib/choose_cases.py | 314 | def __read_single_stat_and_result(_line_content, _line_id, _stat_list, _res_list, _is_in_loop=False, | CODE |
| LOW | test/lib/mysql_stmt_metadata_lib.py | 107 | def decode_null_terminated_str(data: bytes, pos: int = 0) -> Tuple[str, int]: | CODE |
| LOW | test/lib/mysql_stmt_metadata_lib.py | 262 | def execute_and_fetch_metadata(self, statement_id: int, num_params: int) -> List[ColumnDef]: | CODE |
| LOW | test/lib/test_result_format.py | 55 | def test_negative_whole_seconds(self): | CODE |
| LOW | test/lib/test_result_format.py | 82 | def test_everything_else_is_left_to_str(self): | CODE |
| LOW | test/lib/sr_sql_lib.py | 164 | def skip_if_plugin_download_failed(sql, act): | CODE |
| LOW | test/lib/sr_sql_lib.py | 501 | def check_case_result_contains_crash(crash_msg_list, case_result_logs): | CODE |
| LOW | test/lib/sr_sql_lib.py | 679 | def create_starrocks_conn_pool(self): | CODE |
| LOW | test/lib/sr_sql_lib.py | 748 | def _create_iceberg_catalog_hive(self, catalog_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 767 | def _create_iceberg_catalog_hadoop(self, catalog_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 789 | def create_database_and_table(self, catalog_name, database_name, table_name, table_sql_path=None, | CODE |
| LOW | test/lib/sr_sql_lib.py | 1920 | def wait_db_transaction_finish(self, db_name, timeout_sec=30): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1948 | def get_running_transaction_count(self, db_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1960 | def get_single_running_transaction_label(self, db_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2048 | def check_routine_load_progress(self, sum_data_count, task_name, db_name, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2145 | def wait_materialized_view_finish(self, timeout=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2152 | def wait_materialized_view_cancel(self, check_count=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2335 | def wait_show_materialized_view_finish(self, mv_name, check_count=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2352 | def wait_async_materialized_view_finish(self, current_db, mv_name, check_count=None): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2433 | def get_task_run_success_count(self, results): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3247 | def check_es_table_metadata_ready(self, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3740 | def assert_node_script_prints(self, node_id, script, pattern): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3800 | def set_vlog_level_for_all_be(self, prefixes, level: int): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3831 | def wait_refresh_dictionary_finish(self, name, check_status): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3848 | def set_first_tablet_bad_and_recover(self, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3879 | def assert_is_identical_explain_plan(self, query1, query2): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3902 | def assert_query_not_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3940 | def assert_query_contains_times(self, query, expect, expected_times: int): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3957 | def assert_query_error_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3981 | def assert_explain_not_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3990 | def assert_explain_verbose_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4004 | def assert_explain_verbose_not_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4018 | def assert_explain_costs_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4031 | def get_col_stats_from_explain_costs(self, query, col_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4085 | def assert_show_stats_meta_contains(self, predicate, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4099 | def assert_trace_values_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4130 | def assert_prepare_execute_varchar_metadata(self, db, query, expected_prepare_len, expected_execute_len=None, | CODE |
| LOW | test/lib/sr_sql_lib.py | 4197 | def execute_with_prepared_connection(self, sql): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4200 | def assert_trace_times_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 4225 | def print_table_partitions_num(self, table_name) -> str: | CODE |
| LOW | test/lib/sr_sql_lib.py | 4231 | def print_plan_partition_selected_num(self, sql, table_name) -> str: | CODE |
| LOW | test/lib/sr_sql_lib.py | 4250 | def assert_table_partitions_num(self, table_name, expect_num): | CODE |
| 760 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/show_segment_status/fe_meta_resolver.py | 23 | # NOTE: The default organization of meta info is cascading, we flatten its structure | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 117 | # Step 1: Create database and table | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 141 | # Step 2: Generate JSON data (optionally with queries) | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 219 | # Step 3: Import data via Stream Load | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 258 | # Step 4: Run generated queries | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2631 | // Step 1: Write txn generates a delvec for segment 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2639 | // Step 2: Compaction removes rowset 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2647 | // Step 3: Finalize - this is where the bug would manifest | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 5412 | // Step 3: Verify correctness - the last partial update set c1 = c0 * (5 + kNumPartialUpdates - 1) | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 5419 | // Step 4: Verify metadata - should still have same number of rowsets (column update | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4775 | // Step 1: Write initial full data with all 3 columns (pk 0-11) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4796 | // Step 2: Insert NEW rows with COLUMN_UPSERT_MODE (pk 12-23, only update c0+c1) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4860 | // Step 3: Update existing rows with COLUMN_UPSERT_MODE | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4884 | // Step 4: Verify functional correctness | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4943 | // Step 1: Write initial full data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4962 | // Step 2: Partial update with COLUMN_UPSERT_MODE (updating existing rows) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4993 | // Step 3: Verify that orphan_files contains the partial segments | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5020 | // Step 1: Write base data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5042 | // Step 2: COLUMN_UPSERT_MODE with mixed operations: some deletes and some upserts with new rows | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5133 | // Step 3: Verify the result | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5349 | // Step 1: Create multiple source segments by writing full data multiple times | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5375 | // Step 2: Perform partial column updates with multiple update segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5444 | // Step 1: Create initial full data with multiple key ranges. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5466 | // Step 2: Perform row-mode partial update with multiple segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5500 | // Step 3: Verify correctness - c1 should be updated (c0 * 7), | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4133 | // Step 3: Verify sstable_meta is cleared after full replication | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4142 | // Step 4: Write more data - this should NOT fail with "unexpected segment id" | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4273 | // Step 4: Verify delvec_meta and dcg_meta are cleared | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4280 | // Step 5: Verify old delvec and dcg files are marked as orphan files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4041 | // Step 1: Write some data to generate SST files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4073 | // Step 2: Simulate full replication by creating a replication txn log | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4176 | // Step 1: Write initial data | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4197 | // Step 2: Get current metadata and manually add delvec_meta and dcg_meta for testing | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4219 | // Step 3: Simulate full replication | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1404 | // Step 1: query "$.a.b" — parent of typed column "a.b.c" | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1415 | // Step 2: query "$.c" from the sub-object — must be 42 (from typed column) | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1427 | // Step 3: query "$.d" from the sub-object — must be non-null (from remain payload) | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 663 | // Step 1: Create PK tablet with one committed rowset. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 686 | // Step 2: Migrate A->B. Wait until clock passes rowset_time so migration1 wins. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 696 | // Step 3: GC runs synchronously. A sync point callback injects migration B->A | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 715 | // Step 4: Verify V3 on disk_a has its rowset metadata intact. | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 727 | // Step 5: Verify restart-loading works — proves on-disk meta is complete. | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 108 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 119 | // Step 2: fill version magic_num, first column must be version(const int) | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 132 | // Step 3: fill statistic data | COMMENT |
| LOW | be/src/data_sink/result/http_result_writer.cpp | 74 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/http_result_writer.cpp | 86 | // Step 2: convert chunk to http json row format row by row | COMMENT |
| LOW | be/src/column/column_hash.h | 44 | // NOTE: This function will access 15 excessive bytes after p1 and p2, which should has padding bytes when allocating | COMMENT |
| LOW | be/src/storage/rowset/segment_writer.cpp | 398 | // NOTE: This function will be called when any row of data is added, so we need to | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 345 | // Step 1: Evaluate predicates on dictionary once and reuse the selection across pages. | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 366 | // Step 2: Read dictionary codes for the range (we must do this regardless of dict selection) | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 385 | // Step 3: Update selection based on dictionary selection and collect matching slices | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 400 | // Step 4: Append selected strings to column using append_strings_overflow | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 552 | // Step 3: Distribute segment data across overlapping ranges. | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 557 | // Step 4: Calculate split boundaries using a greedy algorithm. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 475 | // Step 1: Collect all unique boundary points (including sort-key samples) and sort them. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 539 | // Step 2: Build ordered ranges between adjacent boundary points. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 699 | // Step 5: Estimate per-range data sizes by walking candidate ranges against boundaries. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 1164 | // Step 2: Calculate split boundaries with tablet range filtering. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 1186 | // Step 3: Build TabletRangeInfo directly from result. | COMMENT |
| 203 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/json_data_generator/test_starrocks_json.sh | 117 | # Step 1: Create database and table | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 141 | # Step 2: Generate JSON data (optionally with queries) | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 219 | # Step 3: Import data via Stream Load | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 258 | # Step 4: Run generated queries | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2631 | // Step 1: Write txn generates a delvec for segment 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2639 | // Step 2: Compaction removes rowset 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 2647 | // Step 3: Finalize - this is where the bug would manifest | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 5412 | // Step 3: Verify correctness - the last partial update set c1 = c0 * (5 + kNumPartialUpdates - 1) | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 5419 | // Step 4: Verify metadata - should still have same number of rowsets (column update | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4775 | // Step 1: Write initial full data with all 3 columns (pk 0-11) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4796 | // Step 2: Insert NEW rows with COLUMN_UPSERT_MODE (pk 12-23, only update c0+c1) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4860 | // Step 3: Update existing rows with COLUMN_UPSERT_MODE | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4884 | // Step 4: Verify functional correctness | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4943 | // Step 1: Write initial full data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4962 | // Step 2: Partial update with COLUMN_UPSERT_MODE (updating existing rows) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4993 | // Step 3: Verify that orphan_files contains the partial segments | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5020 | // Step 1: Write base data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5042 | // Step 2: COLUMN_UPSERT_MODE with mixed operations: some deletes and some upserts with new rows | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5133 | // Step 3: Verify the result | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5349 | // Step 1: Create multiple source segments by writing full data multiple times | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5375 | // Step 2: Perform partial column updates with multiple update segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5444 | // Step 1: Create initial full data with multiple key ranges. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5466 | // Step 2: Perform row-mode partial update with multiple segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 5500 | // Step 3: Verify correctness - c1 should be updated (c0 * 7), | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4133 | // Step 3: Verify sstable_meta is cleared after full replication | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4142 | // Step 4: Write more data - this should NOT fail with "unexpected segment id" | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4273 | // Step 4: Verify delvec_meta and dcg_meta are cleared | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 4280 | // Step 5: Verify old delvec and dcg files are marked as orphan files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4041 | // Step 1: Write some data to generate SST files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4073 | // Step 2: Simulate full replication by creating a replication txn log | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4176 | // Step 1: Write initial data | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4197 | // Step 2: Get current metadata and manually add delvec_meta and dcg_meta for testing | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 4219 | // Step 3: Simulate full replication | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1404 | // Step 1: query "$.a.b" — parent of typed column "a.b.c" | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1415 | // Step 2: query "$.c" from the sub-object — must be 42 (from typed column) | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1427 | // Step 3: query "$.d" from the sub-object — must be non-null (from remain payload) | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 663 | // Step 1: Create PK tablet with one committed rowset. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 686 | // Step 2: Migrate A->B. Wait until clock passes rowset_time so migration1 wins. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 696 | // Step 3: GC runs synchronously. A sync point callback injects migration B->A | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 715 | // Step 4: Verify V3 on disk_a has its rowset metadata intact. | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 727 | // Step 5: Verify restart-loading works — proves on-disk meta is complete. | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 108 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 119 | // Step 2: fill version magic_num, first column must be version(const int) | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 132 | // Step 3: fill statistic data | COMMENT |
| LOW | be/src/data_sink/result/http_result_writer.cpp | 74 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/http_result_writer.cpp | 86 | // Step 2: convert chunk to http json row format row by row | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 345 | // Step 1: Evaluate predicates on dictionary once and reuse the selection across pages. | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 366 | // Step 2: Read dictionary codes for the range (we must do this regardless of dict selection) | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 385 | // Step 3: Update selection based on dictionary selection and collect matching slices | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 400 | // Step 4: Append selected strings to column using append_strings_overflow | COMMENT |
| LOW | be/src/storage/rowset/segment.cpp | 525 | // if the column is a char column, we need to check if the length of the column is the same as | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 552 | // Step 3: Distribute segment data across overlapping ranges. | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 557 | // Step 4: Calculate split boundaries using a greedy algorithm. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 475 | // Step 1: Collect all unique boundary points (including sort-key samples) and sort them. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 539 | // Step 2: Build ordered ranges between adjacent boundary points. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 699 | // Step 5: Estimate per-range data sizes by walking candidate ranges against boundaries. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 1164 | // Step 2: Calculate split boundaries with tablet range filtering. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 1186 | // Step 3: Build TabletRangeInfo directly from result. | COMMENT |
| LOW | be/src/storage/lake/vacuum.cpp | 1026 | // Step 1: walk each tablet's prev_garbage_version chain from the range's top real node down to | COMMENT |
| LOW | be/src/storage/lake/vacuum.cpp | 1105 | // Step 2: shared data files no longer referenced by any metadata still alive at the retain floor | COMMENT |
| 144 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …c/test/java/com/starrocks/sql/plan/WindowSkewTest.java | 0 | create table `force_merge_sort_table` ( `p` int null, `s` int null, `x` int null ) engine=olap duplicate key(`p`, `s`, ` | STRING |
| HIGH | …va/com/starrocks/sql/plan/WindowMergeSortHintTest.java | 0 | create table `force_merge_sort_table` ( `p` int null, `s` int null, `x` int null ) engine=olap duplicate key(`p`, `s`, ` | STRING |
| HIGH | …/starrocks/sql/plan/WindowSkewToMergeSortRuleTest.java | 0 | create table `force_merge_sort_table` ( `p` int null, `s` int null, `x` int null ) engine=olap duplicate key(`p`, `s`, ` | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | tmp_crash_date, tmp_crash_time, crash_date=str_to_date(concat_ws(' ', tmp_crash_date, tmp_crash_time), '%m/%d/%y %h:%i') | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | tmp_crash_date, tmp_crash_time, crash_date=str_to_date(concat_ws(' ', tmp_crash_date, tmp_crash_time), '%m/%d/%y %h:%i') | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | tmp_crash_date, tmp_crash_time, crash_date=str_to_date(concat_ws(' ', tmp_crash_date, tmp_crash_time), '%m/%d/%y %h:%i') | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | insert into crashdata ( crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_name, | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | insert into crashdata ( crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_name, | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | insert into crashdata ( crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_name, | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | create table if not exists crashdata ( crash_date datetime, borough string, zip_code string, latitude int, longitude int | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | create table if not exists crashdata ( crash_date datetime, borough string, zip_code string, latitude int, longitude int | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | create table if not exists crashdata ( crash_date datetime, borough string, zip_code string, latitude int, longitude int | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | insert into crashdata values ('2024-01-15 08:30:00', 'manhattan', '10001', 40748817, -73985428, '(40.748817, -73.985428) | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | insert into crashdata values ('2024-01-15 08:30:00', 'manhattan', '10001', 40748817, -73985428, '(40.748817, -73.985428) | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | insert into crashdata values ('2024-01-15 08:30:00', 'manhattan', '10001', 40748817, -73985428, '(40.748817, -73.985428) | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | select borough, on_street_name, count(*) as crash_count, count(distinct date(crash_date)) as days_with_crashes from cras | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | select borough, on_street_name, count(*) as crash_count, count(distinct date(crash_date)) as days_with_crashes from cras | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | select borough, on_street_name, count(*) as crash_count, count(distinct date(crash_date)) as days_with_crashes from cras | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | select contributing_factor_vehicle_1 as factor, count(*) as count, round(count(*) * 100.0 / sum(count(*)) over (), 2) as | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | select contributing_factor_vehicle_1 as factor, count(*) as count, round(count(*) * 100.0 / sum(count(*)) over (), 2) as | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | select contributing_factor_vehicle_1 as factor, count(*) as count, round(count(*) * 100.0 / sum(count(*)) over (), 2) as | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | create table if not exists crashdata_staging ( crash_date datetime, borough string, zip_code string, latitude int, longi | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | create table if not exists crashdata_staging ( crash_date datetime, borough string, zip_code string, latitude int, longi | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | create table if not exists crashdata_staging ( crash_date datetime, borough string, zip_code string, latitude int, longi | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | insert into crashdata select crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_ | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | insert into crashdata select crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_ | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | insert into crashdata select crash_date, borough, zip_code, latitude, longitude, location, on_street_name, cross_street_ | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | submit task backup_crashdata as create table crash_data_backup as select * from crashdata | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | submit task backup_crashdata as create table crash_data_backup as select * from crashdata | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | submit task backup_crashdata as create table crash_data_backup as select * from crashdata | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | select state, error_message from information_schema.task_runs where task_name = '{task_name}' | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | select state, error_message from information_schema.task_runs where task_name = '{task_name}' | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | select state, error_message from information_schema.task_runs where task_name = '{task_name}' | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | drop materialized view if exists quickstart.mv_daily_crash_stats | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | drop materialized view if exists quickstart.mv_daily_crash_stats | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | drop materialized view if exists quickstart.mv_daily_crash_stats | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | create materialized view if not exists quickstart.mv_daily_crash_stats distributed by hash(`crash_date`) refresh async a | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | create materialized view if not exists quickstart.mv_daily_crash_stats distributed by hash(`crash_date`) refresh async a | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | create materialized view if not exists quickstart.mv_daily_crash_stats distributed by hash(`crash_date`) refresh async a | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | select task_name from information_schema.tasks where `database` = 'quickstart' and definition like '%{mv_name}%' order b | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | select task_name from information_schema.tasks where `database` = 'quickstart' and definition like '%{mv_name}%' order b | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | select task_name from information_schema.tasks where `database` = 'quickstart' and definition like '%{mv_name}%' order b | STRING |
| HIGH | docs/ja/integrations/airflow.md | 0 | select state from information_schema.task_runs where task_name = '{task_name}' order by create_time desc limit 1 | STRING |
| HIGH | docs/zh/integrations/airflow.md | 0 | select state from information_schema.task_runs where task_name = '{task_name}' order by create_time desc limit 1 | STRING |
| HIGH | docs/en/integrations/airflow.md | 0 | select state from information_schema.task_runs where task_name = '{task_name}' order by create_time desc limit 1 | STRING |
| HIGH | docs/ja/unloading/arrow_flight.md | 0 | execute a sql statement and print the result and execution time. | STRING |
| HIGH | docs/zh/unloading/arrow_flight.md | 0 | execute a sql statement and print the result and execution time. | STRING |
| HIGH | docs/en/unloading/arrow_flight.md | 0 | execute a sql statement and print the result and execution time. | STRING |
| HIGH | docs/ja/unloading/arrow_flight.md | 0 | create table sr_arrow_flight_sql_test ( k0 int, k1 double, k2 varchar(32) null default "" comment "", k3 decimal(27,9) d | STRING |
| HIGH | docs/zh/unloading/arrow_flight.md | 0 | create table sr_arrow_flight_sql_test ( k0 int, k1 double, k2 varchar(32) null default "" comment "", k3 decimal(27,9) d | STRING |
| HIGH | docs/en/unloading/arrow_flight.md | 0 | create table sr_arrow_flight_sql_test ( k0 int, k1 double, k2 varchar(32) null default "" comment "", k3 decimal(27,9) d | STRING |
| HIGH | docs/ja/unloading/arrow_flight.md | 0 | insert into sr_arrow_flight_sql_test values (0, 0.1, "id", 0.0001, 1111111111, '2025-04-21'), (1, 0.20, "id_1", 1.000000 | STRING |
| HIGH | docs/zh/unloading/arrow_flight.md | 0 | insert into sr_arrow_flight_sql_test values (0, 0.1, "id", 0.0001, 1111111111, '2025-04-21'), (1, 0.20, "id_1", 1.000000 | STRING |
| HIGH | docs/en/unloading/arrow_flight.md | 0 | insert into sr_arrow_flight_sql_test values (0, 0.1, "id", 0.0001, 1111111111, '2025-04-21'), (1, 0.20, "id_1", 1.000000 | STRING |
| HIGH | docs/ja/unloading/arrow_flight.md | 0 | select k5, sum(k1) as total_k1, count(1) as row_count, avg(k3) as avg_k3 from sr_arrow_flight_sql_test group by k5 order | STRING |
| HIGH | docs/zh/unloading/arrow_flight.md | 0 | select k5, sum(k1) as total_k1, count(1) as row_count, avg(k3) as avg_k3 from sr_arrow_flight_sql_test group by k5 order | STRING |
| HIGH | docs/en/unloading/arrow_flight.md | 0 | select k5, sum(k1) as total_k1, count(1) as row_count, avg(k3) as avg_k3 from sr_arrow_flight_sql_test group by k5 order | STRING |
| HIGH | …python-client/test/integration/test_reflection_view.py | 0 | with monthly_stats as ( select user_id, count(*) as monthly_orders from orders where order_date >= date_sub(current_date | STRING |
| HIGH | …s-python-client/test/integration/test_reflection_mv.py | 0 | with monthly_stats as ( select user_id, count(*) as monthly_orders from orders where order_date >= date_sub(current_date | STRING |
| HIGH | …starrocks-python-client/test/sql/test_compiler_view.py | 0 | with monthly_stats as ( select user_id, count(*) as monthly_orders from orders where order_date >= date_sub(current_date | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | be/AGENTS.md | 310 | ### Orchestration (`orchestration`) | COMMENT |
| MEDIUM | be/CLAUDE.md | 310 | ### Orchestration (`orchestration`) | COMMENT |
| MEDIUM | be/test/CMakeLists.txt | 144 | #./orchestration/routine_load_task_executor_test.cpp | COMMENT |
| MEDIUM | be/test/storage/lake/tablet_manager_test.cpp | 2277 | // load_segment+open() path here without a SegmentWriter scaffold — Segment::open parses the | COMMENT |
| MEDIUM | be/test/http/handler_required_privilege_test.cpp | 50 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/test/http/stream_load_test.cpp | 70 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/test/http/transaction_stream_load_test.cpp | 48 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/test/orchestration/stream_load_orchestrator_test.cpp | 15 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | …test/orchestration/external_scan_orchestrator_test.cpp | 15 | #include "orchestration/external_scan_orchestrator.h" | COMMENT |
| MEDIUM | …test/orchestration/external_scan_orchestrator_test.cpp | 35 | #include "orchestration/external_scan_context_mgr.h" | COMMENT |
| MEDIUM | …test/orchestration/routine_load_task_executor_test.cpp | 35 | #include "orchestration/routine_load_task_executor.h" | COMMENT |
| MEDIUM | …test/orchestration/routine_load_task_executor_test.cpp | 47 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | …/test/orchestration/external_scan_context_mgr_test.cpp | 35 | #include "orchestration/external_scan_context_mgr.h" | COMMENT |
| MEDIUM | be/test/orchestration/query_orchestrator_test.cpp | 15 | #include "orchestration/query_orchestrator.h" | COMMENT |
| MEDIUM | be/test/orchestration/fragment_mgr_test.cpp | 35 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM | be/test/orchestration/fragment_mgr_test.cpp | 48 | #include "orchestration/plan_fragment_executor.h" | COMMENT |
| MEDIUM | be/test/orchestration/orchestration_metrics_test.cpp | 15 | #include "orchestration/orchestration_metrics.h" | COMMENT |
| MEDIUM | be/test/orchestration/orchestration_metrics_test.cpp | 21 | #include "orchestration/runtime_filter_worker_event.h" | COMMENT |
| MEDIUM | be/test/orchestration/fragment_executor_test.cpp | 15 | #include "orchestration/fragment_executor.h" | COMMENT |
| MEDIUM | be/test/testutil/init_test_env.h | 53 | #include "orchestration/orchestration_env.h" | COMMENT |
| MEDIUM | be/src/http/action/transaction_stream_load.cpp | 58 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/src/http/action/stream_load.cpp | 80 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/src/orchestration/plan_fragment_executor.cpp | 35 | #include "orchestration/plan_fragment_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/orchestration_metrics.cpp | 15 | #include "orchestration/orchestration_metrics.h" | COMMENT |
| MEDIUM | be/src/orchestration/fragment_mgr.cpp | 35 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM | be/src/orchestration/fragment_mgr.cpp | 65 | #include "orchestration/plan_fragment_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/query_orchestrator.cpp | 15 | #include "orchestration/query_orchestrator.h" | COMMENT |
| MEDIUM | be/src/orchestration/query_orchestrator.cpp | 42 | #include "orchestration/fragment_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/runtime_filter_worker.cpp | 15 | #include "orchestration/runtime_filter_worker.h" | COMMENT |
| MEDIUM | be/src/orchestration/fragment_executor.cpp | 15 | #include "orchestration/fragment_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/external_scan_context_mgr.cpp | 35 | #include "orchestration/external_scan_context_mgr.h" | COMMENT |
| MEDIUM | be/src/orchestration/runtime_filter_worker.h | 27 | #include "orchestration/runtime_filter_delivery.h" | COMMENT |
| MEDIUM | be/src/orchestration/runtime_filter_worker.h | 28 | #include "orchestration/runtime_filter_worker_event.h" | COMMENT |
| MEDIUM | be/src/orchestration/orchestration_metrics.h | 22 | #include "orchestration/runtime_filter_worker_event.h" | COMMENT |
| MEDIUM | be/src/orchestration/orchestration_env.cpp | 15 | #include "orchestration/orchestration_env.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 31 | #include "orchestration/external_scan_context_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 32 | #include "orchestration/external_scan_orchestrator.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 33 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 34 | #include "orchestration/orchestration_metrics.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 35 | #include "orchestration/routine_load_task_executor.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 36 | #include "orchestration/runtime_filter_worker.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/orchestration_env.cpp | 37 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/src/orchestration/external_scan_orchestrator.cpp | 15 | #include "orchestration/external_scan_orchestrator.h" | COMMENT |
| MEDIUM | be/src/orchestration/external_scan_orchestrator.cpp | 32 | #include "orchestration/external_scan_context_mgr.h" | COMMENT |
| MEDIUM | be/src/orchestration/external_scan_orchestrator.cpp | 33 | #include "orchestration/query_orchestrator.h" | COMMENT |
| MEDIUM | be/src/orchestration/stream_load_orchestrator.cpp | 15 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/stream_load_orchestrator.cpp | 31 | #include "orchestration/fragment_executor.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/stream_load_orchestrator.cpp | 32 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/orchestration/stream_load_orchestrator.cpp | 33 | #include "orchestration/plan_fragment_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/runtime_filter_delivery.cpp | 15 | #include "orchestration/runtime_filter_delivery.h" | COMMENT |
| MEDIUM | be/src/orchestration/runtime_filter_delivery.cpp | 34 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM | be/src/orchestration/routine_load_task_executor.cpp | 35 | #include "orchestration/routine_load_task_executor.h" | COMMENT |
| MEDIUM | be/src/orchestration/routine_load_task_executor.cpp | 52 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 45 | #include "orchestration/external_scan_orchestrator.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 46 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 47 | #include "orchestration/orchestration_env.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 48 | #include "orchestration/routine_load_task_executor.h" | COMMENT |
| MEDIUM⚡ | be/src/service/internal_service.cpp | 86 | #include "orchestration/fragment_executor.h" | COMMENT |
| MEDIUM⚡ | be/src/service/internal_service.cpp | 87 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/service/internal_service.cpp | 88 | #include "orchestration/orchestration_env.h" | COMMENT |
| 5 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | packaging/debian/build.sh | 195 | # Define the key and path based on component | COMMENT |
| MEDIUM | be/test/exec/test_data/parquet_data/variant_gen.py | 47 | # Create a table with variant and insert various types into it | COMMENT |
| MEDIUM | …/test/exec/test_data/parquet_data/generate_datetime.py | 22 | # Create a sample dataframe with one column in datetime type | COMMENT |
| MEDIUM | …/test/exec/test_data/orc_scanner/generate_timestamp.py | 22 | # Create a data frame | COMMENT |
| MEDIUM | be/test/exec/test_data/orc_scanner/generate_compound.py | 19 | # Define the ORC type for the columns | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_fe/config_models/instance.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_fe/config_models/__init__.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …fe/datadog_checks/starrocks_fe/config_models/shared.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_fe/config_models/defaults.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_be/config_models/instance.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_be/config_models/__init__.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …be/datadog_checks/starrocks_be/config_models/shared.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM | …/datadog_checks/starrocks_be/config_models/defaults.py | 5 | # This file is autogenerated. | COMMENT |
| MEDIUM⚡ | …-client/test/integration/test_reflection_data_types.py | 508 | # Create a comprehensive table with various types | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 100 | # Create a simple view | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 134 | # Create a view with comment | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 179 | # Create a view with security invoker | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 219 | # Create a view with explicit column names and comments | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 278 | # Create a complex view | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 336 | # Create a view with window functions | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 383 | # Create a view with CTE | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 431 | # Create a view with special characters | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 688 | # Create a comprehensive view with all features | STRING |
| MEDIUM | …hon-client/test/integration/test_autogenerate_views.py | 992 | # Create a table in database (with StarRocks-specific properties) | COMMENT |
| MEDIUM | …hon-client/test/integration/test_autogenerate_views.py | 1328 | # Create the view in the DB exactly as the user wrote it in their model. | COMMENT |
| MEDIUM⚡ | …ython-client/test/integration/test_reflection_table.py | 37 | # Define a table with various StarRocks-specific options | COMMENT |
| MEDIUM | …ython-client/test/integration/test_reflection_table.py | 59 | # Create the table in the test database | COMMENT |
| MEDIUM | …hon-client/test/integration/test_reflection_columns.py | 67 | # Create a map of column name to its reflected info dict | COMMENT |
| MEDIUM | …hon-client/test/integration/test_reflection_columns.py | 72 | # Create a map of column name to its reflected info dict | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 131 | # Create a simple materialized view using the users table | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 166 | # Create a materialized view with properties | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 306 | # Create a materialized view with comment | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 337 | # Create a materialized view with aggregation | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 384 | # Create a materialized view with window functions | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 427 | # Create a materialized view with CTE | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 471 | # Create a materialized view with special characters | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 608 | # Create a materialized view with complex joins | COMMENT |
| MEDIUM | contrib/starrocks-python-client/test/system/conftest.py | 114 | # Create the versions directory | COMMENT |
| MEDIUM | …arrocks-python-client/test/system/test_mv_lifecycle.py | 34 | # Create a simple base table for MV to reference | COMMENT |
| MEDIUM⚡ | …arrocks-python-client/test/system/test_mv_lifecycle.py | 58 | # Create a table to support MV definition | COMMENT |
| MEDIUM | …arrocks-python-client/test/system/test_mv_lifecycle.py | 213 | # Create an object in the ignored schema to ensure it's not picked up for a DROP operation | COMMENT |
| MEDIUM⚡ | …starrocks-python-client/test/sql/test_compiler_view.py | 48 | # Create a source table | COMMENT |
| MEDIUM⚡ | …starrocks-python-client/test/sql/test_compiler_view.py | 54 | # Create a select statement | COMMENT |
| MEDIUM | …trib/starrocks-python-client/examples/view_examples.py | 57 | # Create a view | COMMENT |
| MEDIUM | …trib/starrocks-python-client/examples/view_examples.py | 70 | # Create a materialized view | COMMENT |
| MEDIUM | …trib/starrocks-python-client/examples/view_examples.py | 120 | # Define a view using ViewMixin | COMMENT |
| MEDIUM | …trib/starrocks-python-client/examples/view_examples.py | 146 | # Define a materialized view using MaterializedViewMixin | COMMENT |
| MEDIUM | …trib/starrocks-python-client/examples/view_examples.py | 205 | # Create a simple view | COMMENT |
| MEDIUM | …ib/starrocks-python-client/starrocks/alembic/toimpl.py | 105 | # Create a minimal MaterializedView object for DROP operation | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 418 | # Create a View object (not Table) since we know it's a view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 441 | # Create a View object (not Table) since we know it's a view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 997 | # Create a MaterializedView object (not Table) since we know it's a materialized view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 1020 | # Create a MaterializedView object (not Table) since we know it's a materialized view | COMMENT |
| MEDIUM | .github/workflows/issue-jira-sync.yml | 3 | # Create a CelerData Jira issue (project RB) for every newly opened issue. | COMMENT |
| MEDIUM | .github/workflows/cd-repo-sync.yml | 216 | # Create the SR PR directly (no pending/ordering — native review + rebase handle | COMMENT |
| MEDIUM | thirdparty/build-thirdparty.sh | 1146 | # Create a mapping file with '<old_sym> <suffixed_sym>' on each line. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | nix/generate-thirdparty-archives.py | 20 | CODE | |
| LOW | be/extension/python-udf/src/flight_server.py | 22 | CODE | |
| LOW | be/test/exec/test_data/parquet_data/issue_16375.py | 15 | CODE | |
| LOW | be/test/exec/test_data/parquet_data/generate_null.py | 15 | CODE | |
| LOW | be/test/exec/test_data/parquet_data/generate.py | 15 | CODE | |
| LOW | be/test/exec/test_data/parquet_data/generate_nested.py | 16 | CODE | |
| LOW | be/test/exec/test_data/parquet_data/issue_17693.py | 15 | CODE | |
| LOW | test/test_sql_cases.py | 30 | CODE | |
| LOW | test/test_sql_cases.py | 34 | CODE | |
| LOW | test/test_sql_cases.py | 43 | CODE | |
| LOW | test/tag_mac_tests.py | 14 | CODE | |
| LOW | test/tag_mac_tests.py | 19 | CODE | |
| LOW | test/tag_mac_tests.py | 19 | CODE | |
| LOW | test/lib/choose_cases.py | 30 | CODE | |
| LOW | test/lib/choose_cases.py | 39 | CODE | |
| LOW | test/lib/trino_lib.py | 20 | CODE | |
| LOW | test/lib/connection_base_lib.py | 21 | CODE | |
| LOW | test/lib/spark_lib.py | 20 | CODE | |
| LOW | test/lib/github_issue.py | 14 | CODE | |
| LOW | test/lib/hive_lib.py | 20 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 34 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 36 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 37 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 40 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 49 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 62 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 63 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 78 | CODE | |
| LOW | docs/scripts/run_sql_samples.py | 45 | CODE | |
| LOW | docs/scripts/run_sql_samples.py | 52 | CODE | |
| LOW | docs/scripts/extract_sql_samples.py | 37 | CODE | |
| LOW | docs/scripts/sql_sample_parity.py | 40 | CODE | |
| LOW | docs/scripts/check_function_signatures.py | 47 | CODE | |
| LOW | …r/starrocks_fe/datadog_checks/starrocks_fe/__init__.py | 4 | CODE | |
| LOW | …r/starrocks_fe/datadog_checks/starrocks_fe/__init__.py | 5 | CODE | |
| LOW | …/datadog_checks/starrocks_fe/config_models/instance.py | 11 | CODE | |
| LOW | …fe/datadog_checks/starrocks_fe/config_models/shared.py | 11 | CODE | |
| LOW | …adog-connector/starrocks_fe/tests/test_starrocks_fe.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_fe/tests/test_starrocks_fe.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_fe/tests/test_starrocks_fe.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_fe/tests/test_starrocks_fe.py | 7 | CODE | |
| LOW | …adog-connector/starrocks_fe/tests/test_starrocks_fe.py | 8 | CODE | |
| LOW | …r/starrocks_be/datadog_checks/starrocks_be/__init__.py | 4 | CODE | |
| LOW | …r/starrocks_be/datadog_checks/starrocks_be/__init__.py | 5 | CODE | |
| LOW | …/datadog_checks/starrocks_be/config_models/instance.py | 11 | CODE | |
| LOW | …be/datadog_checks/starrocks_be/config_models/shared.py | 11 | CODE | |
| LOW | …adog-connector/starrocks_be/tests/test_starrocks_be.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_be/tests/test_starrocks_be.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_be/tests/test_starrocks_be.py | 5 | CODE | |
| LOW | …adog-connector/starrocks_be/tests/test_starrocks_be.py | 7 | CODE | |
| LOW | …adog-connector/starrocks_be/tests/test_starrocks_be.py | 8 | CODE | |
| LOW | contrib/starrocks-python-client/test/test_suite.py | 40 | CODE | |
| LOW | …st/integration/test_combine_column_alters_range_key.py | 35 | CODE | |
| LOW | …-client/test/integration/test_combine_column_alters.py | 24 | CODE | |
| LOW | …-client/test/integration/test_combine_column_alters.py | 37 | CODE | |
| LOW | …n-client/test/integration/test_autogenerate_columns.py | 15 | CODE | |
| LOW | …hon-client/test/integration/test_reflection_indexes.py | 31 | CODE | |
| LOW | …hon-client/test/integration/test_reflection_indexes.py | 41 | CODE | |
| LOW | …hon-client/test/integration/test_schema_change_wait.py | 29 | CODE | |
| LOW | …rrocks-python-client/test/integration/templates/env.py | 19 | CODE | |
| 93 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | be/test/storage/lake/condition_update_test.cpp | 712 | // translation units. Match by string value so the lookup is robust against the compiler's | COMMENT |
| MEDIUM | be/test/storage/lake/schema_change_test.cpp | 3310 | // and may fail with NotFound; allow either path so the test is robust. | COMMENT |
| MEDIUM | be/test/storage/lake/persistent_index_sstable_test.cpp | 1088 | // instead so the test is robust against the compiler's string pooling decisions. | COMMENT |
| MEDIUM | be/test/exprs/array_functions_test.cpp | 3278 | // matches the production convention and stays robust if array_difference starts using it. | COMMENT |
| MEDIUM | be/test/fs_ext/hdfs_filesystem_test.cpp | 157 | // use file:// as the fs scheme, which will leverage Hadoop LocalFileSystem for testing | COMMENT |
| MEDIUM | be/test/base/compression/block_compression_test.cpp | 1366 | // dictID. What makes this case robust rather than lucky is that the frame's backreferences | COMMENT |
| MEDIUM | be/src/compute_env/query/scan_conjuncts_manager.h | 151 | // If Type is OR, to convert OR to AND to utilize existing parsing logic, perform the `Negative` operation | COMMENT |
| MEDIUM | be/src/storage_primitive/tablet_column_util.cpp | 211 | // only when `default_value` is not set to make schema conversion robust. | COMMENT |
| MEDIUM | be/src/column/variant_column.h | 78 | // schema-aware shredded row encoding, but it is robust for schema-less key restoration. | COMMENT |
| MEDIUM | be/src/storage/extends_column_utils.cpp | 142 | // Record root column unique id to make it robust across schema changes | COMMENT |
| MEDIUM | be/src/storage/rowset/segment_options.h | 145 | // 2. Partial-Sorted block: leverage data ordering to improve the evenness | COMMENT |
| MEDIUM | be/src/storage/rowset/segment.cpp | 569 | // Resolve the root column by unique id to be robust across schema changes | COMMENT |
| MEDIUM | be/src/storage/lake/tablet_manager.cpp | 1632 | // 2. leverage `indexId` to lookup the global_schema from cache and if missing from file. | COMMENT |
| MEDIUM | …rc/storage/lake/tablet_parallel_compaction_manager.cpp | 1731 | // path (try_replace), which is more robust and performant. | COMMENT |
| MEDIUM | be/src/storage/lake/parallel_task_runner.h | 37 | // failed the publish. Running inline is strictly more robust -- the task is going to run either | COMMENT |
| MEDIUM | be/src/storage/base/short_key_index.h | 85 | // 1. If this can leverage binary page to save key and offset data | COMMENT |
| MEDIUM | be/src/exprs/agg/avg.h | 224 | // But for robust, we add this check. | COMMENT |
| MEDIUM | be/src/common/system/cpu_info.cpp | 348 | // TODO: is there a more robust way to do this, such as | COMMENT |
| MEDIUM | be/src/connector/common/partition_chunk_writer.h | 132 | // TODO: Refactor the file writer and output stream to make them more robust and user-friendly. | COMMENT |
| MEDIUM | be/src/base/phmap/phmap_config.h | 352 | // are not defined as such in any file). To utilize the following | COMMENT |
| MEDIUM | be/src/base/process/lite_exec.cpp | 47 | // make read end non-blocking for robust poll/read | COMMENT |
| MEDIUM | be/src/base/utility/arrow_utils.h | 27 | // to share data with others we can leverage Arrow's ability. | COMMENT |
| MEDIUM | webroot/static/jquery.js | 10821 | // understands anonymous AMD modules. A named AMD is safest and most robust | COMMENT |
| MEDIUM | …er/reshard/presplit/OrcStripeStatisticsReaderTest.java | 528 | // Whole-second max; assert the second prefix to stay robust to a sub-millisecond stats | COMMENT |
| MEDIUM | …er/reshard/presplit/OrcStripeStatisticsReaderTest.java | 732 | // Whole-second max; assert the second prefix to stay robust to a sub-millisecond stats | COMMENT |
| MEDIUM | …/src/main/java/com/starrocks/planner/OlapScanNode.java | 727 | // TODO: Implement a more robust strategy for tablet affinity. | COMMENT |
| MEDIUM | …ore/src/main/java/com/starrocks/catalog/OlapTable.java | 273 | // We can utilize a monotonically increasing IndexId, | COMMENT |
| MEDIUM | …/src/main/java/com/starrocks/lake/LakeTableHelper.java | 71 | // 2. to utilize the recycle bin's delete retry capability to perform retries. | COMMENT |
| MEDIUM | …c/main/java/com/starrocks/lake/TabletRepairHelper.java | 627 | // Larger batches leverage the BE-side file existence cache to reduce object storage accesses. | COMMENT |
| MEDIUM | …ava/com/starrocks/statistic/StatisticsMetaManager.java | 573 | // TODO(stephen): This check is not robust because we can't get job handle here. | COMMENT |
| MEDIUM | …/sql/optimizer/statistics/StatisticsEstimateUtils.java | 215 | // Primary estimation path: utilize multi-column statistics when available | COMMENT |
| MEDIUM | docs/lychee.toml | 24 | # Number of threads to utilize. | COMMENT |
| MEDIUM | docs/zh/lychee.toml | 26 | # Number of threads to utilize. | COMMENT |
| MEDIUM⚡ | …-client/test/integration/test_reflection_data_types.py | 508 | # Create a comprehensive table with various types | COMMENT |
| MEDIUM | …python-client/test/integration/test_reflection_view.py | 688 | # Create a comprehensive view with all features | STRING |
| MEDIUM | contrib/starrocks-python-client/test/system/conftest.py | 184 | # Create and attach the harness | STRING |
| MEDIUM | …ocks-python-client/test/system/test_table_lifecycle.py | 207 | # Normalize script content for robust comparison | COMMENT |
| MEDIUM | …ocks-python-client/test/system/test_table_lifecycle.py | 237 | # 1. Define the comprehensive model | COMMENT |
| MEDIUM | …ocks-python-client/test/system/test_table_lifecycle.py | 728 | # alembic_env.harness.downgrade("-1") | COMMENT |
| MEDIUM | …ocks-python-client/test/system/test_table_lifecycle.py | 299 | """Tests comprehensive column alterations: ADD, DROP, ALTER. | STRING |
| MEDIUM⚡ | …arrocks-python-client/test/system/test_mv_lifecycle.py | 56 | """Tests creating a comprehensive MV with all attributes.""" | STRING |
| MEDIUM | …rocks-python-client/test/system/test_view_lifecycle.py | 722 | # We normalize both for a robust comparison | COMMENT |
| MEDIUM | contrib/starrocks-python-client/starrocks/reflection.py | 435 | # Find the end of the RANGE/LIST(...) part using robust parenthesis matching | COMMENT |
| LOW | contrib/starrocks-python-client/starrocks/sql/dml.py | 101 | # or a string of these expressions that we just use | COMMENT |
| MEDIUM | conf/hadoop_env.sh | 31 | # local hadoop configuration is usually well-tailored and optimized, we'd better to leverage that. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | test/lib/sr_sql_lib.py | 3520 | except Exception: | CODE |
| HIGH | test/lib/sr_sql_lib.py | 1281 | except Exception: | CODE |
| HIGH | test/lib/arrow_sql_lib.py | 430 | except (ValueError, struct.error): | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 325 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 397 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 518 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 392 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 308 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 379 | except Exception: # noqa: BLE001 | CODE |
| HIGH | docs/scripts/run_sql_samples.py | 385 | except Exception: # noqa: BLE001 | CODE |
| HIGH | …ient/test/integration/test_autogenerate_alter_table.py | 106 | except Exception: | CODE |
| HIGH | …hon-client/test/integration/test_schema_change_wait.py | 212 | except DatabaseError: | CODE |
| HIGH | contrib/starrocks-python-client/starrocks/reflection.py | 147 | except KeyError: | CODE |
| HIGH | contrib/starrocks-python-client/starrocks/provision.py | 63 | except Exception: | CODE |
| HIGH | contrib/starrocks-python-client/starrocks/datatype.py | 319 | except NotImplementedError: | CODE |
| HIGH | build-support/extract_and_diff_params.py | 209 | except subprocess.SubprocessError: | CODE |
| HIGH | build-support/gen_build_version.py | 112 | except Exception: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | be/extension/python-udf/src/flight_server.py | 81 | except Exception: | CODE |
| LOW⚡ | be/extension/python-udf/src/flight_server.py | 102 | except Exception as e: | CODE |
| LOW⚡ | be/extension/python-udf/src/flight_server.py | 112 | except Exception as e: | CODE |
| LOW | test/run.py | 123 | except Exception as e: | CODE |
| LOW | test/test_sql_cases.py | 147 | except Exception as e: | CODE |
| LOW | test/test_sql_cases.py | 149 | except Exception as e: | CODE |
| LOW | test/tag_mac_tests.py | 57 | except Exception as e: | CODE |
| LOW | test/tag_mac_tests.py | 72 | except Exception as e: | CODE |
| LOW | test/tag_mac_tests.py | 124 | except Exception as e: | CODE |
| LOW | test/tag_mac_tests.py | 162 | except Exception as e: | CODE |
| LOW | test/lib/choose_cases.py | 474 | except Exception: | CODE |
| LOW | test/lib/choose_cases.py | 598 | except Exception: | CODE |
| LOW | test/lib/github_issue.py | 43 | except Exception as e: | CODE |
| LOW | test/lib/sql_annotation.py | 52 | except Exception as e: | CODE |
| LOW | test/lib/sql_annotation.py | 80 | except Exception as e: | CODE |
| MEDIUM | test/lib/sr_sql_lib.py | 939 | def conn_execute_sql(self, conn, sql): | CODE |
| LOW | test/lib/sr_sql_lib.py | 192 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 583 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 911 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 929 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 957 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1226 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1281 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1471 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1565 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1577 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1612 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1644 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 2312 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3520 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3784 | except Exception: | CODE |
| LOW | docs/ja/unloading/arrow_flight.md | 271 | except Exception as e: | CODE |
| LOW⚡ | docs/ja/unloading/arrow_flight.md | 1111 | except Exception as e: | STRING |
| LOW | docs/zh/unloading/arrow_flight.md | 271 | except Exception as e: | CODE |
| LOW⚡ | docs/zh/unloading/arrow_flight.md | 1111 | except Exception as e: | STRING |
| LOW⚡ | docs/scripts/run_sql_samples.py | 305 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 308 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 312 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 376 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 379 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 385 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 392 | except Exception: # noqa: BLE001 | CODE |
| LOW⚡ | docs/scripts/run_sql_samples.py | 397 | except Exception: # noqa: BLE001 | CODE |
| LOW | docs/scripts/run_sql_samples.py | 196 | except Exception: # noqa: BLE001 | CODE |
| LOW | docs/scripts/run_sql_samples.py | 325 | except Exception: # noqa: BLE001 | CODE |
| LOW | docs/scripts/run_sql_samples.py | 339 | except Exception: # noqa: BLE001 | CODE |
| LOW | docs/scripts/run_sql_samples.py | 355 | except Exception as exc: # noqa: BLE001 | CODE |
| LOW | docs/scripts/run_sql_samples.py | 518 | except Exception: # noqa: BLE001 | CODE |
| LOW | docs/en/unloading/arrow_flight.md | 271 | except Exception as e: | CODE |
| LOW⚡ | docs/en/unloading/arrow_flight.md | 1113 | except Exception as e: | STRING |
| LOW | contrib/starrocks-python-client/test/conftest_sr.py | 42 | except Exception as exc: | CODE |
| LOW | …python-client/test/integration/test_reflection_view.py | 551 | except Exception: | STRING |
| LOW | …ient/test/integration/test_autogenerate_alter_table.py | 91 | except Exception as e: | CODE |
| LOW | …ient/test/integration/test_autogenerate_alter_table.py | 106 | except Exception: | CODE |
| LOW | …-client/test/integration/test_combine_column_alters.py | 184 | except Exception as exc: # noqa: BLE001 - message is the assertion | CODE |
| MEDIUM | contrib/starrocks-python-client/starrocks/dialect.py | 1807 | def has_table( | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 896 | except Exception: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1724 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1830 | except Exception: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1857 | except Exception as e: | CODE |
| 25 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | be/test/exec/test_data/parquet_data/variant_gen.py | 96 | INSERT INTO T VALUES ('object_primitive', parse_json('{"int_field" : 1, "double_field": 1.23456789, "boolean_true_field" | CODE |
| HIGH | be/test/exec/test_data/parquet_data/variant_gen.py | 112 | INSERT INTO T VALUES ('array_nested', parse_json('[ { "id": 1, "thing": { "names": ["Contrarian", "Spider"] } }, null, { | CODE |
| HIGH | test/lib/data_insert_lib.py | 62 | values += "null, " | CODE |
| HIGH | test/lib/sr_sql_lib.py | 2812 | early when analyzeAndCreateJob gives null). Both cases look identical, and the old code | CODE |
| HIGH | test/lib/sr_sql_lib.py | 3603 | regexp_extract(line, ".*- PhySegmentsCount: (?:.*\\()?(\\d+)\\)?", 1), null)), | CODE |
| HIGH | test/lib/sr_sql_lib.py | 3605 | regexp_extract(line, ".*- SegmentsReadCount: (?:.*\\()?(\\d+)\\)?", 1), null))) as value | CODE |
| HIGH⚡ | …rrocks-python-client/test/unit/test_structured_type.py | 198 | assert _process(datatype.ARRAY(datatype.INTEGER), "[1,null,3]") == [1, None, 3] | CODE |
| HIGH⚡ | …rrocks-python-client/test/unit/test_structured_type.py | 240 | result = _process(datatype.MAP(datatype.VARCHAR(10), datatype.INTEGER), '{"a":null}') | CODE |
| HIGH⚡ | …rrocks-python-client/test/unit/test_structured_type.py | 275 | assert _process(t, '{"name":null,"age":30}') == {"name": None, "age": 30} | CODE |
| HIGH | …b/starrocks-python-client/starrocks/alembic/compare.py | 1756 | # For materialized views, if the distribution is undefined, it is auto-assigned, but appears in SHOW CREATE | COMMENT |
| HIGH⚡ | build-support/test_check_be_module_boundaries.py | 170 | 'if git cat-file -e "${{ steps.merge_base.outputs.base }}:build-support/be_module_boundary_baseline.json" 2> | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/query-trace-thread-pov.py | 44 | CODE | |
| LOW | tools/starrocks-diagnostics/starrocks-diagnostics.py | 679 | CODE | |
| LOW | nix/generate-thirdparty-archives.py | 190 | CODE | |
| LOW | be/extension/python-udf/src/flight_server.py | 52 | CODE | |
| LOW | test/test_sql_cases.py | 135 | CODE | |
| LOW | test/test_sql_cases.py | 179 | CODE | |
| LOW | test/test_sql_cases.py | 260 | CODE | |
| LOW | test/test_sql_cases.py | 306 | CODE | |
| LOW | test/test_sql_cases.py | 420 | CODE | |
| LOW | test/tag_mac_tests.py | 38 | CODE | |
| LOW | test/lib/choose_cases.py | 112 | CODE | |
| LOW | test/lib/choose_cases.py | 166 | CODE | |
| LOW | test/lib/choose_cases.py | 250 | CODE | |
| LOW | test/lib/choose_cases.py | 311 | CODE | |
| LOW | test/lib/choose_cases.py | 314 | CODE | |
| LOW | test/lib/mysql_lib.py | 64 | CODE | |
| LOW | test/lib/data_insert_lib.py | 36 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 545 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 875 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1003 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1133 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1242 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1302 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1442 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1512 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1900 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 2677 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 3558 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 3759 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 4231 | CODE | |
| LOW | test/lib/arrow_sql_lib.py | 211 | CODE | |
| LOW | test/lib/arrow_sql_lib.py | 236 | CODE | |
| LOW | test/lib/arrow_sql_lib.py | 281 | CODE | |
| LOW | test/lib/arrow_sql_lib.py | 327 | CODE | |
| LOW | test/lib/arrow_sql_lib.py | 109 | CODE | |
| LOW | docs/scripts/run_sql_samples.py | 287 | CODE | |
| LOW | docs/scripts/extract_sql_samples.py | 169 | CODE | |
| LOW | docs/scripts/sql_sample_parity.py | 70 | CODE | |
| LOW | docs/scripts/check_function_signatures.py | 218 | CODE | |
| LOW | docs/scripts/check_function_signatures.py | 386 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 49 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 1562 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 1630 | CODE | |
| LOW | …hon-client/test/integration/test_autogenerate_views.py | 827 | CODE | |
| LOW | …hon-client/test/integration/test_schema_change_wait.py | 201 | CODE | |
| LOW | …ks-python-client/test/sql/test_compiler_alter_table.py | 181 | CODE | |
| LOW | …ks-python-client/test/sql/test_compiler_alter_table.py | 611 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 658 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 795 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1749 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 408 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 372 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 138 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 185 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 225 | CODE | |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 1077 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 205 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1860 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 220 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 222 | CODE | |
| 19 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | run-fe-ut.sh | 154 | # Check if we're on Linux platform | COMMENT |
| LOW | run-fe-ut.sh | 156 | # Check if async profiler library exists | COMMENT |
| LOW | build-in-docker.sh | 154 | # Check if Docker is available | COMMENT |
| LOW | build-in-docker.sh | 220 | # Check if protobuf version mismatch exists | COMMENT |
| LOW | tools/json_data_generator/test_starrocks_json.sh | 243 | # Check if import was successful | COMMENT |
| LOW | docker/dockerfiles/be/upload_coredump.sh | 61 | # Check if file size is greater than 1TB | COMMENT |
| LOW | docker/dockerfiles/be/upload_coredump.sh | 79 | # Check if the creation time of the file is more than 10 minutes later than the file handles in the previous loop iter | COMMENT |
| LOW | be/test/exec/test_data/json_scanner/create_gzip.sh | 8 | # Check if gzip is available | COMMENT |
| LOW | test/test_sql_cases.py | 93 | # Check if case has @arrow_flight_sql tag and setup connection accordingly | COMMENT |
| LOW | test/tag_mac_tests.py | 111 | # Check if test passed | COMMENT |
| LOW | test/tag_mac_tests.py | 140 | # Check if first line is name comment | COMMENT |
| LOW | test/tag_mac_tests.py | 201 | # Check if matches filter | COMMENT |
| LOW | test/tag_mac_tests.py | 207 | # Check if already has @mac tag | COMMENT |
| LOW | test/sql/test_optimize_table/T/insert.sh | 3 | # Check if the required number of arguments is provided | COMMENT |
| LOW | bin/collect_be_profile.sh | 94 | # Check if a directory or file is writable, exit if not | COMMENT |
| LOW | bin/collect_be_profile.sh | 113 | # Check if directory exists | COMMENT |
| LOW | bin/collect_be_profile.sh | 238 | # Check if BRPC server is accessible | COMMENT |
| LOW | bin/collect_be_profile.sh | 293 | # Check if curl command succeeds | COMMENT |
| LOW | bin/collect_be_profile.sh | 299 | # Check if file was created and has content | COMMENT |
| LOW | bin/collect_be_profile.sh | 333 | # Check if file is too old | COMMENT |
| LOW | bin/collect_be_profile.sh | 404 | # Check if BRPC server is still accessible | COMMENT |
| LOW | bin/stop_be.sh | 88 | # Check if the process is actually a profile collection daemon | COMMENT |
| LOW | …ker/doc-verification/docker-compose-shared-nothing.yml | 2 | # Set SR_VERSION to the StarRocks release whose docs you are testing, e.g. | COMMENT |
| LOW | …docker/doc-verification/docker-compose-shared-data.yml | 2 | # Set SR_VERSION to the StarRocks release whose docs you are testing, e.g. | COMMENT |
| LOW | …ient/test/integration/test_autogenerate_alter_table.py | 583 | # Check if properties are in the expected location | STRING |
| LOW | …ib/starrocks-python-client/starrocks/alembic/render.py | 78 | # Check if the object is a user-defined type in our custom module | COMMENT |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1335 | # Check if we're comparing View/MaterializedView objects | COMMENT |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1596 | # Check if conn_value starts with the default_value, ignoring case and spaces | COMMENT |
| LOW | gensrc/script/gen_functions.py | 373 | # Check if function has named arguments | COMMENT |
| LOW | build-support/extract_and_diff_params.py | 317 | # Check if @Deprecated appears on the immediately preceding non-blank line | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …r/starrocks_fe/datadog_checks/starrocks_fe/__init__.py | 7 | __all__ = ['__version__', 'StarrocksFeCheck'] | CODE |
| LOW | …r/starrocks_be/datadog_checks/starrocks_be/__init__.py | 7 | __all__ = ['__version__', 'StarrocksBeCheck'] | CODE |
| LOW | contrib/starrocks-python-client/test/test_suite.py | 59 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ntrib/starrocks-python-client/test/unit/test_parser.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW⚡ | …starrocks-python-client/test/unit/test_render_views.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …rrocks-python-client/test/unit/test_compare_columns.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …python-client/test/unit/test_alter_table_operations.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 40 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ython-client/test/integration/test_autogenerate_mvs.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | …-client/test/integration/test_reflection_data_types.py | 59 | logger = logging.getLogger(__name__) | CODE |
| LOW | …python-client/test/integration/test_reflection_view.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ython-client/test/integration/test_result_processor.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …hon-client/test/integration/test_autogenerate_views.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ient/test/integration/test_autogenerate_alter_table.py | 55 | logger = logging.getLogger(__name__) | CODE |
| LOW | …st/integration/test_combine_column_alters_range_key.py | 52 | logger = logging.getLogger(__name__) | CODE |
| LOW | …-client/test/integration/test_combine_column_alters.py | 42 | logger = logging.getLogger(__name__) | CODE |
| LOW⚡ | …ython-client/test/integration/test_reflection_table.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | …n-client/test/integration/test_autogenerate_columns.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | …hon-client/test/integration/test_reflection_columns.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …hon-client/test/integration/test_reflection_indexes.py | 47 | logger = logging.getLogger(__name__) | CODE |
| LOW | …s-python-client/test/integration/test_reflection_mv.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …hon-client/test/integration/test_schema_change_wait.py | 47 | logger = logging.getLogger(__name__) | CODE |
| LOW | contrib/starrocks-python-client/test/system/conftest.py | 31 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ocks-python-client/test/system/test_table_lifecycle.py | 56 | logger = logging.getLogger(__name__) | CODE |
| LOW | …arrocks-python-client/test/system/test_mv_lifecycle.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | …rocks-python-client/test/system/test_view_lifecycle.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ocks-python-client/test/system/test_type_comparison.py | 37 | logger = logging.getLogger(__name__) | CODE |
| LOW | …b/starrocks-python-client/test/system/templates/env.py | 45 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ks-python-client/test/sql/test_compiler_alter_table.py | 42 | logger = logging.getLogger(__name__) | CODE |
| LOW | …s-python-client/test/sql/test_compiler_alter_column.py | 42 | logger = logging.getLogger(__name__) | CODE |
| LOW | …b/starrocks-python-client/test/sql/test_compiler_mv.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 140 | logger = logging.getLogger(__name__) | CODE |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 56 | logger = logging.getLogger(__name__) | CODE |
| LOW | …b/starrocks-python-client/starrocks/drivers/parsers.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …rib/starrocks-python-client/starrocks/common/params.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | …rrocks-python-client/starrocks/common/sql_canonical.py | 31 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/starrocks-python-client/starrocks/alembic/__init__.py | 22 | __all__ = [ | CODE |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 31 | logger = logging.getLogger(__name__) | CODE |
| LOW | …starrocks-python-client/starrocks/alembic/starrocks.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ib/starrocks-python-client/starrocks/alembic/toimpl.py | 48 | logger = logging.getLogger(__name__) | CODE |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 68 | logger = logging.getLogger(__name__) | CODE |
| LOW | contrib/starrocks-python-client/starrocks/sql/schema.py | 27 | logger = logging.getLogger(__name__) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | contrib/starrocks-python-client/starrocks/dialect.py | 1371 | Get the StarRocks system run_mode (shared_data or shared_nothing). Args: connection: The SQLAlchemy | STRING |
| HIGH | …b/starrocks-python-client/starrocks/alembic/compare.py | 772 | Compare view security attribute and update AlterViewOp if changed. Args: alter_view_op: AlterViewOp ob | STRING |
| HIGH | …b/starrocks-python-client/starrocks/alembic/compare.py | 1551 | Get table key type. like 'PRIMARY KEY (id, name)' The key in table_attributes is like 'PRIMARY_KEY' without prefix ' | STRING |
| HIGH | …b/starrocks-python-client/starrocks/alembic/compare.py | 2015 | Generic comparison logic for a single table attribute. Args: table_name: Table name for logging contex | STRING |
| HIGH | contrib/starrocks-python-client/starrocks/sql/schema.py | 91 | Create a View object. Args: name: Name of the view metadata: MetaData object t | STRING |
| HIGH | contrib/starrocks-python-client/starrocks/sql/schema.py | 220 | Process view definition and return view_info dict. This is a helper method to avoid code duplication b | STRING |
| HIGH | contrib/starrocks-python-client/starrocks/sql/schema.py | 255 | Convert simplified column definitions to Column objects. Args: columns: List of column def | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nector/hive/scanner/test_data/2_cols_2_rows_large.json | 1 | {"c1": 1001, "c2": "In the context of big data testing with Iceberg and semi-structured data, this string is designed to | CODE |
| LOW | …nector/hive/scanner/test_data/2_cols_2_rows_large.json | 1 | {"c1": 1001, "c2": "In the context of big data testing with Iceberg and semi-structured data, this string is designed to | CODE |
| LOW | be/src/formats/json/map_column.cpp | 46 | auto dummy_json = simdjson::padded_string(R"({"dummy_key": ")" + std::string(field_name_str) + R"("})"); | CODE |
| LOW | be/src/formats/json/map_column.cpp | 49 | simdjson::ondemand::value field_key = obj.find_field("dummy_key"); | CODE |
| LOW | be/src/storage_primitive/column_predicate_cmp.cpp | 1161 | os << "placeholder"; | CODE |
| LOW⚡ | be/src/data_workflows/load/push_broker_reader.cpp | 43 | TUniqueId dummy_id; | CODE |
| LOW⚡ | be/src/data_workflows/load/push_broker_reader.cpp | 44 | dummy_id.hi = 0; | CODE |
| LOW⚡ | be/src/data_workflows/load/push_broker_reader.cpp | 45 | dummy_id.lo = 0; | CODE |
| LOW⚡ | be/src/data_workflows/load/push_broker_reader.cpp | 47 | params.fragment_instance_id = dummy_id; | CODE |
| LOW⚡ | be/src/data_workflows/load/push_broker_reader.cpp | 48 | params.query_id = dummy_id; | CODE |
| LOW | be/src/data_workflows/load/push_broker_reader.cpp | 69 | _runtime_state->init_mem_trackers(dummy_id, ExecEnv::GetInstance()->query_pool_mem_tracker()); | CODE |
| LOW | webroot/static/jquery.dataTables.js | 4204 | .attr( 'placeholder', language.sSearchPlaceholder ) | CODE |
| LOW | webroot/static/jquery.dataTables.js | 12481 | * // { "phone": 5552368, "phone_filter": "5552368 555-2368", "phone_display": "555-2368" } | COMMENT |
| LOW | …ava/com/starrocks/service/FrontendServiceImplTest.java | 2060 | testRequestMergeCommitBase(request -> request.setUser("fake_user"), | CODE |
| LOW | docs/ja/using_starrocks/skew_join_v2.md | 98 | (1001, 'John Doe', 'New York'), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 103 | (1, 'John Doe', 5000), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 154 | (1,'Acme Corporation','John Doe'), | CODE |
| LOW | docs/zh/using_starrocks/skew_join_v2.md | 98 | (1001, 'John Doe', 'New York'), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 101 | (1, 'John Doe', 5000), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 152 | (1,'Acme Corporation','John Doe'), | CODE |
| LOW | docs/en/using_starrocks/skew_join_v2.md | 98 | (1001, 'John Doe', 'New York'), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 103 | (1, 'John Doe', 5000), | CODE |
| LOW | …rence/sql-statements/table_bucket_part_index/UPDATE.md | 154 | (1,'Acme Corporation','John Doe'), | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | build.sh | 21 | # Usage: | COMMENT |
| LOW | build-in-docker.sh | 21 | # Usage: | COMMENT |
| LOW | be/test/testutil/desc_tbl_builder.h | 54 | // Example usage: | COMMENT |
| LOW | be/src/gutil/map_util.h | 782 | // Example usage: | COMMENT |
| LOW | be/src/gutil/map_util.h | 795 | // Example usage: | COMMENT |
| LOW | be/src/gutil/map_util.h | 829 | // Example usage: | COMMENT |
| LOW | be/src/fs/output_stream_wrapper.h | 26 | // Example usage: | COMMENT |
| LOW | be/src/base/string/slice.h | 344 | // Usage example: | COMMENT |
| LOW | bin/stop_be.sh | 21 | # Usage: | COMMENT |
| LOW | bin/stop_cn.sh | 21 | # Usage: | COMMENT |
| LOW | .claude/skills/release-notes/scripts/collect-prs.sh | 14 | # Usage: | COMMENT |
| LOW | docs/scripts/supported_versions.sh | 11 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | be/test/exec/join_hash_map_test.cpp | 802 | //TODO: implement | COMMENT |
| LOW | be/src/formats/parquet/scalar_column_reader.cpp | 443 | //TODO: implement parquet_bloom_filter(bloom_filter, col_type, parquet_logical_type, parquet_physical_ty | COMMENT |
| LOW | be/src/storage/tablet_schema.cpp | 423 | // TODO: implement multi-column index | COMMENT |
| LOW | be/src/exprs/expr.cpp | 225 | // TODO: implement partial debug string for member vars | COMMENT |
| LOW | be/src/exprs/udf/java/java_udf_context.h | 82 | // TODO: implement a Java binder to avoid using this class | COMMENT |
| LOW | …ks/connector/delta/ScalarOperationToDeltaLakeExpr.java | 117 | // TODO: implement | COMMENT |
| LOW | …ain/java/com/starrocks/sql/optimizer/rule/RuleSet.java | 522 | // TODO: implement merge join | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | be/src/storage_primitive/tablet_column.h | 56 | // To developers: if you changed the typedefs, don't forget to reorder class members to | COMMENT |
| LOW | be/src/column/column_helper.h | 641 | // Don't forget to resize the result constant columns if necessary. | COMMENT |
| MEDIUM | be/src/base/time/time.h | 132 | /// yyyy-MM-dd HH:mm:SS[.ms[us[ns]]. It's worth noting that if the precision specified | COMMENT |
| MEDIUM | thirdparty/build-thirdparty.sh | 1385 | # only build s3, s3-crt, transfer manager, identity-management and sts, you can add more components if you want. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | .github/workflows/ci-doc-needs-update.yml | 30 | # the "I have added documentation" box. Doc PRs themselves are excluded. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | be/extension/python-udf/src/flight_server.py | 202 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 831 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 839 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 848 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 990 | CODE | |
| LOW | contrib/starrocks-python-client/test/test_suite.py | 257 | CODE | |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 85 | CODE | |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 125 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/sql/dml.py | 324 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | .github/copilot-instructions.md | 243 | - `gensrc/` - Auto-generated code from IDL definitions | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 108 | CODE | |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 115 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | webroot/static/jquery.js | 4401 | function getData( data ) { | CODE |