Repository Analysis

risingwavelabs/risingwave

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

4.6 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of risingwavelabs/risingwave, a Rust project with 9,164 GitHub stars. SynthScan v2.0 examined 1,115,535 lines of code across 4586 source files, recording 4391 pattern matches distributed across 21 syntactic categories. The overall adjusted score of 4.6 places this repository in the Likely human-written 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).

4.6
Adjusted Score
4.6
Raw Score
100%
Time Factor
2026-07-14
Last Push
9.2K
Stars
Rust
Language
1.1M
Lines of Code
4.6K
Files
4.4K
Pattern Hits
2026-07-14
Scan Date
0.01
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

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.

Severity Breakdown

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.

CRITICAL 2HIGH 21MEDIUM 237LOW 4131

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 4391 distinct pattern matches across 21 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.

Over-Commented Block3655 hits · 3648 pts
SeverityFileLineSnippetContext
LOWCargo.toml441madsim-tonic = { git = "https://github.com/risingwavelabs/madsim.git", rev = "595455fd05058b3b48bf281bea3ada1bca3d6646" COMMENT
LOWtomlfmt.toml1# Configuration file for `cargo-sort`.COMMENT
LOWrisedev.yml1# The schema for RiseDev configuration files is defined under `src/risedevtool/schemas`.COMMENT
LOWrisedev.yml21 # # Specify custom environment variablesCOMMENT
LOWrisedev.yml41COMMENT
LOW.config/hakari.toml1# This file contains settings for `cargo hakari`.COMMENT
LOWdocker/risingwave.toml1# RisingWave config file to be mounted into the Docker containers.COMMENT
LOWintegration_tests/iceberg-cdc/python/script/init.py61 # WITH (COMMENT
LOWintegration_tests/feature-store/run-local.sh41COMMENT
LOWintegration_tests/feature-store/server/src/server_pb.rs1#[allow(clippy::derive_partial_eq_without_eq)]COMMENT
LOWintegration_tests/feature-store/server/src/server_pb.rs81 #[prost(int64, tag = "1")]COMMENT
LOWintegration_tests/feature-store/server/src/model.rs1#[allow(clippy::derive_partial_eq_without_eq)]COMMENT
LOW…gration_tests/feature-store/simulator/src/server_pb.rs1#[allow(clippy::derive_partial_eq_without_eq)]COMMENT
LOW…gration_tests/feature-store/simulator/src/server_pb.rs81 #[prost(int64, tag = "1")]COMMENT
LOWintegration_tests/tidb-cdc-sink/config/pd.toml81COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml1# TiKV config templateCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml21# max-tasks-high = 8000COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml41[server]COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml61COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml81# labels = {}COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml101# the "scheduler too busy" error is displayed.COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml121# raftdb-path = ""COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml141# Interval to check region whether need to be split or not.COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml161# Interval to check whether start manual compaction for a region,COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml181COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml201# compaction job by breaking it into multiple, smaller ones that are run simultaneously.COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml221COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml241# then wal-size-limit, they will be deleted starting with theCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml261COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml281# rate-bytes-per-sec = 0COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml301# if it has been active longer than `log_file_time_to_roll`.COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml321# snappy: kSnappyCompressionCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml341# false means one sst file one bloom filter, true means every block has a corresponding bloom filterCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml361# min-write-buffer-number-to-merge = 1COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml381# block-cache-size = "1GB"COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml401# dynamic-level-bytes = trueCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml421# compaction-pri = 3COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml441# dynamic-level-bytes = trueCOMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml461# info-log-roll-time = "0"COMMENT
LOWintegration_tests/tidb-cdc-sink/config/tikv.toml481# compaction-pri = 0COMMENT
LOWintegration_tests/superset/docker/docker-bootstrap.sh1#!/usr/bin/env bashCOMMENT
LOWintegration_tests/superset/docker/run-server.sh1#!/usr/bin/env bashCOMMENT
LOWintegration_tests/superset/docker/docker-init.sh1#!/usr/bin/env bashCOMMENT
LOW…ests/superset/docker/pythonpath_dev/superset_config.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWci/scripts/flamegraph-env-build.sh21############# SETUP RWCOMMENT
LOWci/scripts/deterministic-recovery-test.sh21sqlx=error,\COMMENT
LOWci/scripts/run-backfill-tests.sh1#!/usr/bin/env bashCOMMENT
LOWci/scripts/remove-micro-bench-results.sh1#!/usr/bin/env bashCOMMENT
LOWci/scripts/gen-flamegraph.sh121KAFKA_HOST="localhost:9092"COMMENT
LOWci/scripts/e2e-source-mysql-cdc-reset.sh1#!/bin/bashCOMMENT
LOWgrafana/dashboard/dev/streaming_common.py1from ..common import Panels, metricCOMMENT
LOWgrafana/dashboard/dev/vector_search.py81 % (COMPONENT_LABEL, NODE_LABEL),COMMENT
LOW…a/io/debezium/connector/postgresql/PostgresSchema.java241COMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java441 // Remove any PKs that do not exist as part of this this relation message. This can occurCOMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java481 // scope.COMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java561 if (!resolvedTable.isPresent()) {COMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java641 */COMMENT
LOW…ctor/binlog/history/BinlogHistoryRecordComparator.java121 // https://dev.mysql.com/doc/refman/8.2/en/replication-gtids-failover.html,COMMENT
LOW…r/cdc/debezium/internal/NoDataRecoverySnapshotter.java1// Copyright 2025 RisingWave LabsCOMMENT
LOW…nector/cdc/debezium/internal/OpendalSchemaHistory.java1// Copyright 2025 RisingWave LabsCOMMENT
3595 more matches not shown…
Self-Referential Comments162 hits · 480 pts
SeverityFileLineSnippetContext
MEDIUMMakefile.toml617# This file is used to store extra profiles besides the ones defined in `risedev.yml`.COMMENT
MEDIUM.config/hakari.toml1# This file contains settings for `cargo hakari`.COMMENT
MEDIUM…ion_tests/feature-store/server/model/model_pb2_grpc.py84 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUM…gration_tests/client-library/python/test_sqlalchemy.py5# Create a base class for declarative class definitionsCOMMENT
MEDIUM…gration_tests/client-library/python/test_sqlalchemy.py10 # Define a simple User class as an exampleCOMMENT
MEDIUM…gration_tests/client-library/python/test_sqlalchemy.py22 # Create an SQLAlchemy engine to manage connections to the databaseCOMMENT
MEDIUMintegration_tests/client-library/python/client.py22 cursor = self.connection.cursor() # Create a cursor objectCODE
MEDIUMintegration_tests/superset/docker/docker-init.sh54# Create an admin userCOMMENT
MEDIUM…ests/superset/docker/pythonpath_dev/superset_config.py18# This file is included in the final Docker image and SHOULD be overridden whenCOMMENT
MEDIUMintegration_tests/mindsdb/prepare_data.sh12 # Create a new table and insert recordsCOMMENT
MEDIUMci/docker-compose.yml125 # Create the userCOMMENT
MEDIUMci/docker-compose.yml157 # Create the userCOMMENT
MEDIUMci/scripts/upload-coverage.sh12# Create a directory for coverage filesCOMMENT
MEDIUMe2e_test/source_inline/commands.toml1# This file contains commands used by the tests.COMMENT
MEDIUMe2e_test/source_inline/nats/operation.py12 # Create a NATS clientCOMMENT
MEDIUMe2e_test/source_inline/vault/vault_approle_setup.py40 # Create a policy for secret accessCOMMENT
MEDIUMe2e_test/source_inline/vault/vault_approle_setup.py129 # Create the secret using AppRole authenticationCOMMENT
MEDIUMe2e_test/over_window/gen.py21file_head = """# This file is generated by `gen.py`. Do not edit it manually!"""CODE
MEDIUMe2e_test/udf/tests/scalar/gen.py18file_head = """# This file is generated by `gen.py`. Do not edit it manually!"""CODE
MEDIUM.github/dependabot.yml28 # Create a group of dependencies to be updated together in one pull requestCOMMENT
MEDIUM…tend/planner_test/tests/testdata/output/asof_join.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ner_test/tests/testdata/output/predicate_pushdown.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…end/planner_test/tests/testdata/output/parameters.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ntend/planner_test/tests/testdata/output/gap_fill.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…end/planner_test/tests/testdata/output/pg_catalog.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…end/planner_test/tests/testdata/output/delta_join.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…/planner_test/tests/testdata/output/select_except.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ontend/planner_test/tests/testdata/output/project.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…nner_test/tests/testdata/output/generated_columns.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…planner_test/tests/testdata/output/column_pruning.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…end/planner_test/tests/testdata/output/bushy_join.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…lanner_test/tests/testdata/output/with_ordinality.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…tend/planner_test/tests/testdata/output/intersect.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…tend/planner_test/tests/testdata/output/pk_derive.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…d/planner_test/tests/testdata/output/shared_views.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…c/frontend/planner_test/tests/testdata/output/agg.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…est/tests/testdata/output/nexmark_temporal_filter.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…lanner_test/tests/testdata/output/stream_dist_agg.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…r_test/tests/testdata/output/over_window_function.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…d/planner_test/tests/testdata/output/shared_source.yml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…planner_test/tests/testdata/output/batch_dist_agg.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…/planner_test/tests/testdata/output/join_ordering.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…lanner_test/tests/testdata/output/watermark_group.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…d/planner_test/tests/testdata/output/named_window.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…rontend/planner_test/tests/testdata/output/delete.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…frontend/planner_test/tests/testdata/output/share.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ontend/planner_test/tests/testdata/output/dbeaver.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…st/tests/testdata/output/subquery_expr_correlated.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…lanner_test/tests/testdata/output/sink_into_table.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…planner_test/tests/testdata/output/batch_seq_scan.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…d/planner_test/tests/testdata/output/rw_timestamp.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…/planner_test/tests/testdata/output/sysinfo_funcs.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…/frontend/planner_test/tests/testdata/output/cast.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…/planner_test/tests/testdata/output/create_source.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…nd/planner_test/tests/testdata/output/append_only.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…er_test/tests/testdata/output/explain_json_format.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ontend/planner_test/tests/testdata/output/explain.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…er_test/tests/testdata/output/struct_field_access.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…ontend/planner_test/tests/testdata/output/nexmark.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
MEDIUM…test/tests/testdata/output/case_when_optimization.yaml1# This file is automatically generated. See `src/frontend/planner_test/README.md` for more information.COMMENT
102 more matches not shown…
Decorative Section Separators42 hits · 162 pts
SeverityFileLineSnippetContext
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs20//! ┌───┐ x┌──────┐COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs21//! │Any◄─────────────────┤single│COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs22//! └─▲─┘ x└──────┘COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs26//! ┌───┴────┐ x┌──────────┐COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs27//! │AnyShard◄──────────────┤SomeShard │COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs28//! └───▲────┘ x└──────────┘COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs30//! ┌───┴───────────┐ x┌──────────────┐ ┌──────────────┐COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs32//! └───▲──▲────────┘ │ x└──────────────┘ └┬─────────────┘COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs34//! │ │ └─────────────────────┘COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs36//! │ ┌┴────────────┐ x┌────────────┐COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs38//! │ └─────────────┘ x└────────────┘COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs40//! ┌┴────────────┐ x┌────────────┐COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs41//! │ShardByKey(b)◄──────┤HashShard(b)│COMMENT
MEDIUMsrc/frontend/src/optimizer/property/distribution.rs42//! └─────────────┘ x└────────────┘COMMENT
MEDIUMsrc/frontend/src/datafusion/aggregate/mod.rs133//! └──────────┬──────────────────┘COMMENT
MEDIUMsrc/frontend/src/datafusion/aggregate/mod.rs155//! └──────────┬──────────────────┘COMMENT
MEDIUMsrc/stream/src/executor/over_window/eowc.rs122/// ──────────────┬────────────────────────────────────────────────────── curr evict rowCOMMENT
MEDIUMsrc/stream/src/executor/over_window/eowc.rs128/// ────────┴──┬─────┼──┼──────────────────────────────────────────────── curr output rowCOMMENT
MEDIUMsrc/stream/src/executor/over_window/eowc.rs132/// ─────────────────┴─────────────────────────────────────────────────── curr input rowCOMMENT
MEDIUM…tion/tests/integration_tests/recovery/batch_refresh.rs199 // ── Recover while job is idle / between refresh cycles. ──────────────────COMMENT
MEDIUM…tion/tests/integration_tests/recovery/batch_refresh.rs202 // ── Second cycle: changes after recovery must still be picked up. ────────COMMENT
MEDIUM…tion/tests/integration_tests/recovery/batch_refresh.rs209 // ── Recover using meta + CN together, then run another cycle. ────────────COMMENT
MEDIUMsrc/meta/src/barrier/checkpoint/control.rs1388 // ── Batch refresh trigger helpers ────────────────────────────────────────COMMENT
MEDIUMsrc/meta/src/barrier/checkpoint/independent_job/mod.rs71// ── Enum unifying independent checkpoint job types ──────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs72// ── Public types ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs102// ── Batch refresh job metadata ───────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs122// ── Status ────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs183// ── Complete type ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs185// ── Main checkpoint control ───────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs205// ── Unified actor rendering ───────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs465// ── Construction ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs684// ── Barrier injection ─────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs731// ── Barrier forwarding and collection ─────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs922// ── Completing ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs1055// ── Query methods ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs1185// ── Logstore refresh run ──────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs1476// ── Drop handling ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…er/checkpoint/independent_job/batch_refresh_job/mod.rs1545// ── Barrier stats ─────────────────────────────────────────────────────────────COMMENT
MEDIUMsrc/compute/src/memory/controller.rs62/// ┌───────────────────┐ ┌───────────────────┐COMMENT
MEDIUMsrc/compute/src/memory/controller.rs64/// ┌───► (observe) ├───────►│ (control) ├───┐COMMENT
MEDIUMsrc/compute/src/memory/controller.rs66/// │ └───────────────────┘ └───────────────────┘ │COMMENT
MEDIUMsrc/compute/src/memory/controller.rs68/// └────────────────────────────────────────────────────────┘COMMENT
Structural Annotation Overuse87 hits · 159 pts
SeverityFileLineSnippetContext
LOW…ava/src/test/java/com/risingwave/TestSubscription.java16 // Step 1: Create a subscriptionCOMMENT
LOW…ava/src/test/java/com/risingwave/TestSubscription.java22 // Step 2: Declare a subscription cursorCOMMENT
LOW…ava/src/test/java/com/risingwave/TestSubscription.java28 // Step 3: Fetch data from the subscription cursorCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md33## Step 1: Identify Failing Buildkite ChecksCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md40## Step 2: Pull Build JSON and Failed JobsCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md52## Step 3: Extract the Concrete FailureCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md65## Step 4: Fall Back to ArtifactsCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md74## Step 5: Apply Focused FixesCOMMENT
LOW.agents/skills/fix-buildkite-ci/SKILL.md84## Step 6: Verify and ReportCOMMENT
LOW.agents/skills/risingwave-rust-analyzer/SKILL.md19## Step 1: Confirm the Analysis RootCOMMENT
LOW.agents/skills/risingwave-rust-analyzer/SKILL.md28## Step 2: Resolve the Crate and FeaturesCOMMENT
LOW.agents/skills/risingwave-rust-analyzer/SKILL.md53## Step 3: Use rust-analyzer CLICOMMENT
LOW.agents/skills/risingwave-rust-analyzer/SKILL.md68## Step 4: Configure LSP CarefullyCOMMENT
LOWdocs/dev/src/benchmark-and-profile/memory-profiling.md17## Step 1 - Collect Heap DumpCOMMENT
LOWdocs/dev/src/benchmark-and-profile/memory-profiling.md129## Step 2 - Analyze Heap DumpCOMMENT
LOWdocs/dev/src/benchmark-and-profile/memory-profiling.md201## Step 3 - Visualize Flame GraphCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py40 # Step 1: Produce some initial records to the topicCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py47 # Step 2: Sleep 1 secondCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py51 # Step 3: Record timestamp as millis as CURRENT_TIMESTAMPCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py55 # Step 4: Produce more dataCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py83 # Step 5: Create a table in RisingWave, starting load from CURRENT_TIMESTAMPCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py108 # Step 6: Select count(*) from the tableSTRING
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py125 # Step 7: Drop the tableSTRING
LOWe2e_test/source_inline/vault/vault_approle_setup.py182 # Step 1: Create/setup Vault AppRoleSTRING
LOWe2e_test/source_inline/vault/vault_approle_setup.py185 # Step 2: Create RisingWave secret using AppRole credentialsSTRING
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs154 // Step 1: Build pre-projection that constructs ROW expressionsCOMMENT
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs189 // Step 2: Build new aggregation calls operating on ROW columnsCOMMENT
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs246 // Step 3: Build post-projection to extract fields from ROW resultsCOMMENT
LOW…d/src/optimizer/rule/streaming_index_selection_rule.rs45 // Step 1: Try covering index selection.COMMENT
LOW…d/src/optimizer/rule/streaming_index_selection_rule.rs49 // Step 2: Try IN expansion on the (possibly index-backed) scan.COMMENT
LOWsrc/stream/src/executor/source/source_executor.rs829 // Step 1: Collect all current splits and clear their offsetsCOMMENT
LOWsrc/stream/src/executor/source/source_executor.rs904 // Step 2: Write splits back to state table with offset = NoneCOMMENT
LOWsrc/stream/src/executor/source/source_executor.rs910 // Step 3: Update in-memory split info with cleared offsetsCOMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs124 // Step 1: Check if this is a frontend-only error (SQL syntax, type errors, etc.)COMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs161 // Step 2: Check if connection is lost (possible panic)COMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs165 // Step 3: Check logs for panic in compute/meta/compactorCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs63 // Step 1: Enable locality backfill and configure for slow background DDLCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs68 // Step 2: Create table and populate with 10,000 rowsCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs73 // Step 3: Verify row countCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs77 // Step 4: Create materialized view with background DDLCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs80 // Step 5: Find the internal table names for locality providerCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs107 // Step 7: Trigger recoveryCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs110 // Step 8: Check internal tables after recoveryCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs123 // Step 9: Remove rate limit and wait for completionCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs127 // Step 10: Verify MV resultCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs94 // Step 6: Check internal tables before recoveryCOMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs93 // Step 5: Alter rate limit to default (unlimited).COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs99 // Step 6: Wait for the batch refresh to complete.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs104 // Step 7: Verify the MV row count matches the source table.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs128 // Step 9: Trigger another recovery while the batch refresh job is idle.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs133 // Step 10: Verify that the MV is still queryable after idle recovery.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs37 // Step 1: Create table and insert 10,000 rows.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs48 // Step 2: Create a batch refresh MV with background DDL and backfill rate limit = 1.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs67 // Step 3: Wait a bit for backfill to make some progress, then check DDL progress.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs79 // Step 4: Trigger recovery and verify progress survives.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs116 // Step 8: Now the batch refresh job is idle (snapshot done, waiting for next refresh).COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs145 // Step 11: DROP the MV.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs61 // Step 1: Create a table and insert data.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs72 // Step 2: Kill all nodes.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs77 // Step 3: Restart meta first.COMMENT
27 more matches not shown…
Unused Imports143 hits · 136 pts
SeverityFileLineSnippetContext
LOWintegration_tests/deltalake-sink/sink_check.py2CODE
LOWintegration_tests/upsert-avro/datagen.py3CODE
LOWintegration_tests/upsert-avro/datagen.py7CODE
LOWintegration_tests/iceberg-source/python/main.py1CODE
LOWintegration_tests/feature-store/server/udf.py2CODE
LOWintegration_tests/feature-store/server/udf.py2CODE
LOWintegration_tests/feature-store/server/udf.py2CODE
LOWintegration_tests/feature-store/server/udf.py2CODE
LOWintegration_tests/feature-store/server/udf.py2CODE
LOWintegration_tests/feature-store/server/udf.py3CODE
LOWintegration_tests/feature-store/server/model/model.py1CODE
LOWintegration_tests/feature-store/server/model/model.py2CODE
LOWintegration_tests/feature-store/server/model/model.py4CODE
LOWintegration_tests/feature-store/server/model/model.py5CODE
LOWintegration_tests/feature-store/server/model/model.py7CODE
LOWintegration_tests/feature-store/server/model/model.py12CODE
LOW…ion_tests/feature-store/server/model/model_pb2_grpc.py4CODE
LOW…tegration_tests/feature-store/server/model/__main__.py1CODE
LOWintegration_tests/feature-store/generator/preference.py1CODE
LOWintegration_tests/feature-store/generator/user.py1CODE
LOWintegration_tests/feature-store/generator/user.py2CODE
LOWintegration_tests/feature-store/generator/__main__.py7CODE
LOWintegration_tests/scripts/gen_pb_compose.py3CODE
LOW…tegration_tests/scripts/compatibility/compatibility.py3CODE
LOWintegration_tests/scripts/compatibility/cli.py2CODE
LOW…ests/superset/docker/pythonpath_dev/superset_config.py25CODE
LOW…ests/superset/docker/pythonpath_dev/superset_config.py118CODE
LOWintegration_tests/iceberg-sink2/python/main.py1CODE
LOWgrafana/risingwave-user-dashboard.dashboard.py5CODE
LOWgrafana/risingwave-user-dashboard.dashboard.py5CODE
LOWgrafana/risingwave-user-dashboard.dashboard.py5CODE
LOWgrafana/risingwave-user-dashboard.dashboard.py5CODE
LOWgrafana/risingwave-user-dashboard.dashboard.py20CODE
LOWgrafana/risingwave-dev-dashboard.dashboard.py10CODE
LOWgrafana/dashboard/common.py4CODE
LOWgrafana/dashboard/user/memory.py1CODE
LOWgrafana/dashboard/user/batch.py1CODE
LOWgrafana/dashboard/user/cpu.py1CODE
LOWgrafana/dashboard/user/__init__.py2CODE
LOWgrafana/dashboard/user/__init__.py14CODE
LOWgrafana/dashboard/user/__init__.py15CODE
LOWgrafana/dashboard/user/__init__.py16CODE
LOWgrafana/dashboard/user/__init__.py17CODE
LOWgrafana/dashboard/user/__init__.py18CODE
LOWgrafana/dashboard/user/__init__.py19CODE
LOWgrafana/dashboard/user/__init__.py20CODE
LOWgrafana/dashboard/user/__init__.py21CODE
LOWgrafana/dashboard/user/overview.py1CODE
LOWgrafana/dashboard/user/storage.py1CODE
LOWgrafana/dashboard/user/actor_info.py1CODE
LOWgrafana/dashboard/user/network.py1CODE
LOWgrafana/dashboard/user/streaming.py1CODE
LOWgrafana/dashboard/dev/object_storage.py1CODE
LOWgrafana/dashboard/dev/iceberg_compaction_metrics.py1CODE
LOWgrafana/dashboard/dev/memory_manager.py1CODE
LOWgrafana/dashboard/dev/hummock_write.py1CODE
LOWgrafana/dashboard/dev/iceberg_metrics.py1CODE
LOWgrafana/dashboard/dev/network_connection.py1CODE
LOWgrafana/dashboard/dev/sink_metrics.py1CODE
LOWgrafana/dashboard/dev/cluster_alerts.py1CODE
83 more matches not shown…
Verbosity Indicators69 hits · 126 pts
SeverityFileLineSnippetContext
LOW…ava/src/test/java/com/risingwave/TestSubscription.java16 // Step 1: Create a subscriptionCOMMENT
LOW…ava/src/test/java/com/risingwave/TestSubscription.java22 // Step 2: Declare a subscription cursorCOMMENT
LOW…ava/src/test/java/com/risingwave/TestSubscription.java28 // Step 3: Fetch data from the subscription cursorCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py40 # Step 1: Produce some initial records to the topicCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py47 # Step 2: Sleep 1 secondCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py51 # Step 3: Record timestamp as millis as CURRENT_TIMESTAMPCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py55 # Step 4: Produce more dataCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py83 # Step 5: Create a table in RisingWave, starting load from CURRENT_TIMESTAMPCOMMENT
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py108 # Step 6: Select count(*) from the tableSTRING
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py125 # Step 7: Drop the tableSTRING
LOWe2e_test/source_inline/vault/vault_approle_setup.py182 # Step 1: Create/setup Vault AppRoleSTRING
LOWe2e_test/source_inline/vault/vault_approle_setup.py185 # Step 2: Create RisingWave secret using AppRole credentialsSTRING
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs154 // Step 1: Build pre-projection that constructs ROW expressionsCOMMENT
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs189 // Step 2: Build new aggregation calls operating on ROW columnsCOMMENT
LOW…tend/src/optimizer/rule/unify_first_last_value_rule.rs246 // Step 3: Build post-projection to extract fields from ROW resultsCOMMENT
LOW…d/src/optimizer/rule/streaming_index_selection_rule.rs45 // Step 1: Try covering index selection.COMMENT
LOW…d/src/optimizer/rule/streaming_index_selection_rule.rs49 // Step 2: Try IN expansion on the (possibly index-backed) scan.COMMENT
LOWsrc/stream/src/executor/hash_join.rs1078 /// For the probe-side row, we need to check if it has values in cache, if not, we need toCOMMENT
LOWsrc/stream/src/executor/source/source_executor.rs829 // Step 1: Collect all current splits and clear their offsetsCOMMENT
LOWsrc/stream/src/executor/source/source_executor.rs904 // Step 2: Write splits back to state table with offset = NoneCOMMENT
LOWsrc/stream/src/executor/source/source_executor.rs910 // Step 3: Update in-memory split info with cleared offsetsCOMMENT
LOWsrc/stream/src/executor/mview/cache.rs479 // For bytea type, we need to check if it contains the string bytes of DEBEZIUM_UNAVAILABLE_VALUECOMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs124 // Step 1: Check if this is a frontend-only error (SQL syntax, type errors, etc.)COMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs161 // Step 2: Check if connection is lost (possible panic)COMMENT
LOWsrc/tests/sqlsmith/src/sqlreduce/checker.rs165 // Step 3: Check logs for panic in compute/meta/compactorCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs63 // Step 1: Enable locality backfill and configure for slow background DDLCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs68 // Step 2: Create table and populate with 10,000 rowsCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs73 // Step 3: Verify row countCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs77 // Step 4: Create materialized view with background DDLCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs80 // Step 5: Find the internal table names for locality providerCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs107 // Step 7: Trigger recoveryCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs110 // Step 8: Check internal tables after recoveryCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs123 // Step 9: Remove rate limit and wait for completionCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs127 // Step 10: Verify MV resultCOMMENT
LOW…/tests/integration_tests/recovery/locality_backfill.rs94 // Step 6: Check internal tables before recoveryCOMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs93 // Step 5: Alter rate limit to default (unlimited).COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs99 // Step 6: Wait for the batch refresh to complete.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs104 // Step 7: Verify the MV row count matches the source table.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs128 // Step 9: Trigger another recovery while the batch refresh job is idle.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs133 // Step 10: Verify that the MV is still queryable after idle recovery.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs37 // Step 1: Create table and insert 10,000 rows.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs48 // Step 2: Create a batch refresh MV with background DDL and backfill rate limit = 1.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs67 // Step 3: Wait a bit for backfill to make some progress, then check DDL progress.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs79 // Step 4: Trigger recovery and verify progress survives.COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs116 // Step 8: Now the batch refresh job is idle (snapshot done, waiting for next refresh).COMMENT
LOW…tion/tests/integration_tests/recovery/batch_refresh.rs145 // Step 11: DROP the MV.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs61 // Step 1: Create a table and insert data.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs72 // Step 2: Kill all nodes.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs77 // Step 3: Restart meta first.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs83 // Step 4: Restart ONLY the serving CN (compute-2).COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs91 // Step 5: Restart frontend.COMMENT
LOW…on/tests/integration_tests/recovery/serving_mapping.rs95 // Step 6: Query the table.COMMENT
LOWsrc/meta/service/src/stream_service.rs976 // Step 1: Pause the stream (already commits state)COMMENT
LOWsrc/meta/service/src/stream_service.rs982 // Step 2: Update catalog and get the new propertiesCOMMENT
LOWsrc/meta/service/src/stream_service.rs1010 // Step 3: Issue ConnectorPropsChange barrierCOMMENT
LOWsrc/meta/service/src/stream_service.rs1021 // Step 4: Optional split resetCOMMENT
LOWsrc/meta/service/src/stream_service.rs1034 // Step 5: Resume the stream (even if previous steps failed)COMMENT
LOWsrc/meta/src/stream/source_manager/split_assignment.rs549 // we need to check if discovered_split_ids is empty, because if it is empty, we need toCOMMENT
LOWsrc/meta/src/barrier/checkpoint/state.rs274 // Step 2: Render actors for each ensemble.COMMENT
LOWsrc/meta/src/barrier/checkpoint/state.rs353 // Step 3: Expand simple assignments into full StreamActor structures.COMMENT
9 more matches not shown…
Cross-Language Confusion16 hits · 108 pts
SeverityFileLineSnippetContext
HIGHdevelop/sql_bench/main.py199 subprocess.run("risedev k && risedev clean-data", shell=True, check=False)STRING
HIGHintegration_tests/upsert-avro/datagen.py15{"type":"record","name":"OBJ_ATTRIBUTE_VALUE","namespace":"CPLM","fields":[{"name":"op_type","type":["null","string"],"dCODE
HIGHintegration_tests/client-library/client_test.py12 subprocess.run(["docker", "compose", "exec", "python", "bash", "-c", "cd /python-client && pip3 install -r requiremeCODE
HIGHintegration_tests/client-library/client_test.py17 subprocess.run(["docker", "compose", "exec", "java", "bash", "-c", "apt-get update && apt-get install -y maven"],CODE
HIGHintegration_tests/client-library/client_test.py19 subprocess.run(["docker", "compose", "exec", "java", "bash", "-c", "cd /java-client && mvn clean test"],CODE
HIGHintegration_tests/client-library/client_test.py25 ["docker", "compose", "exec", "nodejs", "bash", "-c", "cd /nodejs-client && npm install && npm test"],CODE
HIGHintegration_tests/client-library/client_test.py31 ["docker", "compose", "exec", "php", "bash", "-c", "cd /php-client && phpunit tests/RWClientTest.php"],CODE
HIGHintegration_tests/client-library/client_test.py36 subprocess.run(["docker", "compose", "exec", "ruby", "bash", "-c", "cd /ruby-client && ruby test/crud_test.rb"],CODE
HIGHintegration_tests/client-library/client_test.py41 subprocess.run(["docker", "compose", "exec", "spring-boot", "bash", "-c", "cd /spring-boot-client && mvn spring-bootCODE
HIGHgrafana/dashboard/dev/cluster_errors.py47 # We add a small constant 0.05 to make sure that the counter jumps from null to not-null,COMMENT
HIGHe2e_test/python_client/main.py49 cur.execute("select ARRAY[true, false, null]::boolean[]", binary=True)CODE
HIGHe2e_test/python_client/main.py76 cur.execute("select ARRAY['foo', 'bar', null]::varchar[]", binary=True)CODE
HIGHe2e_test/python_client/main.py101 cur.execute("select array[ROW('123 Main St'::varchar, 'New York'::varchar, 10001), ROW('234 Main St'::vaCODE
HIGHe2e_test/python_client/main.py118 cur.execute("select '{\"name\": \"John\", \"age\": 30, \"city\": null}'::jsonb", binary=True)CODE
HIGHe2e_test/python_client/main.py121 cur.execute("select '{\"scores\": [85.5, 90, null], \"passed\": true}'::jsonb", binary=True)CODE
HIGHe2e_test/python_client/main.py124 cur.execute("select '[{\"id\": 1, \"value\": null}, {\"id\": 2, \"value\": \"test\"}]'::jsonb", binary=TCODE
Hyper-Verbose Identifiers65 hits · 67 pts
SeverityFileLineSnippetContext
LOWintegration_tests/upsert-avro/datagen.py41def get_key_value_and_serializer(id, schema_registry_client):STRING
LOWintegration_tests/iceberg-source/python/main.py87def check_risingwave_iceberg_source(docker):STRING
LOWci/scripts/notify.py129def generate_test_status_message(failed_test_map):CODE
LOWci/scripts/notify.py137def get_buildkite_test_status(test):CODE
LOWci/scripts/find-regression.py201 def test_get_number_of_commits(self):STRING
LOWgrafana/dashboard/common.py102 def next_one_third_width_graph(self):CODE
LOWgrafana/dashboard/common.py249 def timeseries_actor_latency_small(CODE
LOWgrafana/dashboard/common.py384 def timeseries_actor_ops_small(CODE
LOWgrafana/dashboard/dev/streaming_common.py12def _actor_busy_time_relative_target(panels: Panels):CODE
LOWgrafana/dashboard/dev/streaming_common.py123def relabel_materialized_view_id_as_id(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_common.py127def relabel_fragment_id_as_id(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_relations.py10def _relation_busy_rate_expr_by_mv(rate_interval: str):CODE
LOWgrafana/dashboard/dev/streaming_relations.py32def _relation_metric_with_metadata(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_relations.py36def _relation_busy_peak_topk_expr(rate_interval: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_relations.py44def _relation_cpu_peak_topk_expr(CODE
LOWgrafana/dashboard/dev/streaming_relations.py66def _relation_busy_rate_target(panels: Panels, rate_interval: str):CODE
LOWgrafana/dashboard/dev/streaming_relations.py73def _sum_fragment_metric_by_mv(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py9def _fragment_topk_percent_expr(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py13def _fragment_peak_rate_with_id_at_step(expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py20def _fragment_peak_rate_per_actor_with_id_at_step(per_actor_expr: str) -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py28def _kv_log_store_buffer_usage_by_fragment_expr() -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py35def _sync_kv_log_store_buffer_usage_by_fragment_expr() -> str:CODE
LOWgrafana/dashboard/dev/streaming_fragments.py38def _channel_buffer_usage_by_fragment_expr() -> str:CODE
LOW…/risingwave/connector/source/SourceRequestHandler.java25public class SourceRequestHandler {CODE
LOWjava/connector-node/python-client/pyspark-util.py104def test_upsert_iceberg_table(input_file):CODE
LOWjava/connector-node/python-client/pyspark-util.py152def delete_deltalake_table_data():CODE
LOWjava/connector-node/python-client/integration_tests.py42def make_mock_schema_stream_chunk():CODE
LOWjava/connector-node/python-client/integration_tests.py106def load_stream_chunk_payload(input_file):CODE
LOWjava/connector-node/python-client/integration_tests.py263def test_stream_chunk_data_format(param):CODE
LOWdashboard/lib/utils/timeUtils.ts48export function parseTimestampToUnixEpoch(CODE
LOWdashboard/lib/utils/timeUtils.ts70export function getCurrentTimeInSystemTimezone(): string {CODE
LOWdashboard/lib/api/cluster.ts32export async function getClusterInfoComputeNode() {CODE
LOWdashboard/lib/api/cluster.ts46export async function getClusterInfoProfileWorkers() {CODE
LOWdashboard/lib/api/streamingStats.ts48export function createStreamingStatsRefresh(CODE
LOWdashboard/pages/fragment_graph.tsx153function buildFragmentDependencyAsEdges(CODE
LOWdashboard/pages/cluster.tsx70function WorkerNodeMetricsComponent({CODE
LOWe2e_test/check_slt_coverage.py88def extract_slt_patterns_from_script(script_path):CODE
LOWe2e_test/check_slt_coverage.py231def analyze_uncovered_directories(all_files, covered_files):CODE
LOWe2e_test/check_slt_coverage.py271def propagate_coverage_through_includes(CODE
LOWe2e_test/webhook/sender.py179def send_multi_column_validate(secret):CODE
LOWe2e_test/webhook/sender.py211def send_multi_column_with_options():CODE
LOWe2e_test/webhook/sender.py229def send_multi_column_batched():CODE
LOWe2e_test/webhook/sender.py242def send_multi_column_timestamp_option():CODE
LOWe2e_test/webhook/sender.py257def send_multi_column_time_option():CODE
LOWe2e_test/webhook/sender.py272def send_multi_column_bigint_precise_option():CODE
LOWe2e_test/webhook/websocket_sender.py480def scenario_multi_column_no_pk(ws: SimpleWebSocketApp, state: WsState) -> None:CODE
LOWe2e_test/webhook/websocket_sender.py513def scenario_single_jsonb_no_pk(ws: SimpleWebSocketApp, state: WsState) -> None:CODE
LOWe2e_test/webhook/websocket_sender.py577def scenario_error_missing_pk(ws: SimpleWebSocketApp, state: WsState) -> None:CODE
LOWe2e_test/webhook/websocket_sender.py586def scenario_error_incomplete_composite_pk_insert(CODE
LOWe2e_test/webhook/websocket_sender.py606def scenario_error_incomplete_composite_pk_delete(CODE
LOWe2e_test/webhook/websocket_sender.py678def scenario_invalid_decoder_header(CODE
LOWe2e_test/s3/file_source.py19def _test_parquet_struct_field_subset(minio_client: Minio):CODE
LOWe2e_test/s3/file_source.py123def _test_parquet_struct_missing_field_in_file(minio_client: Minio):STRING
LOWe2e_test/s3/file_source.py228def _test_parquet_case_insensitive(minio_client: Minio):STRING
LOWe2e_test/source_inline/nats/operation.py68def validate_state_table_item(table_name: str, expect_count: int):CODE
LOWe2e_test/subscription/main.py17def create_table_subscription():CODE
LOWe2e_test/subscription/main.py66def test_cursor_snapshot_log_store():CODE
LOWe2e_test/subscription/main.py147def test_cursor_without_since():CODE
LOWe2e_test/subscription/main.py172def test_cursor_since_rw_timestamp():CODE
LOWe2e_test/subscription/main.py261def test_cursor_with_table_alter():CODE
5 more matches not shown…
Excessive Try-Catch Wrapping41 hits · 54 pts
SeverityFileLineSnippetContext
MEDIUMdevelop/sql_bench/main.py131 print(f"Error: Benchmark '{bench_name}' already exists")STRING
MEDIUMdevelop/sql_bench/main.py143 print(f"Error: Benchmark configuration '{bench_name}' not found at {yaml_file}")STRING
MEDIUMdevelop/sql_bench/main.py186 print(f"Error: Benchmark '{bench_name}' failed")STRING
LOWintegration_tests/iceberg-cdc/python/script/check.py24 except Exception:CODE
LOWintegration_tests/feature-store/server/model/model.py42 except Exception as e:CODE
LOWintegration_tests/feature-store/server/model/model.py64 except Exception as e:CODE
LOWintegration_tests/client-library/client_test.py67 except Exception as e:CODE
LOWintegration_tests/scripts/run_demos.py39 except Exception:CODE
LOWintegration_tests/scripts/run_demos.py58 except Exception:CODE
LOW…erg-sink/iceberg-compaction-sql/rewrite_small_files.py13 except Exception as exc:CODE
LOWjava/connector-node/python-client/integration_tests.py171 except Exception as e:CODE
LOWjava/connector-node/python-client/integration_tests.py200 except Exception as e:CODE
LOWe2e_test/check_slt_coverage.py211 except Exception as e:CODE
MEDIUMe2e_test/check_slt_coverage.py213 print(f"Error reading {slt_file}, skipping: {e}")CODE
LOWe2e_test/webhook/websocket_sender.py90 except Exception as err: # noqa: BLE001CODE
LOWe2e_test/source_inline/nats/operation.py37 except Exception as e:CODE
MEDIUMe2e_test/source_inline/nats/operation.py38 print(f"Error: {e}")CODE
MEDIUMe2e_test/source_inline/nats/operation.py122 print("Error: Both stream name and subject are required")CODE
MEDIUMe2e_test/source_inline/nats/operation.py133 print("Error: Both table name and expected count are required")CODE
MEDIUMe2e_test/source_inline/nats/operation.py140 print("Error: Both stream name and consumer name are required")CODE
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py35 except Exception as e:CODE
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py76 except Exception as e:CODE
LOWe2e_test/source_inline/kafka/kafka_startup_millis.py130 except Exception as e:STRING
MEDIUMe2e_test/source_inline/mqtt/rabbitmq_operation.py64 print(f"Error: Cannot resolve hostname '{RABBITMQ_HOST}': {e}", file=sys.stderr)CODE
LOWe2e_test/source_inline/mqtt/rabbitmq_operation.py96 except Exception as e:CODE
MEDIUMe2e_test/source_inline/mqtt/rabbitmq_operation.py97 print(f"Error: {e}", file=sys.stderr)CODE
MEDIUMe2e_test/source_inline/mqtt/rabbitmq_operation.py111 print(f"Error: Unknown command '{command}'. Only 'produce' is supported.", file=sys.stderr)CODE
LOWe2e_test/source_inline/vault/vault_approle_setup.py118 except Exception as e:CODE
LOWe2e_test/source_inline/vault/vault_approle_setup.py158 except Exception as e:STRING
LOWe2e_test/iceberg/main.py67 except Exception as e:CODE
LOWe2e_test/iceberg/test_utils/spark_utils.py55 except Exception as e:CODE
LOWe2e_test/commands/pulsar_util.py256 except Exception as e:CODE
MEDIUMe2e_test/commands/pulsar_util.py271 print(f"Error receiving message: {e}")CODE
LOWe2e_test/commands/pulsar_util.py351 except Exception as e:CODE
MEDIUMe2e_test/commands/pulsar_util.py352 print(f"Error checking compaction status: {e}")CODE
LOWe2e_test/commands/pulsar_util.py393 except Exception as e:CODE
MEDIUMe2e_test/commands/pulsar_util.py394 print(f"Error checking unacked messages: {e}")CODE
LOWe2e_test/commands/psql_validate.py175 except Exception as e:CODE
LOWsrc/stream/benches/stream_hash_join.py58 except Exception as e:CODE
MEDIUMsrc/stream/benches/stream_hash_join.py69 print(f"Error running benchmark for Amp={amp}, Workload={workload}, JoinType={join_type}", file=sys.stdeCODE
MEDIUMsrc/stream/benches/stream_hash_join.py70 print(f"Error output: {e.output}", file=sys.stderr)CODE
AI Slop Vocabulary19 hits · 52 pts
SeverityFileLineSnippetContext
LOWci/scripts/backwards-compat-test.sh187 # Assume we use the latest version, so we just set to some large number.COMMENT
MEDIUM…ngwave/connector/source/core/JniDbzSourceRegistry.java47 // TODO: use a more robust way to handle this, e.g., may include the current termCOMMENT
MEDIUMdashboard/package-lock.json9391 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.1.tgz",CODE
MEDIUMdashboard/package-lock.json17432 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.1.tgz",CODE
LOWe2e_test/iceberg/main.py64 # Don't raise the exception, just return the failed resultCOMMENT
MEDIUMe2e_test/commands/pulsar_util.py257 # More robust timeout detectionCOMMENT
MEDIUMsrc/frontend/src/handler/alter_mv.rs182 // TODO(alter-mv): improve this to make it more robust and friendly.COMMENT
MEDIUMsrc/frontend/src/handler/variable.rs77 // In future we can add converter/parser to make the API more robust.COMMENT
MEDIUMsrc/frontend/src/optimizer/plan_node/logical_agg.rs1545 // If we call `try_better_locality` on input, it would miss the chance to utilize the locality of the current agCOMMENT
MEDIUMsrc/frontend/src/datafusion/scalar_function/mod.rs36//! [`ScalarUDFImpl`] to wrap RisingWave's expression evaluation logic. This allows seamlessCOMMENT
MEDIUMsrc/frontend/src/expr/type_inference/cast.rs59 // Essentially a filter_map followed by a try_reduce, which is unstable.COMMENT
MEDIUMsrc/stream/src/executor/over_window/general.rs385 // can leverage the block cache under the hood.COMMENT
MEDIUMsrc/meta/src/rpc/ddl_controller.rs2134 // but more robust.COMMENT
MEDIUMsrc/expr/impl/src/window_function/aggregate.rs87 // TODO(rc): utilize `retract` method of embedded UDAF to do incremental aggregationCOMMENT
MEDIUMsrc/common/proc_macro/src/config.rs32// TODO(bugen): the implementation is not robust but it works for now.COMMENT
MEDIUMsrc/connector/src/source/cdc/external/sql_server.rs413 // sql server cannot leverage the given key to narrow down the range of scan,COMMENT
MEDIUMsrc/connector/src/source/cdc/external/mysql.rs744 // mysql cannot leverage the given key to narrow down the range of scan,COMMENT
MEDIUMsrc/connector/src/source/iceberg/planner.rs616 /// It's deterministic so that it can best utilize the data locality.COMMENT
MEDIUMsrc/connector/src/source/iceberg/mod.rs424 /// It's deterministic so that it can best utilize the data locality.COMMENT
Fake / Example Data31 hits · 34 pts
SeverityFileLineSnippetContext
LOW…egration_tests/client-library/nodejs/test/crud_test.js6 let name = "John Doe"CODE
LOWintegration_tests/client-library/go/pgx_test/mv_test.go22 name := "John Doe"CODE
LOWintegration_tests/client-library/go/pgx_test/mv_test.go99 case "John Doe":CODE
LOW…egration_tests/client-library/go/pgx_test/crud_test.go122 name := "John Doe"CODE
LOW…egration_tests/client-library/go/pgx_test/crud_test.go158 updateData(conn, "John Doe", 60000)CODE
LOW…egration_tests/client-library/go/pgx_test/crud_test.go159 deleteData(conn, "John Doe")CODE
LOW…tegration_tests/client-library/python/test_database.py66 crud_instance.insert_data("John Doe", 25, 10000)CODE
LOW…tegration_tests/client-library/python/test_database.py79 crud_instance.update_data("John Doe", 12000)CODE
LOW…tegration_tests/client-library/python/test_database.py83 cursor.execute("SELECT salary FROM sample_table_py WHERE name='John Doe';")CODE
LOW…tegration_tests/client-library/python/test_database.py91 crud_instance.delete_data("John Doe")CODE
LOW…tegration_tests/client-library/python/test_database.py96 "SELECT EXISTS (SELECT 1 FROM sample_table_py WHERE name = 'John Doe');")CODE
LOW…gration_tests/client-library/python/test_sqlalchemy.py47 new_user = User(id=1, name='John Doe', age=30)STRING
LOW…gration_tests/client-library/python/test_sqlalchemy.py57 user_to_delete = db_session.query(User).filter_by(name='John Doe').first()STRING
LOW…ration_tests/client-library/php/tests/RWClientTest.php10 $name = 'John Doe';CODE
LOWintegration_tests/client-library/csharp/NpgsqlTest.cs31 insertCmd.Parameters.AddWithValue("name", "John Doe");CODE
LOWintegration_tests/client-library/ruby/test/crud_test.rb15 name = 'John Doe'CODE
LOWci/scripts/e2e-source-mysql-cdc-reset.sh121mysql -e "USE binlog_test; INSERT INTO test_table (id, value) VALUES (50, 'dummy_data');"CODE
LOWe2e_test/webhook/sender.py10 "source": "placeholder",CODE
LOWe2e_test/webhook/sender.py11 "auth_algo": "placeholder",CODE
LOWe2e_test/python_client/main.py98 cur.execute("select ROW('123 Main St'::varchar, 'New York'::varchar, 10001)", binary=True)CODE
LOWe2e_test/python_client/main.py99 self.assertEqual(cur.fetchone(), (('123 Main St', 'New York', 10001),))CODE
LOWe2e_test/python_client/main.py101 cur.execute("select array[ROW('123 Main St'::varchar, 'New York'::varchar, 10001), ROW('234 Main St'::vaCODE
LOWe2e_test/python_client/main.py102 self.assertEqual(cur.fetchone(), ([('123 Main St', 'New York', 10001), ('234 Main St', None, 10002)],))CODE
LOWsrc/stream/src/executor/stream_reader.rs104 futures::stream::once(async { unreachable!("placeholder") }).boxed(),CODE
LOWsrc/tests/regress/data/sql/tsearch.sql472'Lorem ipsum urna. Nullam nullam ullamcorper urna.',CODE
LOWsrc/tests/regress/data/sql/tsearch.sql548'Lorem ipsum urna. Nullam nullam ullamcorper urna.',CODE
LOWsrc/connector/codec/tests/integration_tests/protobuf.rs492 "value": "John Doe",CODE
LOWsrc/connector/src/sink/encoder/avro.rs1021 "name": "John Doe",CODE
LOWsrc/connector/src/sink/encoder/template.rs649 Some(ScalarImpl::Utf8("John Doe".into())),CODE
LOWsrc/connector/src/sink/encoder/template.rs701 Some(ScalarImpl::Utf8("John Doe".into())),CODE
LOWsrc/connector/src/parser/debezium/mongo_json_parser.rs629 ScalarImpl::Utf8("John Doe".into()),CODE
Redundant / Tautological Comments15 hits · 22 pts
SeverityFileLineSnippetContext
LOWMakefile.toml313# Check if there is any panic in log.COMMENT
LOWMakefile.toml322# Check if there are too many duplicated lines in log.COMMENT
LOWMakefile.toml345# Check if the total log size is too large.COMMENT
LOWintegration_tests/mindsdb/prepare_data.sh7# Check if the table exists in the databaseCOMMENT
LOWci/scripts/setup-vault.sh25# Check if kv-v2 secrets engine is already enabledCOMMENT
LOWe2e_test/check_slt_coverage.py137 # Check if there's a grep exclusion in this commandCOMMENT
LOWe2e_test/check_slt_coverage.py325 # Check if any file including this .slt.part is coveredCOMMENT
LOWe2e_test/check_slt_coverage.py336 # Check if we've added any new filesCOMMENT
LOWe2e_test/source_inline/kafka/alter/get_kafka_offsets.py33 # Set offset to skip last N messagesCOMMENT
LOWe2e_test/source_inline/mqtt/rabbitmq_operation.py60 # Check if host is reachableCOMMENT
LOWe2e_test/source_inline/vault/vault_approle_setup.py20 # Check if AppRole auth method is enabledCOMMENT
LOWe2e_test/commands/pulsar_util.py244 # Print message infoCOMMENT
LOWe2e_test/commands/psql_validate.py190 # Check if the number of lines matchesCOMMENT
LOWscripts/install/install-risingwave.sh103# Check if $JAVA_HOME is set, if not, prompt user to install Java, and set $JAVA_HOME.COMMENT
LOWsrc/tests/sqlsmith/scripts/gen_queries.sh246# Check if any query generation step failed, and any query file not generated.COMMENT
Deep Nesting22 hits · 22 pts
SeverityFileLineSnippetContext
LOWintegration_tests/scripts/run_demos.py25CODE
LOWintegration_tests/scripts/compatibility/cli.py35CODE
LOWintegration_tests/scripts/compatibility/cli.py58CODE
LOWci/scripts/notify.py113CODE
LOWci/scripts/find-regression.py142CODE
LOWjava/connector-node/python-client/integration_tests.py119CODE
LOWe2e_test/check_slt_coverage.py42CODE
LOWe2e_test/check_slt_coverage.py88CODE
LOWe2e_test/check_slt_coverage.py171CODE
LOWe2e_test/check_slt_coverage.py271CODE
LOWe2e_test/check_slt_coverage.py365CODE
LOWe2e_test/webhook/websocket_sender.py701CODE
LOWe2e_test/webhook/websocket_sender.py42CODE
LOW…e_inline/cdc/mysql/cron_only/wait_mysql_cdc_metrics.py18CODE
LOWe2e_test/iceberg/test_utils/test_utils.py67CODE
LOWe2e_test/iceberg/test_utils/test_utils.py112CODE
LOWe2e_test/iceberg/test_utils/log.py27CODE
LOWe2e_test/commands/pulsar_util.py411CODE
LOWe2e_test/commands/pulsar_util.py95CODE
LOWe2e_test/commands/pulsar_util.py152CODE
LOWe2e_test/commands/pulsar_util.py200CODE
LOWe2e_test/commands/pulsar_util.py302CODE
Hallucination Indicators2 hits · 20 pts
SeverityFileLineSnippetContext
CRITICAL…a/com/risingwave/connector/source/MySQLSourceTest.java71 com.risingwave.java.binding.Binding.initObjectStoreForTest(CODE
CRITICALsrc/storage/hummock_test/src/bin/replay/replay_impl.rs74 .map_ok(|value| (value.0.user_key.table_key.0.into(), value.1.into()))CODE
TODO Padding12 hits · 18 pts
SeverityFileLineSnippetContext
LOW…/frontend/src/optimizer/plan_node/batch_project_set.rs70 // TODO: implement to_distributed_with_required like BatchProjectCOMMENT
LOW…rontend/src/optimizer/plan_node/logical_project_set.rs399 // TODO: implement to_stream_with_dist_required like LogicalProjectCOMMENT
LOWsrc/frontend/src/binder/expr/function/builtin_scalar.rs586 // TODO: implement pg_get_expr rather than just return empty as an workaround.COMMENT
LOWsrc/frontend/src/binder/expr/function/builtin_scalar.rs741 // TODO: implement real cancel rather than just return false as an workaround.COMMENT
LOWsrc/frontend/src/binder/expr/function/builtin_scalar.rs745 // TODO: implement real terminate rather than just return false as anCOMMENT
LOWsrc/frontend/src/binder/expr/function/builtin_scalar.rs784 // TODO: implement pg_sleep_untilCOMMENT
LOWsrc/meta/src/rpc/ddl_controller.rs338 // TODO: implement dynamic semaphore with limits by ourself.COMMENT
LOWsrc/expr/impl/src/scalar/arithmetic_op.rs250 // TODO: implement `checked_sub` for `Timestamp` to handle the edge case of negationCOMMENT
LOWsrc/common/src/config/hba.rs226 // TODO: implement hostname resolutionCOMMENT
LOWsrc/sqlparser/src/parser_v2/expr.rs26 // TODO: implement this function using combinator style.COMMENT
LOWsrc/sqlparser/src/parser_v2/expr.rs37 // TODO: implement this function using combinator style.COMMENT
LOWsrc/sqlparser/src/ast/ddl.rs58 /// TODO: implement `DROP CONSTRAINT <name>`COMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHe2e_test/iceberg/test_case/no_partition_upsert.toml01,1,50,1-50,2022-03-11 1,2,2,2-2,2022-03-12 1,3,2,3-2,2022-03-13 1,5,2,5-2,2022-03-15 1,8,2,8-2,2022-03-18 1,13,2,13-2,2STRING
HIGHe2e_test/iceberg/test_case/partition_upsert.toml01,1,50,1-50,2022-03-11 1,2,2,2-2,2022-03-12 1,3,2,3-2,2022-03-13 1,5,2,5-2,2022-03-15 1,8,2,8-2,2022-03-18 1,13,2,13-2,2STRING
HIGHe2e_test/iceberg/test_case/range_partition_upsert.toml01,1,50,1-50,2022-03-11 1,2,2,2-2,2022-03-12 1,3,2,3-2,2022-03-13 1,5,2,5-2,2022-03-15 1,8,2,8-2,2022-03-18 1,13,2,13-2,2STRING
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHsrc/common/secret/src/vault_client.rs41/// Cache key contains (vault service base url, `role_id`) as requestedCOMMENT
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHsrc/common/src/vector/distance.rs130/// In this implementation, we don't take the square root to avoid unnecessary computation, becauseCOMMENT
AI Structural Patterns3 hits · 3 pts
SeverityFileLineSnippetContext
LOW…ion_tests/feature-store/server/model/model_pb2_grpc.py89CODE
LOW…ion_tests/feature-store/server/model/model_pb2_grpc.py116CODE
LOW…tegration_tests/scripts/compatibility/compatibility.py7CODE
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippetContext
LOWgrafana/dashboard/dev/streaming_common.py24 # We make sure to fill in zero if there are no dispatchers for a given fragment.COMMENT
Modern Structural Boilerplate1 hit · 1 pts
SeverityFileLineSnippetContext
LOWe2e_test/commands/psql_validate.py39logger = logging.getLogger(__name__)CODE