Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
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).
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 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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 441 | madsim-tonic = { git = "https://github.com/risingwavelabs/madsim.git", rev = "595455fd05058b3b48bf281bea3ada1bca3d6646" | COMMENT |
| LOW | tomlfmt.toml | 1 | # Configuration file for `cargo-sort`. | COMMENT |
| LOW | risedev.yml | 1 | # The schema for RiseDev configuration files is defined under `src/risedevtool/schemas`. | COMMENT |
| LOW | risedev.yml | 21 | # # Specify custom environment variables | COMMENT |
| LOW | risedev.yml | 41 | COMMENT | |
| LOW | .config/hakari.toml | 1 | # This file contains settings for `cargo hakari`. | COMMENT |
| LOW | docker/risingwave.toml | 1 | # RisingWave config file to be mounted into the Docker containers. | COMMENT |
| LOW | integration_tests/iceberg-cdc/python/script/init.py | 61 | # WITH ( | COMMENT |
| LOW | integration_tests/feature-store/run-local.sh | 41 | COMMENT | |
| LOW | integration_tests/feature-store/server/src/server_pb.rs | 1 | #[allow(clippy::derive_partial_eq_without_eq)] | COMMENT |
| LOW | integration_tests/feature-store/server/src/server_pb.rs | 81 | #[prost(int64, tag = "1")] | COMMENT |
| LOW | integration_tests/feature-store/server/src/model.rs | 1 | #[allow(clippy::derive_partial_eq_without_eq)] | COMMENT |
| LOW | …gration_tests/feature-store/simulator/src/server_pb.rs | 1 | #[allow(clippy::derive_partial_eq_without_eq)] | COMMENT |
| LOW | …gration_tests/feature-store/simulator/src/server_pb.rs | 81 | #[prost(int64, tag = "1")] | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/pd.toml | 81 | COMMENT | |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 1 | # TiKV config template | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 21 | # max-tasks-high = 8000 | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 41 | [server] | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 61 | COMMENT | |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 81 | # labels = {} | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 101 | # the "scheduler too busy" error is displayed. | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 121 | # raftdb-path = "" | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 141 | # Interval to check region whether need to be split or not. | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 161 | # Interval to check whether start manual compaction for a region, | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 181 | COMMENT | |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 201 | # compaction job by breaking it into multiple, smaller ones that are run simultaneously. | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 221 | COMMENT | |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 241 | # then wal-size-limit, they will be deleted starting with the | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 261 | COMMENT | |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 281 | # rate-bytes-per-sec = 0 | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 301 | # if it has been active longer than `log_file_time_to_roll`. | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 321 | # snappy: kSnappyCompression | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 341 | # false means one sst file one bloom filter, true means every block has a corresponding bloom filter | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 361 | # min-write-buffer-number-to-merge = 1 | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 381 | # block-cache-size = "1GB" | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 401 | # dynamic-level-bytes = true | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 421 | # compaction-pri = 3 | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 441 | # dynamic-level-bytes = true | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 461 | # info-log-roll-time = "0" | COMMENT |
| LOW | integration_tests/tidb-cdc-sink/config/tikv.toml | 481 | # compaction-pri = 0 | COMMENT |
| LOW | integration_tests/superset/docker/docker-bootstrap.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | integration_tests/superset/docker/run-server.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | integration_tests/superset/docker/docker-init.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …ests/superset/docker/pythonpath_dev/superset_config.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | ci/scripts/flamegraph-env-build.sh | 21 | ############# SETUP RW | COMMENT |
| LOW | ci/scripts/deterministic-recovery-test.sh | 21 | sqlx=error,\ | COMMENT |
| LOW | ci/scripts/run-backfill-tests.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | ci/scripts/remove-micro-bench-results.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | ci/scripts/gen-flamegraph.sh | 121 | KAFKA_HOST="localhost:9092" | COMMENT |
| LOW | ci/scripts/e2e-source-mysql-cdc-reset.sh | 1 | #!/bin/bash | COMMENT |
| LOW | grafana/dashboard/dev/streaming_common.py | 1 | from ..common import Panels, metric | COMMENT |
| LOW | grafana/dashboard/dev/vector_search.py | 81 | % (COMPONENT_LABEL, NODE_LABEL), | COMMENT |
| LOW | …a/io/debezium/connector/postgresql/PostgresSchema.java | 241 | COMMENT | |
| LOW | …gresql/connection/pgoutput/PgOutputMessageDecoder.java | 441 | // Remove any PKs that do not exist as part of this this relation message. This can occur | COMMENT |
| LOW | …gresql/connection/pgoutput/PgOutputMessageDecoder.java | 481 | // scope. | COMMENT |
| LOW | …gresql/connection/pgoutput/PgOutputMessageDecoder.java | 561 | if (!resolvedTable.isPresent()) { | COMMENT |
| LOW | …gresql/connection/pgoutput/PgOutputMessageDecoder.java | 641 | */ | COMMENT |
| LOW | …ctor/binlog/history/BinlogHistoryRecordComparator.java | 121 | // https://dev.mysql.com/doc/refman/8.2/en/replication-gtids-failover.html, | COMMENT |
| LOW | …r/cdc/debezium/internal/NoDataRecoverySnapshotter.java | 1 | // Copyright 2025 RisingWave Labs | COMMENT |
| LOW | …nector/cdc/debezium/internal/OpendalSchemaHistory.java | 1 | // Copyright 2025 RisingWave Labs | COMMENT |
| 3595 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | Makefile.toml | 617 | # This file is used to store extra profiles besides the ones defined in `risedev.yml`. | COMMENT |
| MEDIUM | .config/hakari.toml | 1 | # This file contains settings for `cargo hakari`. | COMMENT |
| MEDIUM | …ion_tests/feature-store/server/model/model_pb2_grpc.py | 84 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | …gration_tests/client-library/python/test_sqlalchemy.py | 5 | # Create a base class for declarative class definitions | COMMENT |
| MEDIUM | …gration_tests/client-library/python/test_sqlalchemy.py | 10 | # Define a simple User class as an example | COMMENT |
| MEDIUM | …gration_tests/client-library/python/test_sqlalchemy.py | 22 | # Create an SQLAlchemy engine to manage connections to the database | COMMENT |
| MEDIUM | integration_tests/client-library/python/client.py | 22 | cursor = self.connection.cursor() # Create a cursor object | CODE |
| MEDIUM | integration_tests/superset/docker/docker-init.sh | 54 | # Create an admin user | COMMENT |
| MEDIUM | …ests/superset/docker/pythonpath_dev/superset_config.py | 18 | # This file is included in the final Docker image and SHOULD be overridden when | COMMENT |
| MEDIUM | integration_tests/mindsdb/prepare_data.sh | 12 | # Create a new table and insert records | COMMENT |
| MEDIUM | ci/docker-compose.yml | 125 | # Create the user | COMMENT |
| MEDIUM | ci/docker-compose.yml | 157 | # Create the user | COMMENT |
| MEDIUM | ci/scripts/upload-coverage.sh | 12 | # Create a directory for coverage files | COMMENT |
| MEDIUM | e2e_test/source_inline/commands.toml | 1 | # This file contains commands used by the tests. | COMMENT |
| MEDIUM | e2e_test/source_inline/nats/operation.py | 12 | # Create a NATS client | COMMENT |
| MEDIUM | e2e_test/source_inline/vault/vault_approle_setup.py | 40 | # Create a policy for secret access | COMMENT |
| MEDIUM | e2e_test/source_inline/vault/vault_approle_setup.py | 129 | # Create the secret using AppRole authentication | COMMENT |
| MEDIUM | e2e_test/over_window/gen.py | 21 | file_head = """# This file is generated by `gen.py`. Do not edit it manually!""" | CODE |
| MEDIUM | e2e_test/udf/tests/scalar/gen.py | 18 | file_head = """# This file is generated by `gen.py`. Do not edit it manually!""" | CODE |
| MEDIUM | .github/dependabot.yml | 28 | # Create a group of dependencies to be updated together in one pull request | COMMENT |
| MEDIUM | …tend/planner_test/tests/testdata/output/asof_join.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …ner_test/tests/testdata/output/predicate_pushdown.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …end/planner_test/tests/testdata/output/parameters.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …/planner_test/tests/testdata/output/select_except.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …ontend/planner_test/tests/testdata/output/project.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …nner_test/tests/testdata/output/generated_columns.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …planner_test/tests/testdata/output/column_pruning.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …lanner_test/tests/testdata/output/with_ordinality.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …tend/planner_test/tests/testdata/output/intersect.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …est/tests/testdata/output/nexmark_temporal_filter.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # 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.yml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …/planner_test/tests/testdata/output/join_ordering.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …lanner_test/tests/testdata/output/watermark_group.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …rontend/planner_test/tests/testdata/output/delete.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …frontend/planner_test/tests/testdata/output/share.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …ontend/planner_test/tests/testdata/output/dbeaver.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …st/tests/testdata/output/subquery_expr_correlated.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …/planner_test/tests/testdata/output/sysinfo_funcs.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …/frontend/planner_test/tests/testdata/output/cast.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …/planner_test/tests/testdata/output/create_source.yaml | 1 | # 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.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …ontend/planner_test/tests/testdata/output/explain.yaml | 1 | # 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.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …ontend/planner_test/tests/testdata/output/nexmark.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| MEDIUM | …test/tests/testdata/output/case_when_optimization.yaml | 1 | # This file is automatically generated. See `src/frontend/planner_test/README.md` for more information. | COMMENT |
| 102 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 20 | //! ┌───┐ x┌──────┐ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 21 | //! │Any◄─────────────────┤single│ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 22 | //! └─▲─┘ x└──────┘ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 26 | //! ┌───┴────┐ x┌──────────┐ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 27 | //! │AnyShard◄──────────────┤SomeShard │ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 28 | //! └───▲────┘ x└──────────┘ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 30 | //! ┌───┴───────────┐ x┌──────────────┐ ┌──────────────┐ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 32 | //! └───▲──▲────────┘ │ x└──────────────┘ └┬─────────────┘ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 34 | //! │ │ └─────────────────────┘ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 36 | //! │ ┌┴────────────┐ x┌────────────┐ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 38 | //! │ └─────────────┘ x└────────────┘ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 40 | //! ┌┴────────────┐ x┌────────────┐ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 41 | //! │ShardByKey(b)◄──────┤HashShard(b)│ | COMMENT |
| MEDIUM⚡ | src/frontend/src/optimizer/property/distribution.rs | 42 | //! └─────────────┘ x└────────────┘ | COMMENT |
| MEDIUM | src/frontend/src/datafusion/aggregate/mod.rs | 133 | //! └──────────┬──────────────────┘ | COMMENT |
| MEDIUM | src/frontend/src/datafusion/aggregate/mod.rs | 155 | //! └──────────┬──────────────────┘ | COMMENT |
| MEDIUM⚡ | src/stream/src/executor/over_window/eowc.rs | 122 | /// ──────────────┬────────────────────────────────────────────────────── curr evict row | COMMENT |
| MEDIUM⚡ | src/stream/src/executor/over_window/eowc.rs | 128 | /// ────────┴──┬─────┼──┼──────────────────────────────────────────────── curr output row | COMMENT |
| MEDIUM⚡ | src/stream/src/executor/over_window/eowc.rs | 132 | /// ─────────────────┴─────────────────────────────────────────────────── curr input row | COMMENT |
| MEDIUM⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 199 | // ── Recover while job is idle / between refresh cycles. ────────────────── | COMMENT |
| MEDIUM⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 202 | // ── Second cycle: changes after recovery must still be picked up. ──────── | COMMENT |
| MEDIUM⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 209 | // ── Recover using meta + CN together, then run another cycle. ──────────── | COMMENT |
| MEDIUM | src/meta/src/barrier/checkpoint/control.rs | 1388 | // ── Batch refresh trigger helpers ──────────────────────────────────────── | COMMENT |
| MEDIUM | src/meta/src/barrier/checkpoint/independent_job/mod.rs | 71 | // ── Enum unifying independent checkpoint job types ────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 72 | // ── Public types ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 102 | // ── Batch refresh job metadata ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 122 | // ── Status ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 183 | // ── Complete type ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 185 | // ── Main checkpoint control ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 205 | // ── Unified actor rendering ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 465 | // ── Construction ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 684 | // ── Barrier injection ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 731 | // ── Barrier forwarding and collection ───────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 922 | // ── Completing ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1055 | // ── Query methods ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1185 | // ── Logstore refresh run ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1476 | // ── Drop handling ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1545 | // ── Barrier stats ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | src/compute/src/memory/controller.rs | 62 | /// ┌───────────────────┐ ┌───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/compute/src/memory/controller.rs | 64 | /// ┌───► (observe) ├───────►│ (control) ├───┐ | COMMENT |
| MEDIUM⚡ | src/compute/src/memory/controller.rs | 66 | /// │ └───────────────────┘ └───────────────────┘ │ | COMMENT |
| MEDIUM⚡ | src/compute/src/memory/controller.rs | 68 | /// └────────────────────────────────────────────────────────┘ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 16 | // Step 1: Create a subscription | COMMENT |
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 22 | // Step 2: Declare a subscription cursor | COMMENT |
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 28 | // Step 3: Fetch data from the subscription cursor | COMMENT |
| LOW | .agents/skills/fix-buildkite-ci/SKILL.md | 33 | ## Step 1: Identify Failing Buildkite Checks | COMMENT |
| LOW | .agents/skills/fix-buildkite-ci/SKILL.md | 40 | ## Step 2: Pull Build JSON and Failed Jobs | COMMENT |
| LOW | .agents/skills/fix-buildkite-ci/SKILL.md | 52 | ## Step 3: Extract the Concrete Failure | COMMENT |
| LOW⚡ | .agents/skills/fix-buildkite-ci/SKILL.md | 65 | ## Step 4: Fall Back to Artifacts | COMMENT |
| LOW⚡ | .agents/skills/fix-buildkite-ci/SKILL.md | 74 | ## Step 5: Apply Focused Fixes | COMMENT |
| LOW⚡ | .agents/skills/fix-buildkite-ci/SKILL.md | 84 | ## Step 6: Verify and Report | COMMENT |
| LOW | .agents/skills/risingwave-rust-analyzer/SKILL.md | 19 | ## Step 1: Confirm the Analysis Root | COMMENT |
| LOW | .agents/skills/risingwave-rust-analyzer/SKILL.md | 28 | ## Step 2: Resolve the Crate and Features | COMMENT |
| LOW | .agents/skills/risingwave-rust-analyzer/SKILL.md | 53 | ## Step 3: Use rust-analyzer CLI | COMMENT |
| LOW | .agents/skills/risingwave-rust-analyzer/SKILL.md | 68 | ## Step 4: Configure LSP Carefully | COMMENT |
| LOW | docs/dev/src/benchmark-and-profile/memory-profiling.md | 17 | ## Step 1 - Collect Heap Dump | COMMENT |
| LOW | docs/dev/src/benchmark-and-profile/memory-profiling.md | 129 | ## Step 2 - Analyze Heap Dump | COMMENT |
| LOW | docs/dev/src/benchmark-and-profile/memory-profiling.md | 201 | ## Step 3 - Visualize Flame Graph | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 40 | # Step 1: Produce some initial records to the topic | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 47 | # Step 2: Sleep 1 second | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 51 | # Step 3: Record timestamp as millis as CURRENT_TIMESTAMP | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 55 | # Step 4: Produce more data | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 83 | # Step 5: Create a table in RisingWave, starting load from CURRENT_TIMESTAMP | COMMENT |
| LOW | e2e_test/source_inline/kafka/kafka_startup_millis.py | 108 | # Step 6: Select count(*) from the table | STRING |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 125 | # Step 7: Drop the table | STRING |
| LOW⚡ | e2e_test/source_inline/vault/vault_approle_setup.py | 182 | # Step 1: Create/setup Vault AppRole | STRING |
| LOW⚡ | e2e_test/source_inline/vault/vault_approle_setup.py | 185 | # Step 2: Create RisingWave secret using AppRole credentials | STRING |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 154 | // Step 1: Build pre-projection that constructs ROW expressions | COMMENT |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 189 | // Step 2: Build new aggregation calls operating on ROW columns | COMMENT |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 246 | // Step 3: Build post-projection to extract fields from ROW results | COMMENT |
| LOW⚡ | …d/src/optimizer/rule/streaming_index_selection_rule.rs | 45 | // Step 1: Try covering index selection. | COMMENT |
| LOW⚡ | …d/src/optimizer/rule/streaming_index_selection_rule.rs | 49 | // Step 2: Try IN expansion on the (possibly index-backed) scan. | COMMENT |
| LOW | src/stream/src/executor/source/source_executor.rs | 829 | // Step 1: Collect all current splits and clear their offsets | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 904 | // Step 2: Write splits back to state table with offset = None | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 910 | // Step 3: Update in-memory split info with cleared offsets | COMMENT |
| LOW | src/tests/sqlsmith/src/sqlreduce/checker.rs | 124 | // Step 1: Check if this is a frontend-only error (SQL syntax, type errors, etc.) | COMMENT |
| LOW⚡ | src/tests/sqlsmith/src/sqlreduce/checker.rs | 161 | // Step 2: Check if connection is lost (possible panic) | COMMENT |
| LOW⚡ | src/tests/sqlsmith/src/sqlreduce/checker.rs | 165 | // Step 3: Check logs for panic in compute/meta/compactor | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 63 | // Step 1: Enable locality backfill and configure for slow background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 68 | // Step 2: Create table and populate with 10,000 rows | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 73 | // Step 3: Verify row count | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 77 | // Step 4: Create materialized view with background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 80 | // Step 5: Find the internal table names for locality provider | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 107 | // Step 7: Trigger recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 110 | // Step 8: Check internal tables after recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 123 | // Step 9: Remove rate limit and wait for completion | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 127 | // Step 10: Verify MV result | COMMENT |
| LOW | …/tests/integration_tests/recovery/locality_backfill.rs | 94 | // Step 6: Check internal tables before recovery | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 93 | // Step 5: Alter rate limit to default (unlimited). | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 99 | // Step 6: Wait for the batch refresh to complete. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 104 | // Step 7: Verify the MV row count matches the source table. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 128 | // Step 9: Trigger another recovery while the batch refresh job is idle. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 133 | // Step 10: Verify that the MV is still queryable after idle recovery. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 37 | // Step 1: Create table and insert 10,000 rows. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 48 | // Step 2: Create a batch refresh MV with background DDL and backfill rate limit = 1. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 67 | // Step 3: Wait a bit for backfill to make some progress, then check DDL progress. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 79 | // Step 4: Trigger recovery and verify progress survives. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 116 | // Step 8: Now the batch refresh job is idle (snapshot done, waiting for next refresh). | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 145 | // Step 11: DROP the MV. | COMMENT |
| LOW | …on/tests/integration_tests/recovery/serving_mapping.rs | 61 | // Step 1: Create a table and insert data. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 72 | // Step 2: Kill all nodes. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 77 | // Step 3: Restart meta first. | COMMENT |
| 27 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | integration_tests/deltalake-sink/sink_check.py | 2 | CODE | |
| LOW | integration_tests/upsert-avro/datagen.py | 3 | CODE | |
| LOW | integration_tests/upsert-avro/datagen.py | 7 | CODE | |
| LOW | integration_tests/iceberg-source/python/main.py | 1 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/udf.py | 3 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 1 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 2 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 4 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 5 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 7 | CODE | |
| LOW | integration_tests/feature-store/server/model/model.py | 12 | CODE | |
| LOW | …ion_tests/feature-store/server/model/model_pb2_grpc.py | 4 | CODE | |
| LOW | …tegration_tests/feature-store/server/model/__main__.py | 1 | CODE | |
| LOW | integration_tests/feature-store/generator/preference.py | 1 | CODE | |
| LOW | integration_tests/feature-store/generator/user.py | 1 | CODE | |
| LOW | integration_tests/feature-store/generator/user.py | 2 | CODE | |
| LOW | integration_tests/feature-store/generator/__main__.py | 7 | CODE | |
| LOW | integration_tests/scripts/gen_pb_compose.py | 3 | CODE | |
| LOW | …tegration_tests/scripts/compatibility/compatibility.py | 3 | CODE | |
| LOW | integration_tests/scripts/compatibility/cli.py | 2 | CODE | |
| LOW | …ests/superset/docker/pythonpath_dev/superset_config.py | 25 | CODE | |
| LOW | …ests/superset/docker/pythonpath_dev/superset_config.py | 118 | CODE | |
| LOW | integration_tests/iceberg-sink2/python/main.py | 1 | CODE | |
| LOW | grafana/risingwave-user-dashboard.dashboard.py | 5 | CODE | |
| LOW | grafana/risingwave-user-dashboard.dashboard.py | 5 | CODE | |
| LOW | grafana/risingwave-user-dashboard.dashboard.py | 5 | CODE | |
| LOW | grafana/risingwave-user-dashboard.dashboard.py | 5 | CODE | |
| LOW | grafana/risingwave-user-dashboard.dashboard.py | 20 | CODE | |
| LOW | grafana/risingwave-dev-dashboard.dashboard.py | 10 | CODE | |
| LOW | grafana/dashboard/common.py | 4 | CODE | |
| LOW | grafana/dashboard/user/memory.py | 1 | CODE | |
| LOW | grafana/dashboard/user/batch.py | 1 | CODE | |
| LOW | grafana/dashboard/user/cpu.py | 1 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 2 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 14 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 15 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 16 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 17 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 18 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 19 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 20 | CODE | |
| LOW | grafana/dashboard/user/__init__.py | 21 | CODE | |
| LOW | grafana/dashboard/user/overview.py | 1 | CODE | |
| LOW | grafana/dashboard/user/storage.py | 1 | CODE | |
| LOW | grafana/dashboard/user/actor_info.py | 1 | CODE | |
| LOW | grafana/dashboard/user/network.py | 1 | CODE | |
| LOW | grafana/dashboard/user/streaming.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/object_storage.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/iceberg_compaction_metrics.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/memory_manager.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/hummock_write.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/iceberg_metrics.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/network_connection.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/sink_metrics.py | 1 | CODE | |
| LOW | grafana/dashboard/dev/cluster_alerts.py | 1 | CODE | |
| 83 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 16 | // Step 1: Create a subscription | COMMENT |
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 22 | // Step 2: Declare a subscription cursor | COMMENT |
| LOW⚡ | …ava/src/test/java/com/risingwave/TestSubscription.java | 28 | // Step 3: Fetch data from the subscription cursor | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 40 | # Step 1: Produce some initial records to the topic | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 47 | # Step 2: Sleep 1 second | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 51 | # Step 3: Record timestamp as millis as CURRENT_TIMESTAMP | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 55 | # Step 4: Produce more data | COMMENT |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 83 | # Step 5: Create a table in RisingWave, starting load from CURRENT_TIMESTAMP | COMMENT |
| LOW | e2e_test/source_inline/kafka/kafka_startup_millis.py | 108 | # Step 6: Select count(*) from the table | STRING |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 125 | # Step 7: Drop the table | STRING |
| LOW⚡ | e2e_test/source_inline/vault/vault_approle_setup.py | 182 | # Step 1: Create/setup Vault AppRole | STRING |
| LOW⚡ | e2e_test/source_inline/vault/vault_approle_setup.py | 185 | # Step 2: Create RisingWave secret using AppRole credentials | STRING |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 154 | // Step 1: Build pre-projection that constructs ROW expressions | COMMENT |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 189 | // Step 2: Build new aggregation calls operating on ROW columns | COMMENT |
| LOW | …tend/src/optimizer/rule/unify_first_last_value_rule.rs | 246 | // Step 3: Build post-projection to extract fields from ROW results | COMMENT |
| LOW⚡ | …d/src/optimizer/rule/streaming_index_selection_rule.rs | 45 | // Step 1: Try covering index selection. | COMMENT |
| LOW⚡ | …d/src/optimizer/rule/streaming_index_selection_rule.rs | 49 | // Step 2: Try IN expansion on the (possibly index-backed) scan. | COMMENT |
| LOW | src/stream/src/executor/hash_join.rs | 1078 | /// For the probe-side row, we need to check if it has values in cache, if not, we need to | COMMENT |
| LOW | src/stream/src/executor/source/source_executor.rs | 829 | // Step 1: Collect all current splits and clear their offsets | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 904 | // Step 2: Write splits back to state table with offset = None | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 910 | // Step 3: Update in-memory split info with cleared offsets | COMMENT |
| LOW | src/stream/src/executor/mview/cache.rs | 479 | // For bytea type, we need to check if it contains the string bytes of DEBEZIUM_UNAVAILABLE_VALUE | COMMENT |
| LOW | src/tests/sqlsmith/src/sqlreduce/checker.rs | 124 | // Step 1: Check if this is a frontend-only error (SQL syntax, type errors, etc.) | COMMENT |
| LOW⚡ | src/tests/sqlsmith/src/sqlreduce/checker.rs | 161 | // Step 2: Check if connection is lost (possible panic) | COMMENT |
| LOW⚡ | src/tests/sqlsmith/src/sqlreduce/checker.rs | 165 | // Step 3: Check logs for panic in compute/meta/compactor | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 63 | // Step 1: Enable locality backfill and configure for slow background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 68 | // Step 2: Create table and populate with 10,000 rows | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 73 | // Step 3: Verify row count | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 77 | // Step 4: Create materialized view with background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 80 | // Step 5: Find the internal table names for locality provider | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 107 | // Step 7: Trigger recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 110 | // Step 8: Check internal tables after recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 123 | // Step 9: Remove rate limit and wait for completion | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 127 | // Step 10: Verify MV result | COMMENT |
| LOW | …/tests/integration_tests/recovery/locality_backfill.rs | 94 | // Step 6: Check internal tables before recovery | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 93 | // Step 5: Alter rate limit to default (unlimited). | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 99 | // Step 6: Wait for the batch refresh to complete. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 104 | // Step 7: Verify the MV row count matches the source table. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 128 | // Step 9: Trigger another recovery while the batch refresh job is idle. | COMMENT |
| LOW⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 133 | // Step 10: Verify that the MV is still queryable after idle recovery. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 37 | // Step 1: Create table and insert 10,000 rows. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 48 | // Step 2: Create a batch refresh MV with background DDL and backfill rate limit = 1. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 67 | // Step 3: Wait a bit for backfill to make some progress, then check DDL progress. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 79 | // Step 4: Trigger recovery and verify progress survives. | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 116 | // Step 8: Now the batch refresh job is idle (snapshot done, waiting for next refresh). | COMMENT |
| LOW | …tion/tests/integration_tests/recovery/batch_refresh.rs | 145 | // Step 11: DROP the MV. | COMMENT |
| LOW | …on/tests/integration_tests/recovery/serving_mapping.rs | 61 | // Step 1: Create a table and insert data. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 72 | // Step 2: Kill all nodes. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 77 | // Step 3: Restart meta first. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 83 | // Step 4: Restart ONLY the serving CN (compute-2). | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 91 | // Step 5: Restart frontend. | COMMENT |
| LOW⚡ | …on/tests/integration_tests/recovery/serving_mapping.rs | 95 | // Step 6: Query the table. | COMMENT |
| LOW⚡ | src/meta/service/src/stream_service.rs | 976 | // Step 1: Pause the stream (already commits state) | COMMENT |
| LOW⚡ | src/meta/service/src/stream_service.rs | 982 | // Step 2: Update catalog and get the new properties | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1010 | // Step 3: Issue ConnectorPropsChange barrier | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1021 | // Step 4: Optional split reset | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1034 | // Step 5: Resume the stream (even if previous steps failed) | COMMENT |
| LOW | src/meta/src/stream/source_manager/split_assignment.rs | 549 | // we need to check if discovered_split_ids is empty, because if it is empty, we need to | COMMENT |
| LOW | src/meta/src/barrier/checkpoint/state.rs | 274 | // Step 2: Render actors for each ensemble. | COMMENT |
| LOW | src/meta/src/barrier/checkpoint/state.rs | 353 | // Step 3: Expand simple assignments into full StreamActor structures. | COMMENT |
| 9 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | develop/sql_bench/main.py | 199 | subprocess.run("risedev k && risedev clean-data", shell=True, check=False) | STRING |
| HIGH | integration_tests/upsert-avro/datagen.py | 15 | {"type":"record","name":"OBJ_ATTRIBUTE_VALUE","namespace":"CPLM","fields":[{"name":"op_type","type":["null","string"],"d | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 12 | subprocess.run(["docker", "compose", "exec", "python", "bash", "-c", "cd /python-client && pip3 install -r requireme | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 17 | subprocess.run(["docker", "compose", "exec", "java", "bash", "-c", "apt-get update && apt-get install -y maven"], | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 19 | subprocess.run(["docker", "compose", "exec", "java", "bash", "-c", "cd /java-client && mvn clean test"], | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 25 | ["docker", "compose", "exec", "nodejs", "bash", "-c", "cd /nodejs-client && npm install && npm test"], | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 31 | ["docker", "compose", "exec", "php", "bash", "-c", "cd /php-client && phpunit tests/RWClientTest.php"], | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 36 | subprocess.run(["docker", "compose", "exec", "ruby", "bash", "-c", "cd /ruby-client && ruby test/crud_test.rb"], | CODE |
| HIGH⚡ | integration_tests/client-library/client_test.py | 41 | subprocess.run(["docker", "compose", "exec", "spring-boot", "bash", "-c", "cd /spring-boot-client && mvn spring-boot | CODE |
| HIGH | grafana/dashboard/dev/cluster_errors.py | 47 | # We add a small constant 0.05 to make sure that the counter jumps from null to not-null, | COMMENT |
| HIGH | e2e_test/python_client/main.py | 49 | cur.execute("select ARRAY[true, false, null]::boolean[]", binary=True) | CODE |
| HIGH | e2e_test/python_client/main.py | 76 | cur.execute("select ARRAY['foo', 'bar', null]::varchar[]", binary=True) | CODE |
| HIGH⚡ | e2e_test/python_client/main.py | 101 | cur.execute("select array[ROW('123 Main St'::varchar, 'New York'::varchar, 10001), ROW('234 Main St'::va | CODE |
| HIGH⚡ | e2e_test/python_client/main.py | 118 | cur.execute("select '{\"name\": \"John\", \"age\": 30, \"city\": null}'::jsonb", binary=True) | CODE |
| HIGH⚡ | e2e_test/python_client/main.py | 121 | cur.execute("select '{\"scores\": [85.5, 90, null], \"passed\": true}'::jsonb", binary=True) | CODE |
| HIGH⚡ | e2e_test/python_client/main.py | 124 | cur.execute("select '[{\"id\": 1, \"value\": null}, {\"id\": 2, \"value\": \"test\"}]'::jsonb", binary=T | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | integration_tests/upsert-avro/datagen.py | 41 | def get_key_value_and_serializer(id, schema_registry_client): | STRING |
| LOW | integration_tests/iceberg-source/python/main.py | 87 | def check_risingwave_iceberg_source(docker): | STRING |
| LOW | ci/scripts/notify.py | 129 | def generate_test_status_message(failed_test_map): | CODE |
| LOW | ci/scripts/notify.py | 137 | def get_buildkite_test_status(test): | CODE |
| LOW | ci/scripts/find-regression.py | 201 | def test_get_number_of_commits(self): | STRING |
| LOW | grafana/dashboard/common.py | 102 | def next_one_third_width_graph(self): | CODE |
| LOW | grafana/dashboard/common.py | 249 | def timeseries_actor_latency_small( | CODE |
| LOW | grafana/dashboard/common.py | 384 | def timeseries_actor_ops_small( | CODE |
| LOW | grafana/dashboard/dev/streaming_common.py | 12 | def _actor_busy_time_relative_target(panels: Panels): | CODE |
| LOW | grafana/dashboard/dev/streaming_common.py | 123 | def relabel_materialized_view_id_as_id(expr: str) -> str: | CODE |
| LOW | grafana/dashboard/dev/streaming_common.py | 127 | def relabel_fragment_id_as_id(expr: str) -> str: | CODE |
| LOW | grafana/dashboard/dev/streaming_relations.py | 10 | def _relation_busy_rate_expr_by_mv(rate_interval: str): | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_relations.py | 32 | def _relation_metric_with_metadata(expr: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_relations.py | 36 | def _relation_busy_peak_topk_expr(rate_interval: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_relations.py | 44 | def _relation_cpu_peak_topk_expr( | CODE |
| LOW | grafana/dashboard/dev/streaming_relations.py | 66 | def _relation_busy_rate_target(panels: Panels, rate_interval: str): | CODE |
| LOW | grafana/dashboard/dev/streaming_relations.py | 73 | def _sum_fragment_metric_by_mv(expr: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 9 | def _fragment_topk_percent_expr(expr: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 13 | def _fragment_peak_rate_with_id_at_step(expr: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 20 | def _fragment_peak_rate_per_actor_with_id_at_step(per_actor_expr: str) -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 28 | def _kv_log_store_buffer_usage_by_fragment_expr() -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 35 | def _sync_kv_log_store_buffer_usage_by_fragment_expr() -> str: | CODE |
| LOW⚡ | grafana/dashboard/dev/streaming_fragments.py | 38 | def _channel_buffer_usage_by_fragment_expr() -> str: | CODE |
| LOW | …/risingwave/connector/source/SourceRequestHandler.java | 25 | public class SourceRequestHandler { | CODE |
| LOW | java/connector-node/python-client/pyspark-util.py | 104 | def test_upsert_iceberg_table(input_file): | CODE |
| LOW | java/connector-node/python-client/pyspark-util.py | 152 | def delete_deltalake_table_data(): | CODE |
| LOW | java/connector-node/python-client/integration_tests.py | 42 | def make_mock_schema_stream_chunk(): | CODE |
| LOW | java/connector-node/python-client/integration_tests.py | 106 | def load_stream_chunk_payload(input_file): | CODE |
| LOW | java/connector-node/python-client/integration_tests.py | 263 | def test_stream_chunk_data_format(param): | CODE |
| LOW | dashboard/lib/utils/timeUtils.ts | 48 | export function parseTimestampToUnixEpoch( | CODE |
| LOW | dashboard/lib/utils/timeUtils.ts | 70 | export function getCurrentTimeInSystemTimezone(): string { | CODE |
| LOW | dashboard/lib/api/cluster.ts | 32 | export async function getClusterInfoComputeNode() { | CODE |
| LOW | dashboard/lib/api/cluster.ts | 46 | export async function getClusterInfoProfileWorkers() { | CODE |
| LOW | dashboard/lib/api/streamingStats.ts | 48 | export function createStreamingStatsRefresh( | CODE |
| LOW | dashboard/pages/fragment_graph.tsx | 153 | function buildFragmentDependencyAsEdges( | CODE |
| LOW | dashboard/pages/cluster.tsx | 70 | function WorkerNodeMetricsComponent({ | CODE |
| LOW | e2e_test/check_slt_coverage.py | 88 | def extract_slt_patterns_from_script(script_path): | CODE |
| LOW | e2e_test/check_slt_coverage.py | 231 | def analyze_uncovered_directories(all_files, covered_files): | CODE |
| LOW | e2e_test/check_slt_coverage.py | 271 | def propagate_coverage_through_includes( | CODE |
| LOW | e2e_test/webhook/sender.py | 179 | def send_multi_column_validate(secret): | CODE |
| LOW | e2e_test/webhook/sender.py | 211 | def send_multi_column_with_options(): | CODE |
| LOW | e2e_test/webhook/sender.py | 229 | def send_multi_column_batched(): | CODE |
| LOW | e2e_test/webhook/sender.py | 242 | def send_multi_column_timestamp_option(): | CODE |
| LOW | e2e_test/webhook/sender.py | 257 | def send_multi_column_time_option(): | CODE |
| LOW | e2e_test/webhook/sender.py | 272 | def send_multi_column_bigint_precise_option(): | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 480 | def scenario_multi_column_no_pk(ws: SimpleWebSocketApp, state: WsState) -> None: | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 513 | def scenario_single_jsonb_no_pk(ws: SimpleWebSocketApp, state: WsState) -> None: | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 577 | def scenario_error_missing_pk(ws: SimpleWebSocketApp, state: WsState) -> None: | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 586 | def scenario_error_incomplete_composite_pk_insert( | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 606 | def scenario_error_incomplete_composite_pk_delete( | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 678 | def scenario_invalid_decoder_header( | CODE |
| LOW | e2e_test/s3/file_source.py | 19 | def _test_parquet_struct_field_subset(minio_client: Minio): | CODE |
| LOW | e2e_test/s3/file_source.py | 123 | def _test_parquet_struct_missing_field_in_file(minio_client: Minio): | STRING |
| LOW | e2e_test/s3/file_source.py | 228 | def _test_parquet_case_insensitive(minio_client: Minio): | STRING |
| LOW | e2e_test/source_inline/nats/operation.py | 68 | def validate_state_table_item(table_name: str, expect_count: int): | CODE |
| LOW | e2e_test/subscription/main.py | 17 | def create_table_subscription(): | CODE |
| LOW | e2e_test/subscription/main.py | 66 | def test_cursor_snapshot_log_store(): | CODE |
| LOW | e2e_test/subscription/main.py | 147 | def test_cursor_without_since(): | CODE |
| LOW | e2e_test/subscription/main.py | 172 | def test_cursor_since_rw_timestamp(): | CODE |
| LOW | e2e_test/subscription/main.py | 261 | def test_cursor_with_table_alter(): | CODE |
| 5 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | develop/sql_bench/main.py | 131 | print(f"Error: Benchmark '{bench_name}' already exists") | STRING |
| MEDIUM | develop/sql_bench/main.py | 143 | print(f"Error: Benchmark configuration '{bench_name}' not found at {yaml_file}") | STRING |
| MEDIUM | develop/sql_bench/main.py | 186 | print(f"Error: Benchmark '{bench_name}' failed") | STRING |
| LOW | integration_tests/iceberg-cdc/python/script/check.py | 24 | except Exception: | CODE |
| LOW | integration_tests/feature-store/server/model/model.py | 42 | except Exception as e: | CODE |
| LOW | integration_tests/feature-store/server/model/model.py | 64 | except Exception as e: | CODE |
| LOW | integration_tests/client-library/client_test.py | 67 | except Exception as e: | CODE |
| LOW | integration_tests/scripts/run_demos.py | 39 | except Exception: | CODE |
| LOW | integration_tests/scripts/run_demos.py | 58 | except Exception: | CODE |
| LOW | …erg-sink/iceberg-compaction-sql/rewrite_small_files.py | 13 | except Exception as exc: | CODE |
| LOW | java/connector-node/python-client/integration_tests.py | 171 | except Exception as e: | CODE |
| LOW | java/connector-node/python-client/integration_tests.py | 200 | except Exception as e: | CODE |
| LOW | e2e_test/check_slt_coverage.py | 211 | except Exception as e: | CODE |
| MEDIUM | e2e_test/check_slt_coverage.py | 213 | print(f"Error reading {slt_file}, skipping: {e}") | CODE |
| LOW | e2e_test/webhook/websocket_sender.py | 90 | except Exception as err: # noqa: BLE001 | CODE |
| LOW | e2e_test/source_inline/nats/operation.py | 37 | except Exception as e: | CODE |
| MEDIUM | e2e_test/source_inline/nats/operation.py | 38 | print(f"Error: {e}") | CODE |
| MEDIUM | e2e_test/source_inline/nats/operation.py | 122 | print("Error: Both stream name and subject are required") | CODE |
| MEDIUM | e2e_test/source_inline/nats/operation.py | 133 | print("Error: Both table name and expected count are required") | CODE |
| MEDIUM | e2e_test/source_inline/nats/operation.py | 140 | print("Error: Both stream name and consumer name are required") | CODE |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 35 | except Exception as e: | CODE |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 76 | except Exception as e: | CODE |
| LOW⚡ | e2e_test/source_inline/kafka/kafka_startup_millis.py | 130 | except Exception as e: | STRING |
| MEDIUM | e2e_test/source_inline/mqtt/rabbitmq_operation.py | 64 | print(f"Error: Cannot resolve hostname '{RABBITMQ_HOST}': {e}", file=sys.stderr) | CODE |
| LOW | e2e_test/source_inline/mqtt/rabbitmq_operation.py | 96 | except Exception as e: | CODE |
| MEDIUM | e2e_test/source_inline/mqtt/rabbitmq_operation.py | 97 | print(f"Error: {e}", file=sys.stderr) | CODE |
| MEDIUM | e2e_test/source_inline/mqtt/rabbitmq_operation.py | 111 | print(f"Error: Unknown command '{command}'. Only 'produce' is supported.", file=sys.stderr) | CODE |
| LOW | e2e_test/source_inline/vault/vault_approle_setup.py | 118 | except Exception as e: | CODE |
| LOW | e2e_test/source_inline/vault/vault_approle_setup.py | 158 | except Exception as e: | STRING |
| LOW | e2e_test/iceberg/main.py | 67 | except Exception as e: | CODE |
| LOW | e2e_test/iceberg/test_utils/spark_utils.py | 55 | except Exception as e: | CODE |
| LOW | e2e_test/commands/pulsar_util.py | 256 | except Exception as e: | CODE |
| MEDIUM | e2e_test/commands/pulsar_util.py | 271 | print(f"Error receiving message: {e}") | CODE |
| LOW | e2e_test/commands/pulsar_util.py | 351 | except Exception as e: | CODE |
| MEDIUM | e2e_test/commands/pulsar_util.py | 352 | print(f"Error checking compaction status: {e}") | CODE |
| LOW | e2e_test/commands/pulsar_util.py | 393 | except Exception as e: | CODE |
| MEDIUM | e2e_test/commands/pulsar_util.py | 394 | print(f"Error checking unacked messages: {e}") | CODE |
| LOW | e2e_test/commands/psql_validate.py | 175 | except Exception as e: | CODE |
| LOW | src/stream/benches/stream_hash_join.py | 58 | except Exception as e: | CODE |
| MEDIUM | src/stream/benches/stream_hash_join.py | 69 | print(f"Error running benchmark for Amp={amp}, Workload={workload}, JoinType={join_type}", file=sys.stde | CODE |
| MEDIUM | src/stream/benches/stream_hash_join.py | 70 | print(f"Error output: {e.output}", file=sys.stderr) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ci/scripts/backwards-compat-test.sh | 187 | # Assume we use the latest version, so we just set to some large number. | COMMENT |
| MEDIUM | …ngwave/connector/source/core/JniDbzSourceRegistry.java | 47 | // TODO: use a more robust way to handle this, e.g., may include the current term | COMMENT |
| MEDIUM | dashboard/package-lock.json | 9391 | "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.1.tgz", | CODE |
| MEDIUM | dashboard/package-lock.json | 17432 | "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.1.tgz", | CODE |
| LOW | e2e_test/iceberg/main.py | 64 | # Don't raise the exception, just return the failed result | COMMENT |
| MEDIUM | e2e_test/commands/pulsar_util.py | 257 | # More robust timeout detection | COMMENT |
| MEDIUM | src/frontend/src/handler/alter_mv.rs | 182 | // TODO(alter-mv): improve this to make it more robust and friendly. | COMMENT |
| MEDIUM | src/frontend/src/handler/variable.rs | 77 | // In future we can add converter/parser to make the API more robust. | COMMENT |
| MEDIUM | src/frontend/src/optimizer/plan_node/logical_agg.rs | 1545 | // If we call `try_better_locality` on input, it would miss the chance to utilize the locality of the current ag | COMMENT |
| MEDIUM | src/frontend/src/datafusion/scalar_function/mod.rs | 36 | //! [`ScalarUDFImpl`] to wrap RisingWave's expression evaluation logic. This allows seamless | COMMENT |
| MEDIUM | src/frontend/src/expr/type_inference/cast.rs | 59 | // Essentially a filter_map followed by a try_reduce, which is unstable. | COMMENT |
| MEDIUM | src/stream/src/executor/over_window/general.rs | 385 | // can leverage the block cache under the hood. | COMMENT |
| MEDIUM | src/meta/src/rpc/ddl_controller.rs | 2134 | // but more robust. | COMMENT |
| MEDIUM | src/expr/impl/src/window_function/aggregate.rs | 87 | // TODO(rc): utilize `retract` method of embedded UDAF to do incremental aggregation | COMMENT |
| MEDIUM | src/common/proc_macro/src/config.rs | 32 | // TODO(bugen): the implementation is not robust but it works for now. | COMMENT |
| MEDIUM | src/connector/src/source/cdc/external/sql_server.rs | 413 | // sql server cannot leverage the given key to narrow down the range of scan, | COMMENT |
| MEDIUM | src/connector/src/source/cdc/external/mysql.rs | 744 | // mysql cannot leverage the given key to narrow down the range of scan, | COMMENT |
| MEDIUM | src/connector/src/source/iceberg/planner.rs | 616 | /// It's deterministic so that it can best utilize the data locality. | COMMENT |
| MEDIUM | src/connector/src/source/iceberg/mod.rs | 424 | /// It's deterministic so that it can best utilize the data locality. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …egration_tests/client-library/nodejs/test/crud_test.js | 6 | let name = "John Doe" | CODE |
| LOW | integration_tests/client-library/go/pgx_test/mv_test.go | 22 | name := "John Doe" | CODE |
| LOW | integration_tests/client-library/go/pgx_test/mv_test.go | 99 | case "John Doe": | CODE |
| LOW | …egration_tests/client-library/go/pgx_test/crud_test.go | 122 | name := "John Doe" | CODE |
| LOW | …egration_tests/client-library/go/pgx_test/crud_test.go | 158 | updateData(conn, "John Doe", 60000) | CODE |
| LOW | …egration_tests/client-library/go/pgx_test/crud_test.go | 159 | deleteData(conn, "John Doe") | CODE |
| LOW | …tegration_tests/client-library/python/test_database.py | 66 | crud_instance.insert_data("John Doe", 25, 10000) | CODE |
| LOW⚡ | …tegration_tests/client-library/python/test_database.py | 79 | crud_instance.update_data("John Doe", 12000) | CODE |
| LOW⚡ | …tegration_tests/client-library/python/test_database.py | 83 | cursor.execute("SELECT salary FROM sample_table_py WHERE name='John Doe';") | CODE |
| LOW⚡ | …tegration_tests/client-library/python/test_database.py | 91 | crud_instance.delete_data("John Doe") | CODE |
| LOW⚡ | …tegration_tests/client-library/python/test_database.py | 96 | "SELECT EXISTS (SELECT 1 FROM sample_table_py WHERE name = 'John Doe');") | CODE |
| LOW | …gration_tests/client-library/python/test_sqlalchemy.py | 47 | new_user = User(id=1, name='John Doe', age=30) | STRING |
| LOW | …gration_tests/client-library/python/test_sqlalchemy.py | 57 | user_to_delete = db_session.query(User).filter_by(name='John Doe').first() | STRING |
| LOW | …ration_tests/client-library/php/tests/RWClientTest.php | 10 | $name = 'John Doe'; | CODE |
| LOW | integration_tests/client-library/csharp/NpgsqlTest.cs | 31 | insertCmd.Parameters.AddWithValue("name", "John Doe"); | CODE |
| LOW | integration_tests/client-library/ruby/test/crud_test.rb | 15 | name = 'John Doe' | CODE |
| LOW | ci/scripts/e2e-source-mysql-cdc-reset.sh | 121 | mysql -e "USE binlog_test; INSERT INTO test_table (id, value) VALUES (50, 'dummy_data');" | CODE |
| LOW | e2e_test/webhook/sender.py | 10 | "source": "placeholder", | CODE |
| LOW | e2e_test/webhook/sender.py | 11 | "auth_algo": "placeholder", | CODE |
| LOW⚡ | e2e_test/python_client/main.py | 98 | cur.execute("select ROW('123 Main St'::varchar, 'New York'::varchar, 10001)", binary=True) | CODE |
| LOW⚡ | e2e_test/python_client/main.py | 99 | self.assertEqual(cur.fetchone(), (('123 Main St', 'New York', 10001),)) | CODE |
| LOW⚡ | e2e_test/python_client/main.py | 101 | cur.execute("select array[ROW('123 Main St'::varchar, 'New York'::varchar, 10001), ROW('234 Main St'::va | CODE |
| LOW⚡ | e2e_test/python_client/main.py | 102 | self.assertEqual(cur.fetchone(), ([('123 Main St', 'New York', 10001), ('234 Main St', None, 10002)],)) | CODE |
| LOW | src/stream/src/executor/stream_reader.rs | 104 | futures::stream::once(async { unreachable!("placeholder") }).boxed(), | CODE |
| LOW | src/tests/regress/data/sql/tsearch.sql | 472 | 'Lorem ipsum urna. Nullam nullam ullamcorper urna.', | CODE |
| LOW | src/tests/regress/data/sql/tsearch.sql | 548 | 'Lorem ipsum urna. Nullam nullam ullamcorper urna.', | CODE |
| LOW | src/connector/codec/tests/integration_tests/protobuf.rs | 492 | "value": "John Doe", | CODE |
| LOW | src/connector/src/sink/encoder/avro.rs | 1021 | "name": "John Doe", | CODE |
| LOW | src/connector/src/sink/encoder/template.rs | 649 | Some(ScalarImpl::Utf8("John Doe".into())), | CODE |
| LOW | src/connector/src/sink/encoder/template.rs | 701 | Some(ScalarImpl::Utf8("John Doe".into())), | CODE |
| LOW | src/connector/src/parser/debezium/mongo_json_parser.rs | 629 | ScalarImpl::Utf8("John Doe".into()), | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Makefile.toml | 313 | # Check if there is any panic in log. | COMMENT |
| LOW | Makefile.toml | 322 | # Check if there are too many duplicated lines in log. | COMMENT |
| LOW | Makefile.toml | 345 | # Check if the total log size is too large. | COMMENT |
| LOW | integration_tests/mindsdb/prepare_data.sh | 7 | # Check if the table exists in the database | COMMENT |
| LOW | ci/scripts/setup-vault.sh | 25 | # Check if kv-v2 secrets engine is already enabled | COMMENT |
| LOW | e2e_test/check_slt_coverage.py | 137 | # Check if there's a grep exclusion in this command | COMMENT |
| LOW | e2e_test/check_slt_coverage.py | 325 | # Check if any file including this .slt.part is covered | COMMENT |
| LOW | e2e_test/check_slt_coverage.py | 336 | # Check if we've added any new files | COMMENT |
| LOW | e2e_test/source_inline/kafka/alter/get_kafka_offsets.py | 33 | # Set offset to skip last N messages | COMMENT |
| LOW | e2e_test/source_inline/mqtt/rabbitmq_operation.py | 60 | # Check if host is reachable | COMMENT |
| LOW | e2e_test/source_inline/vault/vault_approle_setup.py | 20 | # Check if AppRole auth method is enabled | COMMENT |
| LOW | e2e_test/commands/pulsar_util.py | 244 | # Print message info | COMMENT |
| LOW | e2e_test/commands/psql_validate.py | 190 | # Check if the number of lines matches | COMMENT |
| LOW | scripts/install/install-risingwave.sh | 103 | # Check if $JAVA_HOME is set, if not, prompt user to install Java, and set $JAVA_HOME. | COMMENT |
| LOW | src/tests/sqlsmith/scripts/gen_queries.sh | 246 | # Check if any query generation step failed, and any query file not generated. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | integration_tests/scripts/run_demos.py | 25 | CODE | |
| LOW | integration_tests/scripts/compatibility/cli.py | 35 | CODE | |
| LOW | integration_tests/scripts/compatibility/cli.py | 58 | CODE | |
| LOW | ci/scripts/notify.py | 113 | CODE | |
| LOW | ci/scripts/find-regression.py | 142 | CODE | |
| LOW | java/connector-node/python-client/integration_tests.py | 119 | CODE | |
| LOW | e2e_test/check_slt_coverage.py | 42 | CODE | |
| LOW | e2e_test/check_slt_coverage.py | 88 | CODE | |
| LOW | e2e_test/check_slt_coverage.py | 171 | CODE | |
| LOW | e2e_test/check_slt_coverage.py | 271 | CODE | |
| LOW | e2e_test/check_slt_coverage.py | 365 | CODE | |
| LOW | e2e_test/webhook/websocket_sender.py | 701 | CODE | |
| LOW | e2e_test/webhook/websocket_sender.py | 42 | CODE | |
| LOW | …e_inline/cdc/mysql/cron_only/wait_mysql_cdc_metrics.py | 18 | CODE | |
| LOW | e2e_test/iceberg/test_utils/test_utils.py | 67 | CODE | |
| LOW | e2e_test/iceberg/test_utils/test_utils.py | 112 | CODE | |
| LOW | e2e_test/iceberg/test_utils/log.py | 27 | CODE | |
| LOW | e2e_test/commands/pulsar_util.py | 411 | CODE | |
| LOW | e2e_test/commands/pulsar_util.py | 95 | CODE | |
| LOW | e2e_test/commands/pulsar_util.py | 152 | CODE | |
| LOW | e2e_test/commands/pulsar_util.py | 200 | CODE | |
| LOW | e2e_test/commands/pulsar_util.py | 302 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …a/com/risingwave/connector/source/MySQLSourceTest.java | 71 | com.risingwave.java.binding.Binding.initObjectStoreForTest( | CODE |
| CRITICAL | src/storage/hummock_test/src/bin/replay/replay_impl.rs | 74 | .map_ok(|value| (value.0.user_key.table_key.0.into(), value.1.into())) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/frontend/src/optimizer/plan_node/batch_project_set.rs | 70 | // TODO: implement to_distributed_with_required like BatchProject | COMMENT |
| LOW | …rontend/src/optimizer/plan_node/logical_project_set.rs | 399 | // TODO: implement to_stream_with_dist_required like LogicalProject | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 586 | // TODO: implement pg_get_expr rather than just return empty as an workaround. | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 741 | // TODO: implement real cancel rather than just return false as an workaround. | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 745 | // TODO: implement real terminate rather than just return false as an | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 784 | // TODO: implement pg_sleep_until | COMMENT |
| LOW | src/meta/src/rpc/ddl_controller.rs | 338 | // TODO: implement dynamic semaphore with limits by ourself. | COMMENT |
| LOW | src/expr/impl/src/scalar/arithmetic_op.rs | 250 | // TODO: implement `checked_sub` for `Timestamp` to handle the edge case of negation | COMMENT |
| LOW | src/common/src/config/hba.rs | 226 | // TODO: implement hostname resolution | COMMENT |
| LOW | src/sqlparser/src/parser_v2/expr.rs | 26 | // TODO: implement this function using combinator style. | COMMENT |
| LOW | src/sqlparser/src/parser_v2/expr.rs | 37 | // TODO: implement this function using combinator style. | COMMENT |
| LOW | src/sqlparser/src/ast/ddl.rs | 58 | /// TODO: implement `DROP CONSTRAINT <name>` | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | e2e_test/iceberg/test_case/no_partition_upsert.toml | 0 | 1,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,2 | STRING |
| HIGH | e2e_test/iceberg/test_case/partition_upsert.toml | 0 | 1,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,2 | STRING |
| HIGH | e2e_test/iceberg/test_case/range_partition_upsert.toml | 0 | 1,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,2 | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | src/common/secret/src/vault_client.rs | 41 | /// Cache key contains (vault service base url, `role_id`) as requested | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | src/common/src/vector/distance.rs | 130 | /// In this implementation, we don't take the square root to avoid unnecessary computation, because | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ion_tests/feature-store/server/model/model_pb2_grpc.py | 89 | CODE | |
| LOW | …ion_tests/feature-store/server/model/model_pb2_grpc.py | 116 | CODE | |
| LOW | …tegration_tests/scripts/compatibility/compatibility.py | 7 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | grafana/dashboard/dev/streaming_common.py | 24 | # We make sure to fill in zero if there are no dispatchers for a given fragment. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | e2e_test/commands/psql_validate.py | 39 | logger = logging.getLogger(__name__) | CODE |