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 presents the forensic synthetic code analysis of StarRocks/starrocks, a Java project with 11,883 GitHub stars. SynthScan v2.0 examined 3,582,744 lines of code across 15778 source files, recording 17778 pattern matches distributed across 26 syntactic categories. The overall adjusted score of 7.7 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 17778 distinct pattern matches across 26 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | 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 | …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 | …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 |
| LOW | …s/connector/iceberg/IcebergPartitionsTableScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …va/com/starrocks/kudu/reader/TestKuduSplitScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …com/starrocks/kudu/reader/KuduSplitScannerFactory.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| LOW | …n/java/com/starrocks/kudu/reader/KuduSplitScanner.java | 1 | // Copyright 2021-present StarRocks, Inc. All rights reserved. | COMMENT |
| 14705 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 |
| 789 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | run-be-ut.sh | 447 | # =========================================================== | COMMENT |
| MEDIUM | tools/benchmark/table_sample.sh | 23 | # -------------- | COMMENT |
| MEDIUM | be/test/CMakeLists.txt | 424 | # ================================================= | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 122 | // ─── existing test ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 159 | // ─── build_variant_binding_from_node ──────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 284 | // ─── append_variant_binding_row ───────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 325 | // ─── encode_datum error paths ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/complex_column_reader_test.cpp | 456 | // ─── VariantVirtualZoneMapReader tests ─────────────────────────────────────── | 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 | 4063 | // ── Decimal virtual column fallback tests ────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4202 | // ── LazyMaterializationContext tests ───────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4656 | // ── Temp Column Lifecycle Tests ────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/formats/parquet/group_reader_test.cpp | 4823 | // ── Logical-column bypass in emit_physical_columns ─────────────────────────── | COMMENT |
| MEDIUM | be/test/storage/lake/tablet_reshard_test.cpp | 7956 | // ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/test/storage/lake/tablet_reshard_test.cpp | 7958 | // ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 52 | // ┌────────────────────────────────────────────────────────────┐ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 54 | // └────────────────────────────────────────────────────────────┘ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 90 | // ┌────────────────────────────────────────────────────────────┐ | COMMENT |
| MEDIUM | be/src/data_sink/result/arrow_result_writer.cpp | 92 | // └────────────────────────────────────────────────────────────┘ | 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 | 145 | // ── Initialization ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 156 | // ── get_next() pipeline phases ─────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.h | 193 | // ── Member variables ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.h | 50 | // ── Free functions: variant projection utilities ──────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 75 | // ── Setup (called once during GroupReader::_create_column_readers) ────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 83 | // ── Classification (during _process_columns_and_conjunct_ctxs) ────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 92 | // ── Prepare (during GroupReader::prepare / _prepare_column_readers) ────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 99 | // ── Lazy→active promotion when active_chunk would be empty ─────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 102 | // ── IO range collection ────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 106 | // ── Read chunk initialisation ──────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.h | 109 | // ── get_next() phases ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.h | 171 | // ── 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 | 391 | // ── VariantProjectionHandler ──────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 399 | // ── _build_shredded_hints ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 405 | // ── setup_readers ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 485 | // ── Classification helpers ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 551 | // ── Prepare ───────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 572 | // ── Promotion ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/variant_projection.cpp | 717 | // ── Lazy→active promotion ─────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 732 | // ── IO range collection ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 742 | // ── Read chunk init ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | be/src/formats/parquet/variant_projection.cpp | 752 | // ── get_next() phases ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 54 | // ── GroupReader: construction / destruction ───────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 91 | // ── init / prepare ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 141 | // ── Simple accessors ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 171 | // ── get_next: materialise one chunk from the current row group ────────────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 251 | // ── 1. Prune deleted rows ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 266 | // ── 2. Read & filter active columns ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 286 | // ── 3. Evaluate compound predicates ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 329 | // ── 4. Evaluate variant predicates ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 357 | // ── 5. Filter & backfill lazy ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 392 | // ── 7. Emit output ────── | COMMENT |
| MEDIUM | be/src/formats/parquet/group_reader.cpp | 408 | // ── Column reader creation ───────────────────────────────────────────────── | COMMENT |
| 315 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 | 57 | 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/sr_sql_lib.py | 418 | def check_case_result_contains_crash(crash_msg_list, case_result_logs): | CODE |
| LOW | test/lib/sr_sql_lib.py | 596 | def create_starrocks_conn_pool(self): | CODE |
| LOW | test/lib/sr_sql_lib.py | 665 | def _create_iceberg_catalog_hive(self, catalog_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 684 | def _create_iceberg_catalog_hadoop(self, catalog_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 706 | def create_database_and_table(self, catalog_name, database_name, table_name, table_sql_path=None, | CODE |
| LOW | test/lib/sr_sql_lib.py | 1796 | def wait_db_transaction_finish(self, db_name, timeout_sec=30): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1824 | def get_running_transaction_count(self, db_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1836 | def get_single_running_transaction_label(self, db_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1901 | def check_routine_load_progress(self, sum_data_count, task_name, db_name, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 1992 | def wait_materialized_view_finish(self, check_count=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2034 | def wait_materialized_view_cancel(self, check_count=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2072 | def wait_show_materialized_view_finish(self, mv_name, check_count=60): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2089 | def wait_async_materialized_view_finish(self, current_db, mv_name, check_count=None): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2170 | def get_task_run_success_count(self, results): | CODE |
| LOW | test/lib/sr_sql_lib.py | 2795 | def check_es_table_metadata_ready(self, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3272 | def set_vlog_level_for_all_be(self, prefixes, level: int): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3303 | def wait_refresh_dictionary_finish(self, name, check_status): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3320 | def set_first_tablet_bad_and_recover(self, table_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3351 | def assert_is_identical_explain_plan(self, query1, query2): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3374 | def assert_query_not_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3385 | def assert_query_contains_times(self, query, expect, expected_times: int): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3402 | def assert_query_error_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3426 | def assert_explain_not_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3435 | def assert_explain_verbose_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3449 | def assert_explain_costs_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3462 | def get_col_stats_from_explain_costs(self, query, col_name): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3477 | def assert_show_stats_meta_contains(self, predicate, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3491 | def assert_trace_values_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3522 | def assert_prepare_execute_varchar_metadata(self, db, query, expected_prepare_len, expected_execute_len=None, | CODE |
| LOW | test/lib/sr_sql_lib.py | 3589 | def execute_with_prepared_connection(self, sql): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3592 | def assert_trace_times_contains(self, query, *expects): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3617 | def print_table_partitions_num(self, table_name) -> str: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3623 | def print_plan_partition_selected_num(self, sql, table_name) -> str: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3642 | def assert_table_partitions_num(self, table_name, expect_num): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3648 | def wait_table_rowcount_not_empty(self, table, max_times=300): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3663 | def assert_cache_select_is_success(self, query): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3886 | def wait_for_prepared_stmt_detail(self, prepared_stmt_id): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3893 | def assert_prepared_stmt_details(self): | CODE |
| LOW | test/lib/sr_sql_lib.py | 3909 | def assert_query_detail_field(self, query_detail, field_name, expected_value=None): | CODE |
| 640 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 | 1480 | // Step 1: Write txn generates a delvec for segment 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 1488 | // Step 2: Compaction removes rowset 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 1496 | // Step 3: Finalize - this is where the bug would manifest | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 4240 | // Step 3: Verify correctness - the last partial update set c1 = c0 * (5 + kNumPartialUpdates - 1) | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 4247 | // Step 4: Verify metadata - should still have same number of rowsets (column update | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3757 | // Step 1: Write initial full data with all 3 columns (pk 0-11) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3778 | // 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 | 3842 | // Step 3: Update existing rows with COLUMN_UPSERT_MODE | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3866 | // Step 4: Verify functional correctness | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3925 | // Step 1: Write initial full data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3944 | // Step 2: Partial update with COLUMN_UPSERT_MODE (updating existing rows) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3975 | // Step 3: Verify that orphan_files contains the partial segments | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4002 | // Step 1: Write base data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4024 | // 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 | 4104 | // Step 3: Verify the result | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4172 | // Step 1: Create multiple source segments by writing full data multiple times | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4198 | // Step 2: Perform partial column updates with multiple update segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4272 | // Step 1: Create initial full data with multiple key ranges. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4294 | // Step 2: Perform row-mode partial update with multiple segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4328 | // Step 3: Verify correctness - c1 should be updated (c0 * 7), | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2783 | // Step 3: Verify sstable_meta is cleared after full replication | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2792 | // Step 4: Write more data - this should NOT fail with "unexpected segment id" | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2923 | // Step 4: Verify delvec_meta and dcg_meta are cleared | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2930 | // Step 5: Verify old delvec and dcg files are marked as orphan files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2691 | // Step 1: Write some data to generate SST files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2723 | // Step 2: Simulate full replication by creating a replication txn log | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2826 | // Step 1: Write initial data | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2847 | // 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 | 2869 | // Step 3: Simulate full replication | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1348 | // Step 1: query "$.a.b" — parent of typed column "a.b.c" | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1359 | // Step 2: query "$.c" from the sub-object — must be 42 (from typed column) | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1371 | // 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 | 664 | // Step 1: Create PK tablet with one committed rowset. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 687 | // Step 2: Migrate A->B. Wait until clock passes rowset_time so migration1 wins. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 697 | // Step 3: GC runs synchronously. A sync point callback injects migration B->A | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 716 | // Step 4: Verify V3 on disk_a has its rowset metadata intact. | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 728 | // Step 5: Verify restart-loading works — proves on-disk meta is complete. | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 102 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 113 | // Step 2: fill version magic_num, first column must be version(const int) | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 126 | // 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 | 43 | // 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 | 336 | // 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 | 333 | // Step 1: Evaluate predicates on dictionary once and reuse the selection across pages. | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 348 | // 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 | 367 | // Step 3: Update selection based on dictionary selection and collect matching slices | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 382 | // Step 4: Append selected strings to column using append_strings_overflow | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 322 | // Step 3: Distribute segment data across overlapping ranges. | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 327 | // Step 4: Calculate split boundaries using a greedy algorithm. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 248 | // Step 1: Collect all unique boundary points (including sort-key samples) and sort them. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 309 | // Step 2: Build ordered ranges between adjacent boundary points. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 469 | // Step 5: Estimate per-range data sizes by walking candidate ranges against boundaries. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 692 | // Step 2: Calculate split boundaries with tablet range filtering. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 711 | // Step 3: Build TabletRangeInfo directly from result. | COMMENT |
| 194 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 | 1480 | // Step 1: Write txn generates a delvec for segment 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 1488 | // Step 2: Compaction removes rowset 100 | COMMENT |
| LOW⚡ | be/test/storage/lake/meta_file_test.cpp | 1496 | // Step 3: Finalize - this is where the bug would manifest | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 4240 | // Step 3: Verify correctness - the last partial update set c1 = c0 * (5 + kNumPartialUpdates - 1) | COMMENT |
| LOW⚡ | be/test/storage/lake/partial_update_test.cpp | 4247 | // Step 4: Verify metadata - should still have same number of rowsets (column update | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3757 | // Step 1: Write initial full data with all 3 columns (pk 0-11) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3778 | // 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 | 3842 | // Step 3: Update existing rows with COLUMN_UPSERT_MODE | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3866 | // Step 4: Verify functional correctness | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3925 | // Step 1: Write initial full data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3944 | // Step 2: Partial update with COLUMN_UPSERT_MODE (updating existing rows) | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 3975 | // Step 3: Verify that orphan_files contains the partial segments | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4002 | // Step 1: Write base data | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4024 | // 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 | 4104 | // Step 3: Verify the result | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4172 | // Step 1: Create multiple source segments by writing full data multiple times | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4198 | // Step 2: Perform partial column updates with multiple update segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4272 | // Step 1: Create initial full data with multiple key ranges. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4294 | // Step 2: Perform row-mode partial update with multiple segments per txn. | COMMENT |
| LOW | be/test/storage/lake/partial_update_test.cpp | 4328 | // Step 3: Verify correctness - c1 should be updated (c0 * 7), | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2783 | // Step 3: Verify sstable_meta is cleared after full replication | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2792 | // Step 4: Write more data - this should NOT fail with "unexpected segment id" | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2923 | // Step 4: Verify delvec_meta and dcg_meta are cleared | COMMENT |
| LOW⚡ | be/test/storage/lake/primary_key_publish_test.cpp | 2930 | // Step 5: Verify old delvec and dcg files are marked as orphan files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2691 | // Step 1: Write some data to generate SST files | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2723 | // Step 2: Simulate full replication by creating a replication txn log | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2826 | // Step 1: Write initial data | COMMENT |
| LOW | be/test/storage/lake/primary_key_publish_test.cpp | 2847 | // 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 | 2869 | // Step 3: Simulate full replication | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1348 | // Step 1: query "$.a.b" — parent of typed column "a.b.c" | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1359 | // Step 2: query "$.c" from the sub-object — must be 42 (from typed column) | COMMENT |
| LOW | be/test/exprs/variant_functions_test.cpp | 1371 | // 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 | 664 | // Step 1: Create PK tablet with one committed rowset. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 687 | // Step 2: Migrate A->B. Wait until clock passes rowset_time so migration1 wins. | COMMENT |
| LOW⚡ | …flows/migration/engine_storage_migration_task_test.cpp | 697 | // Step 3: GC runs synchronously. A sync point callback injects migration B->A | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 716 | // Step 4: Verify V3 on disk_a has its rowset metadata intact. | COMMENT |
| LOW | …flows/migration/engine_storage_migration_task_test.cpp | 728 | // Step 5: Verify restart-loading works — proves on-disk meta is complete. | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 102 | // Step 1: compute expr | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 113 | // Step 2: fill version magic_num, first column must be version(const int) | COMMENT |
| LOW | be/src/data_sink/result/statistic_result_writer.cpp | 126 | // 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 | 333 | // Step 1: Evaluate predicates on dictionary once and reuse the selection across pages. | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 348 | // 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 | 367 | // Step 3: Update selection based on dictionary selection and collect matching slices | COMMENT |
| LOW | be/src/storage/rowset/binary_dict_page.cpp | 382 | // Step 4: Append selected strings to column using append_strings_overflow | COMMENT |
| LOW | be/src/storage/rowset/segment.cpp | 510 | // 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 | 322 | // Step 3: Distribute segment data across overlapping ranges. | COMMENT |
| LOW⚡ | be/src/storage/lake/tablet_splitter.cpp | 327 | // Step 4: Calculate split boundaries using a greedy algorithm. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 248 | // Step 1: Collect all unique boundary points (including sort-key samples) and sort them. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 309 | // Step 2: Build ordered ranges between adjacent boundary points. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 469 | // Step 5: Estimate per-range data sizes by walking candidate ranges against boundaries. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 692 | // Step 2: Calculate split boundaries with tablet range filtering. | COMMENT |
| LOW | be/src/storage/lake/tablet_splitter.cpp | 711 | // Step 3: Build TabletRangeInfo directly from result. | COMMENT |
| LOW⚡ | …rc/storage/lake/tablet_parallel_compaction_manager.cpp | 372 | // Step 1: Sort rowsets by their index in metadata to ensure adjacency when grouped. | COMMENT |
| LOW⚡ | …rc/storage/lake/tablet_parallel_compaction_manager.cpp | 378 | // Step 2: Filter out large non-overlapped rowsets that don't need compaction. | COMMENT |
| 141 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | 135 | #./orchestration/routine_load_task_executor_test.cpp | COMMENT |
| MEDIUM | be/test/storage/lake/tablet_manager_test.cpp | 1584 | // 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 | 66 | #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/external_scan_orchestrator_test.cpp | 36 | #include "orchestration/fragment_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 | …/test/orchestration/external_scan_context_mgr_test.cpp | 54 | #include "orchestration/fragment_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 | 49 | #include "orchestration/orchestration_env.h" | COMMENT |
| MEDIUM | be/src/http/action/transaction_stream_load.cpp | 54 | #include "orchestration/stream_load_orchestrator.h" | COMMENT |
| MEDIUM | be/src/http/action/stream_load.cpp | 76 | #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 | 41 | #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/external_scan_context_mgr.cpp | 52 | #include "orchestration/fragment_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 | 28 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM | be/src/orchestration/stream_load_orchestrator.cpp | 29 | #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 | 44 | #include "orchestration/external_scan_orchestrator.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 45 | #include "orchestration/fragment_mgr.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 46 | #include "orchestration/orchestration_env.h" | COMMENT |
| MEDIUM⚡ | be/src/service/backend_base.cpp | 47 | #include "orchestration/routine_load_task_executor.h" | COMMENT |
| MEDIUM⚡ | be/src/service/internal_service.cpp | 86 | #include "orchestration/fragment_executor.h" | COMMENT |
| 7 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⚡ | …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 | 221 | # Create a materialized view with comment | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 252 | # Create a materialized view with aggregation | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 298 | # Create a materialized view with window functions | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 341 | # Create a materialized view with CTE | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 385 | # Create a materialized view with special characters | COMMENT |
| MEDIUM | …s-python-client/test/integration/test_reflection_mv.py | 522 | # 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 | 104 | # Create a minimal MaterializedView object for DROP operation | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 413 | # Create a View object (not Table) since we know it's a view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 436 | # Create a View object (not Table) since we know it's a view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 911 | # Create a MaterializedView object (not Table) since we know it's a materialized view | COMMENT |
| MEDIUM | …b/starrocks-python-client/starrocks/alembic/compare.py | 934 | # Create a MaterializedView object (not Table) since we know it's a materialized view | COMMENT |
| MEDIUM | thirdparty/build-thirdparty.sh | 1044 | # 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 | 77 | CODE | |
| LOW | docs/scripts/extract_sql_samples.py | 33 | 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 | …n-client/test/integration/test_autogenerate_columns.py | 15 | CODE | |
| LOW | …rrocks-python-client/test/integration/templates/env.py | 19 | CODE | |
| LOW | contrib/starrocks-python-client/test/system/conftest.py | 15 | CODE | |
| LOW | …ocks-python-client/test/system/test_table_lifecycle.py | 16 | CODE | |
| LOW | …s-python-client/test/sql/test_compiler_alter_column.py | 33 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 21 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 21 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 26 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 26 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 201 | CODE | |
| LOW | …trib/starrocks-python-client/examples/view_examples.py | 201 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/asyncmy.py | 15 | CODE | |
| 80 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | be/test/storage/lake/condition_update_test.cpp | 722 | // 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 | 2985 | // and may fail with NotFound; allow either path so the test is robust. | COMMENT |
| MEDIUM | be/test/storage/lake/persistent_index_sstable_test.cpp | 1018 | // instead so the test is robust against the compiler's string pooling decisions. | COMMENT |
| MEDIUM | be/test/fs_ext/hdfs_filesystem_test.cpp | 56 | // use file:// as the fs scheme, which will leverage Hadoop LocalFileSystem for testing | 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 | 205 | // only when `default_value` is not set to make schema conversion robust. | COMMENT |
| MEDIUM | be/src/column/variant_column.h | 77 | // 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 | 554 | // Resolve the root column by unique id to be robust across schema changes | COMMENT |
| MEDIUM | be/src/storage/lake/tablet_manager.cpp | 1339 | // 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 | 1351 | // path (try_replace), which is more robust and performant. | 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 | 156 | // 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 | 512 | // Whole-second max; assert the second prefix to stay robust to a sub-millisecond stats | COMMENT |
| MEDIUM | …er/reshard/presplit/OrcStripeStatisticsReaderTest.java | 716 | // 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 | 751 | // TODO: Implement a more robust strategy for tablet affinity. | COMMENT |
| MEDIUM | …ore/src/main/java/com/starrocks/catalog/OlapTable.java | 264 | // 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 | 529 | // TODO(stephen): This check is not robust because we can't get job handle here. | COMMENT |
| MEDIUM | …/sql/optimizer/statistics/StatisticsEstimateUtils.java | 216 | // 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 | 434 | # 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 |
|---|---|---|---|---|
| LOW⚡ | be/extension/python-udf/src/flight_server.py | 41 | except Exception as e: | CODE |
| LOW⚡ | be/extension/python-udf/src/flight_server.py | 51 | 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 | 471 | except Exception: | CODE |
| LOW | test/lib/choose_cases.py | 595 | 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 | 856 | def conn_execute_sql(self, conn, sql): | CODE |
| LOW | test/lib/sr_sql_lib.py | 111 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 500 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 828 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 846 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 874 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1116 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1171 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1348 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1441 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1453 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1488 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 1520 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 2030 | except Exception as e: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3068 | except Exception: | CODE |
| LOW | test/lib/sr_sql_lib.py | 3264 | except Exception: | CODE |
| LOW | docs/ja/unloading/arrow_flight.md | 270 | except Exception as e: | CODE |
| LOW⚡ | docs/ja/unloading/arrow_flight.md | 1110 | except Exception as e: | STRING |
| LOW | docs/zh/unloading/arrow_flight.md | 270 | except Exception as e: | CODE |
| LOW⚡ | docs/zh/unloading/arrow_flight.md | 1110 | except Exception as e: | STRING |
| LOW | docs/en/unloading/arrow_flight.md | 270 | except Exception as e: | CODE |
| LOW⚡ | docs/en/unloading/arrow_flight.md | 1112 | 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 |
| MEDIUM | contrib/starrocks-python-client/starrocks/dialect.py | 1750 | def has_table( | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 887 | except Exception: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1667 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1773 | except Exception: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1800 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1822 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1865 | except Exception: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1895 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1906 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1913 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1520 | except Exception as e: | STRING |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1638 | except Exception as e: | STRING |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 342 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 704 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 759 | except Exception as e: | CODE |
| LOW | contrib/starrocks-python-client/starrocks/provision.py | 63 | except Exception: | CODE |
| LOW | .github/workflows/ci-doc-needs-update.yml | 168 | except Exception: | CODE |
| LOW | build-support/run_clang_format.py | 101 | except Exception: | CODE |
| MEDIUM | build-support/sync_pom_to_gradle.py | 244 | print(f"Error reading gradle file {gradle_file}: {e}", file=sys.stderr) | CODE |
| MEDIUM | build-support/sync_pom_to_gradle.py | 294 | print(f"Error writing to gradle file {gradle_file}: {e}", file=sys.stderr) | CODE |
| 4 more matches not shown… | ||||
| 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 | 186 | 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 | 462 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 792 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 920 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1023 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1132 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1192 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1319 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1389 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 1776 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 2312 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 2402 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 3106 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 3243 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 3623 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 2317 | 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/extract_sql_samples.py | 107 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 49 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 1474 | CODE | |
| LOW | …arrocks-python-client/test/unit/test_compare_tables.py | 1542 | CODE | |
| LOW | …hon-client/test/integration/test_autogenerate_views.py | 827 | 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 | 649 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 786 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/dialect.py | 1692 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 407 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 314 | CODE | |
| LOW | …trib/starrocks-python-client/starrocks/common/utils.py | 138 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 200 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1738 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 215 | CODE | |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 217 | CODE | |
| LOW | contrib/starrocks-python-client/starrocks/sql/schema.py | 254 | CODE | |
| LOW | gensrc/script/gen_functions.py | 195 | CODE | |
| LOW | build-support/run_clang_format.py | 50 | CODE | |
| LOW | build-support/check_be_module_boundaries.py | 194 | CODE | |
| LOW | build-support/check_be_module_boundaries.py | 389 | CODE | |
| LOW | build-support/sync_pom_to_gradle.py | 166 | CODE | |
| LOW | build-support/sync_pom_to_gradle.py | 299 | CODE | |
| 11 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⚡ | …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⚡ | 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 | 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 | 94 | # Check if the process is actually a profile collection daemon | 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 | 76 | # Check if the object is a user-defined type in our custom module | COMMENT |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1219 | # Check if we're comparing View/MaterializedView objects | COMMENT |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 1480 | # Check if conn_value starts with the default_value, ignoring case and spaces | COMMENT |
| LOW | gensrc/script/gen_functions.py | 244 | # Check if function has named arguments | COMMENT |
| LOW | build-support/extract_and_diff_params.py | 316 | # 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 | 33 | 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⚡ | …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 | …s-python-client/test/integration/test_reflection_mv.py | 33 | 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 | 137 | logger = logging.getLogger(__name__) | CODE |
| LOW | contrib/starrocks-python-client/starrocks/reflection.py | 55 | 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 | …/starrocks-python-client/starrocks/alembic/__init__.py | 21 | __all__ = [ | CODE |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 30 | logger = logging.getLogger(__name__) | CODE |
| LOW | …starrocks-python-client/starrocks/alembic/starrocks.py | 26 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ib/starrocks-python-client/starrocks/alembic/toimpl.py | 47 | logger = logging.getLogger(__name__) | CODE |
| LOW | …b/starrocks-python-client/starrocks/alembic/compare.py | 67 | 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 | 1333 | 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 | 686 | 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 | 1435 | 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 | 1883 | 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 | 1158 | 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 | 1873 | 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | be/test/exec/join_hash_map_test.cpp | 797 | //TODO: implement | COMMENT |
| LOW | be/src/formats/parquet/scalar_column_reader.cpp | 438 | //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 | 224 | // 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 | …onnector/partitiontraits/DeltaLakePartitionTraits.java | 40 | // TODO: implement | COMMENT |
| LOW | …cks/connector/partitiontraits/KuduPartitionTraits.java | 38 | // TODO: implement | COMMENT |
| LOW | …ain/java/com/starrocks/sql/optimizer/rule/RuleSet.java | 512 | // 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 | 656 | // 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 | 1271 | # 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 | 140 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 748 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 756 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 765 | CODE | |
| LOW | test/lib/sr_sql_lib.py | 907 | CODE | |
| LOW | contrib/starrocks-python-client/test/test_suite.py | 257 | CODE | |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 84 | CODE | |
| LOW | …ntrib/starrocks-python-client/starrocks/alembic/ops.py | 124 | 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 |