Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
This report summarizes scanner evidence for risingwavelabs/risingwave, a Rust project with 9,366 GitHub stars. SynthScan examined 1,183,420 lines of code across 4702 source files, recording 4591 pattern matches distributed across 22 syntactic categories. The legacy adjusted pattern signal is 4.6 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 4296 finding(s).
Are imports declared and package/API names verified? 195 finding(s).
Are wrappers, guards, and repeated structures necessary? 198 finding(s).
Which changes need focused human review? 4591 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 4591 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | 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 | …tor/postgresql/PostgresStreamingChangeEventSource.java | 101 | 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 | // would be reading a binlog of a server that no longer has GTIDs. If they are enabled, | 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 |
| 3753 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | Makefile.toml | 624 | # 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/sink/lancedb/lancedb_helper.py | 47 | # Create an empty table with the defined schema | 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 |
| 106 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 | 200 | // ── Recover while job is idle / between refresh cycles. ────────────────── | COMMENT |
| MEDIUM⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 203 | // ── Second cycle: changes after recovery must still be picked up. ──────── | COMMENT |
| MEDIUM⚡ | …tion/tests/integration_tests/recovery/batch_refresh.rs | 210 | // ── Recover using meta + CN together, then run another cycle. ──────────── | COMMENT |
| MEDIUM | src/meta/src/barrier/checkpoint/control.rs | 1371 | // ── Batch refresh trigger helpers ──────────────────────────────────────── | COMMENT |
| MEDIUM | src/meta/src/barrier/checkpoint/independent_job/mod.rs | 346 | // ── Enum unifying independent checkpoint job types ────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 73 | // ── Public types ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 113 | // ── Batch refresh job metadata ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 133 | // ── Status ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 180 | // ── Complete type ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 182 | // ── Main checkpoint control ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 199 | // ── 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 | 659 | // ── Barrier injection ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 706 | // ── Barrier forwarding and collection ───────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 840 | // ── Completing ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 959 | // ── Query methods ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1081 | // ── Logstore refresh run ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er/checkpoint/independent_job/batch_refresh_job/mod.rs | 1368 | // ── 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 | 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 | 883 | // Step 1: Collect all current splits and clear their offsets | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 958 | // Step 2: Write splits back to state table with offset = None | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 964 | // 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 | 88 | // Step 1: Enable locality backfill and configure for slow background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 94 | // Step 2: Create table and populate with 10,000 rows | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 99 | // Step 3: Verify row count | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 103 | // Step 4: Create materialized view with background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 106 | // Step 5: Find the internal table names for locality provider | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 133 | // Step 7: Trigger recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 136 | // Step 8: Check internal tables after recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 149 | // Step 9: Remove rate limit and wait for completion | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 153 | // Step 10: Verify MV result | COMMENT |
| LOW | …/tests/integration_tests/recovery/locality_backfill.rs | 120 | // 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 | 979 | // Step 1: Pause the stream (already commits state) | COMMENT |
| 17 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 | |
| 86 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 | 1077 | /// 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 | 883 | // Step 1: Collect all current splits and clear their offsets | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 958 | // Step 2: Write splits back to state table with offset = None | COMMENT |
| LOW⚡ | src/stream/src/executor/source/source_executor.rs | 964 | // Step 3: Update in-memory split info with cleared offsets | COMMENT |
| LOW | src/stream/src/executor/mview/cache.rs | 494 | // 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 | 88 | // Step 1: Enable locality backfill and configure for slow background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 94 | // Step 2: Create table and populate with 10,000 rows | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 99 | // Step 3: Verify row count | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 103 | // Step 4: Create materialized view with background DDL | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 106 | // Step 5: Find the internal table names for locality provider | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 133 | // Step 7: Trigger recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 136 | // Step 8: Check internal tables after recovery | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 149 | // Step 9: Remove rate limit and wait for completion | COMMENT |
| LOW⚡ | …/tests/integration_tests/recovery/locality_backfill.rs | 153 | // Step 10: Verify MV result | COMMENT |
| LOW | …/tests/integration_tests/recovery/locality_backfill.rs | 120 | // 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 | 979 | // Step 1: Pause the stream (already commits state) | COMMENT |
| LOW⚡ | src/meta/service/src/stream_service.rs | 985 | // Step 2: Update catalog and get the new properties | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1013 | // Step 3: Issue ConnectorPropsChange barrier | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1024 | // Step 4: Optional split reset | COMMENT |
| LOW | src/meta/service/src/stream_service.rs | 1037 | // Step 5: Resume the stream (even if previous steps failed) | COMMENT |
| LOW | src/meta/src/stream/source_manager/split_assignment.rs | 553 | // 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 | 277 | // Step 2: Render actors for each ensemble. | COMMENT |
| LOW | src/meta/src/barrier/checkpoint/state.rs | 356 | // Step 3: Expand simple assignments into full StreamActor structures. | COMMENT |
| 3 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 | 89 | def check_risingwave_iceberg_source(docker): | STRING |
| LOW | ci/scripts/notify.py | 130 | def generate_test_status_message(failed_test_map): | CODE |
| LOW | ci/scripts/notify.py | 138 | 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 | 104 | def next_one_third_width_graph(self): | CODE |
| LOW | grafana/dashboard/common.py | 251 | def timeseries_actor_latency_small( | CODE |
| LOW | grafana/dashboard/common.py | 386 | 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 | docs/metrics/extract.py | 294 | def find_get_metric_name_closure(text: str, macro_start: int): | CODE |
| LOW | docs/metrics/extract.py | 312 | def resolve_labels_identifier(text: str, macro_start: int, ident: str): | CODE |
| LOW | docs/metrics/extract.py | 528 | def scan_direct_constructions(path: Path, rel: str, test_ranges): | CODE |
| LOW | docs/metrics/extract.py | 614 | def scan_error_metric_callsites(): | 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 | 158 | 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 |
| 35 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | integration_tests/iceberg-cdc/python/script/check.py | 24 | except Exception: | CODE |
| HIGH | integration_tests/scripts/run_demos.py | 58 | except Exception: | CODE |
| HIGH | integration_tests/scripts/run_demos.py | 39 | except Exception: | CODE |
| HIGH | e2e_test/check_slt_coverage.py | 491 | except UnicodeDecodeError: | CODE |
| HIGH | e2e_test/webhook/websocket_sender.py | 112 | except OSError: | CODE |
| HIGH | e2e_test/webhook/websocket_sender.py | 117 | except OSError: | CODE |
| HIGH | e2e_test/webhook/websocket_sender.py | 98 | except OSError: | CODE |
| HIGH | e2e_test/s3/file_source.py | 119 | except OSError: | CODE |
| HIGH | e2e_test/s3/file_source.py | 224 | except OSError: | CODE |
| HIGH | e2e_test/s3/file_source.py | 294 | except OSError: | CODE |
| HIGH | e2e_test/s3/refresh_full_reload_helper.py | 43 | except FileNotFoundError: | CODE |
| HIGH | e2e_test/commands/pulsar_util.py | 126 | except: | CODE |
| 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 | 66 | except Exception as e: | CODE |
| LOW | e2e_test/iceberg/main.py | 77 | except Exception as e: | CODE |
| LOW | e2e_test/iceberg/test_utils/spark_utils.py | 55 | except Exception as e: | CODE |
| LOW | e2e_test/commands/psql_refill_validate.py | 245 | except Exception as error: # Retry transient recovery and RPC failures. | 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 | 212 | # 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 |
| LOW | e2e_test/iceberg/main.py | 63 | # 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 | 1552 | // 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 | 474 | // can leverage the block cache under the hood. | COMMENT |
| MEDIUM | src/meta/src/rpc/ddl_controller.rs | 2211 | // 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 | 424 | // sql server cannot leverage the given key to narrow down the range of scan, | COMMENT |
| MEDIUM | src/connector/src/source/cdc/external/mysql.rs | 886 | // mysql cannot leverage the given key to narrow down the range of scan, | COMMENT |
| MEDIUM | src/connector/src/source/iceberg/planner.rs | 721 | /// It's deterministic so that it can best utilize the data locality. | COMMENT |
| MEDIUM | src/connector/src/source/iceberg/mod.rs | 437 | /// 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 | 1024 | "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 | …ion_tests/iceberg-source/python/rest_table_location.py | 11 | CODE | |
| 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 | 114 | CODE | |
| LOW | ci/scripts/find-regression.py | 142 | CODE | |
| LOW | java/connector-node/python-client/integration_tests.py | 119 | CODE | |
| LOW | docs/metrics/extract.py | 43 | CODE | |
| LOW | docs/metrics/extract.py | 96 | CODE | |
| LOW | docs/metrics/extract.py | 168 | CODE | |
| LOW | docs/metrics/extract.py | 312 | CODE | |
| LOW | docs/metrics/extract.py | 362 | CODE | |
| LOW | docs/metrics/extract.py | 399 | 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 | e2e_test/s3/refresh_full_reload_helper.py | 64 | CODE | |
| LOW | …e_inline/cdc/mysql/cron_only/wait_mysql_cdc_metrics.py | 18 | CODE | |
| LOW | e2e_test/iceberg/main.py | 25 | CODE | |
| LOW | e2e_test/iceberg/test_utils/test_utils.py | 73 | CODE | |
| LOW | e2e_test/iceberg/test_utils/test_utils.py | 118 | 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 | |
| LOW | .github/scripts/doc_issue_tracker.py | 242 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Makefile.toml | 321 | # Check if there is any panic in log. | COMMENT |
| LOW | Makefile.toml | 330 | # Check if there are too many duplicated lines in log. | COMMENT |
| LOW | Makefile.toml | 353 | # 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 |
|---|---|---|---|---|
| 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 | 591 | // TODO: implement pg_get_expr rather than just return empty as an workaround. | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 746 | // TODO: implement real cancel rather than just return false as an workaround. | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 750 | // TODO: implement real terminate rather than just return false as an | COMMENT |
| LOW | src/frontend/src/binder/expr/function/builtin_scalar.rs | 791 | // TODO: implement pg_sleep_until | COMMENT |
| LOW | src/meta/src/rpc/ddl_controller.rs | 340 | // 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 | 95 | /// 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 |