The Feldera Incremental Computation Engine
This report presents the forensic synthetic code analysis of feldera/feldera, a Rust project with 2,032 GitHub stars. SynthScan v2.0 examined 887,622 lines of code across 3165 source files, recording 3817 pattern matches distributed across 24 syntactic categories. The overall adjusted score of 7.0 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.
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 3817 distinct pattern matches across 24 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 |
|---|---|---|---|---|
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 19 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 21 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 28 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 30 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 40 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 44 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 54 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 56 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 62 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 64 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 69 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/nexmark.yaml | 71 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 26 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 28 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 35 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 37 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 47 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 49 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 54 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink-kafka/flink-conf.yaml | 56 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink-kafka/flink-conf.yaml | 77 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink-kafka/flink-conf.yaml | 79 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink-kafka/flink-conf.yaml | 92 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink-kafka/flink-conf.yaml | 94 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-rocksdb.yaml | 27 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-rocksdb.yaml | 29 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-rocksdb.yaml | 36 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-rocksdb.yaml | 38 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink/flink-conf-rocksdb.yaml | 49 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink/flink-conf-rocksdb.yaml | 51 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 19 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 21 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 28 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 30 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 42 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 46 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 56 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 58 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 64 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 66 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 71 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/nexmark.yaml | 73 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-hashmap.yaml | 27 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-hashmap.yaml | 29 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-hashmap.yaml | 36 | #============================================================================== | COMMENT |
| MEDIUM⚡ | benchmark/flink/flink-conf-hashmap.yaml | 38 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink/flink-conf-hashmap.yaml | 49 | #============================================================================== | COMMENT |
| MEDIUM | benchmark/flink/flink-conf-hashmap.yaml | 51 | #============================================================================== | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 261 | // ── helpers ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 272 | // ── combination generator ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 392 | // ── Recursive step ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 412 | // ── Base: all non-nullable — skip ────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 418 | // ── Base: ≥1 nullable, no const generics, wrap in Some() ────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 434 | // ── Base: ≥1 nullable, const generics present, wrap in Some() ───────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 450 | // ── Base: ≥1 nullable, no const generics, direct return ─────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 466 | // ── Base: ≥1 nullable, const generics present, direct return ────────── | COMMENT |
| MEDIUM⚡ | crates/sqllib/src/string_interner.rs | 244 | // ┌──────────┐ ┌────────────────────────┐ | COMMENT |
| MEDIUM⚡ | crates/sqllib/src/string_interner.rs | 246 | // │ ┌───┐ │ ┌───────┐by_id │ │ | COMMENT |
| MEDIUM⚡ | crates/sqllib/src/string_interner.rs | 247 | // │ │Z-1├───┼──────►│gather ├─────►│ INTERNED_STRINGS_BY_ID │ | COMMENT |
| MEDIUM⚡ | crates/sqllib/src/string_interner.rs | 248 | // │ └──┬┘ │ └───────┘ │ CURRENT_STEP │ | COMMENT |
| 448 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 121 | # - 5b35c098 "delta-rs: round-robin pre-split unpartitioned scans into | COMMENT |
| LOW | benchmark/flink-kafka/nexmark.yaml | 1 | ################################################################################ | COMMENT |
| LOW | benchmark/flink-kafka/nexmark.yaml | 21 | #============================================================================== | COMMENT |
| LOW | benchmark/flink-kafka/flink-conf.yaml | 1 | ################################################################################ | COMMENT |
| LOW | benchmark/flink-kafka/run-nexmark.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | benchmark/flink-kafka/config.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | benchmark/flink/flink-conf-rocksdb.yaml | 1 | ################################################################################ | COMMENT |
| LOW | benchmark/flink/nexmark.yaml | 1 | ################################################################################ | COMMENT |
| LOW | benchmark/flink/nexmark.yaml | 41 | COMMENT | |
| LOW | benchmark/flink/run.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | benchmark/flink/config.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | benchmark/flink/flink-conf-hashmap.yaml | 1 | ################################################################################ | COMMENT |
| LOW | benchmark/feldera-sql/run.py | 1 | #! /usr/bin/python3 | COMMENT |
| LOW | sql-to-dbsp-compiler/temp/src/stubs.rs | 1 | // Compiler-generated file. | COMMENT |
| LOW | …g/dbsp/sqlCompiler/compiler/sql/tools/TableParser.java | 501 | } | COMMENT |
| LOW | …lCompiler/compiler/sql/simple/ArrayFunctionsTests.java | 1121 | select array_insert(array(1, 2, 3), 3, cast(null as tinyint)); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1161 | // Before this step: waterline = minimum, table is empty. | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1201 | // ts | uid | | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1301 | a | 2 | 2020-01-01 11:50:00 | 2020-01-01 12:05:00 | 1"""); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1361 | // ----+-----+ | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1541 | 2 | 200 | 1"""); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1581 | // Before this step, table contents: | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1621 | 2 | 1000 | 0 | 1 | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1701 | ts | v | weight | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1721 | // 0 | 1 | GC'd | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1741 | ts | v | weight | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1801 | // id | ts | extra | | COMMENT |
| LOW | …iler/compiler/sql/postgres/PostgresTimestampTests.java | 41 | import org.junit.Test; | COMMENT |
| LOW | …iler/compiler/sql/postgres/PostgresTimestampTests.java | 221 | } | COMMENT |
| LOW | …iler/compiler/sql/postgres/PostgresTimestampTests.java | 581 | // interval, | COMMENT |
| LOW | …lCompiler/compiler/sql/postgres/PostgresDateTests.java | 141 | new DBSPZSetExpression(Linq.map(results, | COMMENT |
| LOW | …lCompiler/compiler/sql/postgres/PostgresDateTests.java | 161 | // | COMMENT |
| LOW | …lCompiler/compiler/sql/postgres/PostgresDateTests.java | 181 | // Two days | COMMENT |
| LOW | …lCompiler/compiler/sql/postgres/PostgresBoolTests.java | 61 | // ERROR: invalid input syntax for type boolean: "test" | COMMENT |
| LOW | …piler/compiler/sql/postgres/PostgresIntervalTests.java | 81 | //"SELECT INTERVAL '1.5' MONTHS AS \"One month 15 days\";\n" + | COMMENT |
| LOW | …ava/org/dbsp/sqlCompiler/ir/expression/DBSPOpcode.java | 101 | // Yet another way to compare, used in controlled filters after a waterline | COMMENT |
| LOW | …ler/circuit/operator/DBSPConcreteAsofJoinOperator.java | 61 | // join: F, | COMMENT |
| LOW | …qlCompiler/compiler/visitors/inner/ExpressionsCSE.java | 41 | // |t_1: &Tup3<i32?, i32?, i32?>| | COMMENT |
| LOW | …piler/visitors/monotone/MonotoneTransferFunctions.java | 301 | new DBSPLetStatement(expression.parameters[0].getName(), | COMMENT |
| LOW | …er/compiler/frontend/aggregates/LeadLagAggregates.java | 81 | inputVar.deref().applyClone()); | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 341 | COMMENT | |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 1881 | COMMENT | |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2001 | private static class GreatestConvertlet implements SqlRexConvertlet { | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2061 | // to | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2141 | // value | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2161 | // THEN start + length(value) + 1 | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2481 | @Override public RexNode convertCall(SqlRexContext cx, SqlCall call) { | COMMENT |
| LOW | …piler/compiler/backend/rust/BaseRustCodeGenerator.java | 81 | #![allow(non_snake_case)] | COMMENT |
| LOW | sql-to-dbsp-compiler/slt/skip.txt | 1 | // This file contains a list of buggy tests to skip | COMMENT |
| LOW | crates/sqllib/src/casts.rs | 981 | Exact(usize), | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 241 | /// | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 381 | /// State carried through `@step`: | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 761 | Some([<$func_name _ $short_name _ $short_name>] $(:: < $($var),* >)? (arg0, arg1)) | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 1401 | #[doc(hidden)] | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 1421 | /// initializers we actually always use static constant values to, but | COMMENT |
| LOW | crates/sqllib/src/lib.rs | 1441 | /// catalog: &mut Catalog, | COMMENT |
| LOW | crates/sqllib/src/string_interner.rs | 101 | /// from the list strings pinned >= 2 steps ago. | COMMENT |
| LOW | crates/sqllib/src/string_interner.rs | 121 | COMMENT | |
| LOW | crates/sqllib/src/string_interner.rs | 241 | /// is going to schedule the interner circuit to run before all existing inputs. | COMMENT |
| LOW | crates/sqllib/src/flat_variant.rs | 1 | //! FlatVariant: a flat-buffer implementation of the SQL VARIANT type. | COMMENT |
| 1635 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …ava/org/dbsp/sqlCompiler/compiler/sql/ParserTests.java | 0 | create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x); | STRING |
| HIGH | …er/compiler/sql/simple/IncrementalRegressionTests.java | 0 | create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x); | STRING |
| HIGH | …org/dbsp/sqlCompiler/compiler/sql/MultiCrateTests.java | 0 | create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x); | STRING |
| HIGH | …/sqlCompiler/compiler/sql/simple/Regression2Tests.java | 0 | create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x); | STRING |
| HIGH | …org/dbsp/sqlCompiler/compiler/sql/MultiCrateTests.java | 0 | declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1; | STRING |
| HIGH | …/compiler/sql/recursive/IncrementalRecursiveTests.java | 0 | declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1; | STRING |
| HIGH | …sqlCompiler/compiler/sql/recursive/RecursiveTests.java | 0 | declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1; | STRING |
| HIGH | …dbsp/sqlCompiler/compiler/sql/simple/TinyintTests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::float | STRING |
| HIGH | …lCompiler/compiler/sql/postgres/PostgresInt4Tests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::float | STRING |
| HIGH | …lCompiler/compiler/sql/postgres/PostgresInt2Tests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::float | STRING |
| HIGH | …dbsp/sqlCompiler/compiler/sql/simple/TinyintTests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5: | STRING |
| HIGH | …lCompiler/compiler/sql/postgres/PostgresInt4Tests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5: | STRING |
| HIGH | …lCompiler/compiler/sql/postgres/PostgresInt2Tests.java | 0 | select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5: | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_max_append.py | 0 | create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) as | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_max.py | 0 | create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) as | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_max.py | 0 | create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) as | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_max_append.py | 0 | create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) as | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_max_append.py | 0 | create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_max.py | 0 | create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_max.py | 0 | create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_max_append.py | 0 | create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_max_append.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_max.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_min_append.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_min.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_min.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_min_append.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_max.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_max_append.py | 0 | create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as c | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_max_append.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_max.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_min_append.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_min.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_min.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_min_append.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_max.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_max_append.py | 0 | create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, | STRING |
| HIGH | …untime_aggtest/aggregate_tests5/test_arg_max_append.py | 0 | create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max( | STRING |
| HIGH | …/tests/runtime_aggtest/aggregate_tests/test_arg_max.py | 0 | create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max( | STRING |
| HIGH | …untime_aggtest/aggregate_tests3/test_un_int_arg_max.py | 0 | create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max( | STRING |
| HIGH | …aggtest/aggregate_tests6/test_un_int_arg_max_append.py | 0 | create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max( | STRING |
| HIGH | …ime_aggtest/aggregate_tests5/test_atbl_charn_append.py | 0 | create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_ | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests2/test_atbl_charn.py | 0 | create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_ | STRING |
| HIGH | …s/runtime_aggtest/aggregate_tests4/test_atbl_charn4.py | 0 | create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_ | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests5/test_max_append.py | 0 | create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5 | STRING |
| HIGH | …thon/tests/runtime_aggtest/aggregate_tests/test_max.py | 0 | create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5 | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests3/test_un_int_max.py | 0 | create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5 | STRING |
| HIGH | …ime_aggtest/aggregate_tests6/test_un_int_max_append.py | 0 | create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5 | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests5/test_max_append.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …thon/tests/runtime_aggtest/aggregate_tests/test_max.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests5/test_min_append.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …thon/tests/runtime_aggtest/aggregate_tests/test_min.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests3/test_un_int_min.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ime_aggtest/aggregate_tests6/test_un_int_min_append.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests3/test_un_int_sum.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …time_aggtest/aggregate_tests3/test_un_int_count_col.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests3/test_un_int_avg.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ts/runtime_aggtest/aggregate_tests3/test_un_int_max.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ime_aggtest/aggregate_tests6/test_un_int_max_append.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| HIGH | …ime_aggtest/aggregate_tests3/test_un_int_stddev_pop.py | 0 | create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) | STRING |
| 98 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/tests/utils.py | 480 | def ensure_delta_spark_fixture( | CODE |
| LOW | python/tests/unit/test_stats.py | 17 | def test_commit_progress_absent_when_no_transaction(): | CODE |
| LOW | python/tests/unit/test_stats.py | 22 | def test_commit_progress_parsed_into_object(): | CODE |
| LOW | python/tests/unit/test_stats.py | 39 | def test_commit_progress_str_matches_rust_display_format(): | CODE |
| LOW | python/tests/unit/test_stats.py | 55 | def test_progress_summary_falls_back_to_record_counts_outside_transaction(): | CODE |
| LOW | python/tests/unit/test_stats.py | 60 | def test_progress_summary_prefers_commit_progress_during_transaction(): | CODE |
| LOW | python/tests/unit/test_tags.py | 6 | def test_display_name_strips_color_suffix(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 26 | def test_normalize_sorts_lexicographically(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 30 | def test_normalize_is_idempotent(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 39 | def test_normalize_collapses_color_variants_keeping_last(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 47 | def test_normalize_preserves_color_of_survivor(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 53 | def test_normalize_distinct_names_with_colors_all_kept(): | CODE |
| LOW⚡ | python/tests/unit/test_tags.py | 62 | def test_normalize_accepts_any_iterable(): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 33 | def test_no_warning_before_threshold(self, caplog): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 39 | def test_warning_after_threshold(self, caplog): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 46 | def test_threshold_doubles_after_each_warning(self, caplog): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 56 | def test_done_is_noop_if_never_warned(self, caplog): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 63 | def test_done_logs_if_previously_warned(self, caplog): | CODE |
| LOW⚡ | python/tests/unit/test_long_operation_warning.py | 71 | def test_done_without_done_message_is_silent(self, caplog): | CODE |
| LOW | python/tests/unit/test_long_operation_warning.py | 86 | def test_uses_configured_level(self, caplog): | CODE |
| LOW | python/tests/unit/test_long_operation_warning.py | 93 | def test_default_level_is_visible_at_info(self, caplog): | CODE |
| LOW | python/tests/unit/test_github_oidc_token_retry.py | 56 | def test_does_not_retry_non_transient_status(self): | CODE |
| LOW | python/tests/unit/test_github_oidc_token_retry.py | 73 | def test_exhausts_retries_and_raises(self): | CODE |
| LOW | python/tests/unit/test_github_oidc_token_retry.py | 89 | def test_retries_on_connection_error(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 132 | def test_status_codes_are_coerced_to_frozenset(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 137 | def test_config_default_retry_config(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 140 | def test_config_uses_custom_retry_config(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 227 | def test_timeout_exhausts_raises_timeout_error(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 234 | def test_get_connection_error_then_success(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 244 | def test_get_connection_error_exhausts_raises_wrapped(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 253 | def test_post_connection_error_is_not_retried(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 262 | def test_post_marked_idempotent_retries_connection_error(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 271 | def test_get_marked_not_idempotent_skips_connection_error_retry(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 303 | def test_no_retries_when_max_retries_zero(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 310 | def test_custom_retry_config_uses_its_limit(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 319 | def test_deadline_lifts_attempt_cap(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 328 | def test_deadline_expiry_stops_retrying(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 494 | def test_stop_pipeline_posts_idempotent(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 499 | def test_pause_pipeline_posts_idempotent(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 504 | def test_delete_pipeline_deletes_idempotent(self): | CODE |
| LOW⚡ | python/tests/unit/test_httprequests_retry.py | 511 | def test_passes_retry_config_through(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 172 | def test_other_retryable_statuses(self, status): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 206 | def test_timeout_then_success(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 215 | def test_connect_timeout_is_retried(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 347 | def test_retry_after_header_is_honored(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 362 | def test_retry_after_capped_at_max_backoff(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 378 | def test_retry_after_http_date_is_parsed(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 397 | def test_backoff_grows_as_documented(self): | CODE |
| LOW | python/tests/unit/test_httprequests_retry.py | 415 | def test_jitter_adds_uniform_extra(self): | CODE |
| LOW | python/tests/unit/test_query_as_arrow.py | 38 | def test_non_empty_result_yields_correct_data(self, client: FelderaClient): | CODE |
| LOW | python/tests/unit/test_query_as_arrow.py | 52 | def test_http_called_with_correct_params(self, client: FelderaClient): | CODE |
| LOW | python/tests/unit/test_query_as_arrow.py | 69 | def test_empty_result_yields_no_batches(self, client: FelderaClient): | CODE |
| LOW | python/tests/unit/test_query_as_arrow.py | 86 | def test_response_closed_after_full_consumption(self, client: FelderaClient): | CODE |
| LOW | python/tests/unit/test_query_as_arrow.py | 98 | def test_query_arrow_delegates_to_client(self): | CODE |
| LOW⚡ | python/tests/unit/test_callable_api_key.py | 72 | def test_static_key_used_verbatim(self): | CODE |
| LOW⚡ | python/tests/unit/test_callable_api_key.py | 75 | def test_callable_invoked_and_stripped(self): | CODE |
| LOW⚡ | python/tests/unit/test_callable_api_key.py | 78 | def test_non_str_callable_raises(self): | CODE |
| LOW⚡ | python/tests/unit/test_callable_api_key.py | 82 | def test_callable_invoked_per_request(self): | CODE |
| LOW | python/tests/unit/test_callable_api_key.py | 121 | def test_cluster_health_probe_sends_bearer(self): | CODE |
| LOW | python/tests/platform/test_output_buffer_checkpoint.py | 35 | def test_output_buffer_does_not_stall_checkpoint(pipeline_name): | CODE |
| 515 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | crates/iceberg/src/test/create_test_table_s3.py | 7 | CODE | |
| LOW | crates/iceberg/src/test/create_test_table_s3.py | 7 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 4 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/__init__.py | 13 | CODE | |
| LOW | python/tests/utils.py | 15 | CODE | |
| LOW | python/tests/stop_ci_run_pipelines.py | 28 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 3 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 6 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 7 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 8 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 9 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 10 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 11 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 12 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 13 | CODE | |
| LOW | python/tests/runtime_aggtest/illarg_tests/main.py | 14 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 1 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 2 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 3 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 4 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 5 | CODE | |
| LOW | …n/tests/runtime_aggtest/aggregate_tests5/test_table.py | 6 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 4 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 7 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 8 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 9 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 10 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 11 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 12 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 13 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 14 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 15 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 16 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 17 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 18 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 19 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 20 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 21 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 22 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 23 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 24 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 25 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 26 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 27 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 28 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 29 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 30 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 31 | CODE | |
| 384 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | …s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py | 626 | bin || bin AS bin, | CODE |
| HIGH⚡ | …s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py | 627 | str || str AS str | CODE |
| HIGH⚡ | …s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py | 637 | intt || intt AS intt | CODE |
| HIGH⚡ | …s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py | 647 | roww || roww AS roww | CODE |
| HIGH | …ts/runtime_aggtest/illarg_tests/test_str_unicode_fn.py | 385 | str || str AS str | CODE |
| HIGH | …sts/runtime_aggtest/variant_tests/dtype_and_variant.py | 790 | "roww_varnt": '{"int":null,"var":null}', | CODE |
| HIGH⚡ | …/unsigned_int_tests/test_un_int_supported_functions.py | 632 | tiny_int || tiny_int AS tiny_int, | CODE |
| HIGH⚡ | …/unsigned_int_tests/test_un_int_supported_functions.py | 633 | small_int || small_int AS small_int, | CODE |
| HIGH⚡ | …/unsigned_int_tests/test_un_int_supported_functions.py | 634 | intt || intt AS intt, | CODE |
| HIGH⚡ | …/unsigned_int_tests/test_un_int_supported_functions.py | 635 | big_int || big_int AS big_int | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 609 | "CREATE TABLE t1(id bigint not null, s varchar not null); " | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 661 | "id1 bigint not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 662 | "id2 bigint not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 663 | "str1 varchar not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 665 | "int1 bigint not null," | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 809 | # Expect 3 events: delete (id2=1 id1=2 old str2=foo), delete (id1=3...), insert (id1=2 updated str2 null) | COMMENT |
| HIGH | python/tests/platform/test_ingress_formats.py | 382 | '{"id":1,"v":{"name":"Bob","scores":[1,2.5,null],"ok":true}}\n' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 386 | '{"id":5,"v":null}', | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 483 | 'CREATE TABLE t1("c1" integer not null,"C2" bool not null,"😁❤" varchar not null,' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 484 | "\"αβγ\" boolean not null, ΔΘ boolean not null) WITH ('materialized'='true');" | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 506 | sql = "CREATE TABLE t1(id bigint not null, s varchar not null, primary key(id)) " | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 553 | 'CREATE TABLE "TaBle1"(id bigint not null);' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 801 | '{"update":{"id1":2,"id2":1,"str2":null}},' | CODE |
| HIGH | python/tests/runtime/test_postprocessor.py | 126 | result.push(b'\n'); | CODE |
| HIGH | python/tests/runtime/test_clock_advance.py | 10 | * `advance(null)`: advance by one `clock_resolution`, | STRING |
| HIGH | python/tests/runtime/test_clock_advance.py | 39 | # Clock resolution configured below; `advance(null)` moves NOW() by this much. | COMMENT |
| HIGH | python/tests/runtime/test_clock_advance.py | 71 | # and `advance(null)` moves NOW() by exactly this much. | COMMENT |
| HIGH | python/tests/runtime/test_clock_advance.py | 92 | # advance(null) advances by exactly one clock_resolution. | COMMENT |
| HIGH | python/tests/runtime/test_adhoc_queries.py | 28 | CREATE TABLE not_materialized(id bigint not null); | CODE |
| HIGH | python/tests/runtime/test_adhoc_queries.py | 282 | """CREATE TABLE "TaBle1"(id bigint not null) WITH ('materialized' = 'true');""" | STRING |
| HIGH | scripts/dummy_oidc.py | 605 | # answering null, so drop the empty entries. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …iler/compiler/frontend/aggregates/RangeAggregates.java | 108 | // NOTE: This function requires the arguments to be positive | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/integral_weight_validator.rs | 104 | // Step 0: insert key 42 with weight +1 → weight 1. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/integral_weight_validator.rs | 105 | // Step 1: delete key 42 with weight -2 → weight -1 (panic). | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/input.rs | 1745 | // Step 2: repeat with one more additional key. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 485 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 507 | // Step 2: Recompute all row numbers from the current position onward. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/group/rank.rs | 581 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/group/rank.rs | 591 | // Step 2: Find the first value with rank R0 and step forward from it to compute | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/rank.rs | 625 | // Step 3: Recompute all ranks from the current position onward. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1222 | // Step 0: add edges 1->2, 2->3; mark 2 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1227 | // Step 1: extend chain with 3->4; mark 3 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1229 | // Step 2: extend chain with 4->5; mark 4 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1231 | // Step 3: remove key point 3 (paths via 3 should disappear). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1233 | // Step 4: remove edge 2->3 (breaks the original chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1235 | // Step 5: add shortcut edge 2->5 (bypasses missing 3->4). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1237 | // Step 6: add 5->6 and mark 5,6 as key points. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1239 | // Step 7: add edge 6->2 (introduce a cycle). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1241 | // Step 8: remove key point 2 (cycle still exists but via non-key). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1243 | // Step 9: remove edge 6->2 and key point 5 (break cycle, shrink keys). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1245 | // Step 10: re-add key point 2 and edge 2->3 (restore part of chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1247 | // Step 11: re-add key point 3 and edge 3->4 (chain continues again). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1249 | // Step 12: add new branch 3->7 and mark 7 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1251 | // Step 13: add edge 7->5 (reconnect branch to existing node). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1253 | // Step 14: add edge 5->8 and mark 8 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1255 | // Step 15: remove edge 2->5 (drop the shortcut). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1257 | // Step 16: remove key point 4 (paths via 4 should drop). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1259 | // Step 17: add edge 8->2 (new cycle through 8). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1261 | // Step 18: remove edge 7->5 (break branch reconnection). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1263 | // Step 19: remove key point 7 and edge 8->2 (collapse new cycle). | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 2790 | // Step 1: two appends => two parquet files, one Delta version each. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 2795 | // Step 2: OPTIMIZE coalesces the two files into one. Every action has | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 2818 | // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching file | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 2841 | // Step 4: real change. CDC tables encode an in-place row update as a | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1129 | // Step 1: insert a couple of values. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1149 | // Step 2: replace an entry. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1166 | // Step 3: delete an entry. | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 779 | # Step 2: Create checkpoint and sync | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 783 | # Step 3: Start standby pipeline | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1035 | # Step 1: push a checkpoint to the source pipeline (becomes read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1111 | # Step 1: create the source pipeline (becomes read_bucket for standby). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1295 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1380 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1540 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 757 | # Step 1: Start main pipeline | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 804 | # Step 4: Add more data and make 3-10 checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 826 | # Step 5: Stop main and activate standby | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 837 | # Step 6: Validate standby has all expected records | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 942 | # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 967 | # Step 2: start the main pipeline with an empty bucket and read_bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1055 | # Step 2: push a checkpoint to the main pipeline's own bucket. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1075 | # Step 3: restart with both bucket (has main data) and read_bucket (has | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1131 | # Step 2: start the main pipeline; it will push newer checkpoints to | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1144 | # Step 3: start the standby pipeline with empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1166 | # Step 4: main pipeline inserts data and pushes multiple checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1184 | # Step 5: activate standby — it should have tracked the latest bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1315 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1341 | # Step 3: restart with start_from=latest, empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1400 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1430 | # Step 3: restart with the local UUID and read_bucket configured. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1560 | # Step 2: main pipeline creates and syncs its own checkpoint. | COMMENT |
| 31 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | crates/iceberg/src/test/create_test_table_s3.py | 79 | print("Error: AWS_ACCESS_KEY_ID is not set") | CODE |
| MEDIUM | crates/iceberg/src/test/create_test_table_s3.py | 83 | print("Error: AWS_SECRET_ACCESS_KEY is not set") | CODE |
| LOW | crates/iceberg/src/test/follow_table.py | 129 | except Exception: | CODE |
| LOW | crates/iceberg/src/test/follow_table.py | 133 | except Exception: | CODE |
| LOW | python/tests/utils.py | 423 | except Exception: | CODE |
| LOW | python/tests/utils.py | 427 | except Exception: | CODE |
| LOW | python/tests/stop_ci_run_pipelines.py | 79 | except Exception as error: | CODE |
| LOW | python/tests/kafka.py | 36 | except Exception: | CODE |
| LOW | python/tests/runtime_aggtest/aggtst_base.py | 303 | except Exception as e: | CODE |
| LOW | python/tests/runtime_aggtest/aggtst_base.py | 382 | except Exception as e: | CODE |
| LOW | python/tests/platform/test_pipeline_env.py | 20 | except Exception as e: | CODE |
| LOW | python/tests/platform/negative_test.py | 76 | except Exception: | CODE |
| LOW | python/tests/platform/negative_test.py | 116 | except Exception: | CODE |
| LOW | python/tests/platform/test_bootstrapping.py | 73 | except Exception as e: | STRING |
| LOW | python/tests/platform/test_bootstrapping.py | 641 | except Exception as e: | STRING |
| LOW | python/tests/platform/test_bootstrapping.py | 685 | except Exception as e: | STRING |
| LOW | python/tests/platform/test_bootstrapping.py | 730 | except Exception as e: | STRING |
| MEDIUM | python/tests/platform/test_checkpoint_sync.py | 297 | def checkpoint_sync_completed() -> bool: | CODE |
| LOW | python/tests/platform/test_checkpoint_sync.py | 57 | except Exception as e: | CODE |
| LOW | python/tests/platform/test_checkpoint_sync.py | 995 | except Exception: | CODE |
| LOW | python/tests/platform/test_cluster_health.py | 29 | except Exception: | CODE |
| LOW | python/tests/platform/test_cluster_health.py | 76 | except Exception: | CODE |
| LOW | python/tests/platform/test_ingress_formats.py | 148 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/tests/platform/test_ingress_formats.py | 184 | except Exception as e: | CODE |
| LOW | python/tests/runtime/test_checkpoint_runtime_upgrade.py | 368 | except Exception as e: | CODE |
| LOW | python/tests/runtime/test_adhoc_queries.py | 210 | except Exception: | STRING |
| LOW | python/tests/workloads/test_jsonbench.py | 509 | except Exception as e: | CODE |
| LOW | python/tests/workloads/test_tpch.py | 1566 | except Exception as e: | CODE |
| LOW | python/tests/workloads/test_tpch.py | 1585 | except Exception as e: | CODE |
| LOW⚡ | python/tests/workloads/test_kafka_avro.py | 46 | except Exception as e: | CODE |
| LOW | python/tests/workloads/test_kafka_avro.py | 104 | except Exception as e: | CODE |
| LOW | python/tests/workloads/test_kafka_avro.py | 139 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 127 | except Exception: | CODE |
| LOW⚡ | python/feldera/testutils.py | 358 | except Exception as error: | CODE |
| LOW⚡ | python/feldera/testutils.py | 363 | except Exception as error: | CODE |
| LOW⚡ | python/feldera/testutils.py | 369 | except Exception as error: | CODE |
| LOW | python/feldera/testutils.py | 452 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 657 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 675 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 689 | except Exception as e: | CODE |
| LOW⚡ | python/feldera/testutils_oidc.py | 136 | except Exception: | CODE |
| LOW⚡ | python/feldera/testutils_oidc.py | 145 | except Exception: | CODE |
| LOW | python/feldera/testutils_oidc.py | 204 | except Exception as e: | CODE |
| LOW | python/feldera/testutils_oidc.py | 364 | except Exception as e: | CODE |
| LOW | python/feldera/rest/_httprequests.py | 111 | except Exception as e: | CODE |
| LOW | python/feldera/rest/errors.py | 73 | except Exception: | CODE |
| LOW | python/feldera/rest/feldera_client.py | 128 | except Exception as e: | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 212 | except Exception as exc: | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 224 | except Exception as exc: | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 231 | except Exception as exc: | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 296 | except Exception as exc: | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 449 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/integration_tests/conftest.py | 46 | except Exception: | CODE |
| LOW | python/dbt-feldera/integration_tests/conftest.py | 74 | except Exception: | CODE |
| LOW | python/dbt-feldera/integration_tests/conftest.py | 138 | except Exception: | CODE |
| LOW | python/dbt-feldera/integration_tests/docker_duckdb.py | 154 | except Exception: | CODE |
| LOW | python/dbt-feldera/integration_tests/docker_duckdb.py | 217 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/connections.py | 59 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/connections.py | 119 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 176 | except Exception as exc: | CODE |
| 42 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | crates/dbsp/src/operator/integral_weight_validator.rs | 104 | // Step 0: insert key 42 with weight +1 → weight 1. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/integral_weight_validator.rs | 105 | // Step 1: delete key 42 with weight -2 → weight -1 (panic). | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/input.rs | 1719 | // Step 1: | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/input.rs | 1745 | // Step 2: repeat with one more additional key. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 485 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 507 | // Step 2: Recompute all row numbers from the current position onward. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/group/rank.rs | 581 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/group/rank.rs | 591 | // Step 2: Find the first value with rank R0 and step forward from it to compute | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/rank.rs | 625 | // Step 3: Recompute all ranks from the current position onward. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1222 | // Step 0: add edges 1->2, 2->3; mark 2 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1227 | // Step 1: extend chain with 3->4; mark 3 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1229 | // Step 2: extend chain with 4->5; mark 4 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1231 | // Step 3: remove key point 3 (paths via 3 should disappear). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1233 | // Step 4: remove edge 2->3 (breaks the original chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1235 | // Step 5: add shortcut edge 2->5 (bypasses missing 3->4). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1237 | // Step 6: add 5->6 and mark 5,6 as key points. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1239 | // Step 7: add edge 6->2 (introduce a cycle). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1241 | // Step 8: remove key point 2 (cycle still exists but via non-key). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1243 | // Step 9: remove edge 6->2 and key point 5 (break cycle, shrink keys). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1245 | // Step 10: re-add key point 2 and edge 2->3 (restore part of chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1247 | // Step 11: re-add key point 3 and edge 3->4 (chain continues again). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1249 | // Step 12: add new branch 3->7 and mark 7 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1251 | // Step 13: add edge 7->5 (reconnect branch to existing node). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1253 | // Step 14: add edge 5->8 and mark 8 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1255 | // Step 15: remove edge 2->5 (drop the shortcut). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1257 | // Step 16: remove key point 4 (paths via 4 should drop). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1259 | // Step 17: add edge 8->2 (new cycle through 8). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1261 | // Step 18: remove edge 7->5 (break branch reconnection). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1263 | // Step 19: remove key point 7 and edge 8->2 (collapse new cycle). | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 2790 | // Step 1: two appends => two parquet files, one Delta version each. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 2795 | // Step 2: OPTIMIZE coalesces the two files into one. Every action has | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 2818 | // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching file | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 2841 | // Step 4: real change. CDC tables encode an in-place row update as a | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1129 | // Step 1: insert a couple of values. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1149 | // Step 2: replace an entry. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1166 | // Step 3: delete an entry. | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 779 | # Step 2: Create checkpoint and sync | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 783 | # Step 3: Start standby pipeline | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1035 | # Step 1: push a checkpoint to the source pipeline (becomes read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1111 | # Step 1: create the source pipeline (becomes read_bucket for standby). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1295 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1380 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1540 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 757 | # Step 1: Start main pipeline | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 804 | # Step 4: Add more data and make 3-10 checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 826 | # Step 5: Stop main and activate standby | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 837 | # Step 6: Validate standby has all expected records | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 942 | # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 967 | # Step 2: start the main pipeline with an empty bucket and read_bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1055 | # Step 2: push a checkpoint to the main pipeline's own bucket. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1075 | # Step 3: restart with both bucket (has main data) and read_bucket (has | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1131 | # Step 2: start the main pipeline; it will push newer checkpoints to | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1144 | # Step 3: start the standby pipeline with empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1166 | # Step 4: main pipeline inserts data and pushes multiple checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1184 | # Step 5: activate standby — it should have tracked the latest bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1315 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1341 | # Step 3: restart with start_from=latest, empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1400 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1430 | # Step 3: restart with the local UUID and read_bucket configured. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1560 | # Step 2: main pipeline creates and syncs its own checkpoint. | COMMENT |
| 1 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …sp/sqlCompiler/ir/type/primitive/DBSPTypeBaseType.java | 44 | && org.dbsp.sqlCompiler.compiler.VariantMode.isEnabled()) | CODE |
| CRITICAL | …sp/sqlCompiler/ir/type/primitive/DBSPTypeBaseType.java | 51 | && org.dbsp.sqlCompiler.compiler.VariantMode.isEnabled()) | CODE |
| CRITICAL | …g/dbsp/sqlCompiler/circuit/annotation/Annotations.java | 30 | Annotation anno = org.dbsp.sqlCompiler.circuit.annotation.Annotation.fromJson(annotation); | CODE |
| CRITICAL | …mpiler/frontend/calciteCompiler/RenameIdentifiers.java | 199 | return new org.dbsp.sqlCompiler.compiler.frontend.parser.SqlCreateTable( | CODE |
| CRITICAL | crates/dbsp/src/trace/ord/file/key_batch.rs | 438 | time: self.batch.factories.factories1.key_factory.default_box(), | CODE |
| CRITICAL | crates/dbsp/src/trace/ord/vec/val_batch.rs | 678 | let mut times = factories.layer_factories.child.child.keys.default_box(); | CODE |
| CRITICAL | crates/dbsp/src/trace/ord/vec/val_batch.rs | 681 | let mut diffs = factories.layer_factories.child.child.diffs.default_box(); | CODE |
| CRITICAL | crates/adapters/src/controller.rs | 1360 | .with_product(self.inner.status.pipeline_config.given_name.as_ref()) | CODE |
| CRITICAL | crates/adapters/src/controller.rs | 8456 | if self.status.pipeline_config.global.storage.is_none() { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | openapi.json | 5 | "description": "\nWith Feldera, users create data pipelines out of SQL programs.\nA SQL program comprises tables and | CODE |
| MEDIUM | …Compiler/compiler/sql/tools/CompilerCircuitStream.java | 138 | // not very robust | COMMENT |
| MEDIUM | …piler/visitors/outer/intern/RewriteInternedFields.java | 401 | // Essentially an identity function | COMMENT |
| MEDIUM | …piler/visitors/outer/intern/RewriteInternedFields.java | 414 | // Essentially an identity function | COMMENT |
| MEDIUM | crates/sqllib/src/float.rs | 470 | /// This is used to make tests involving FP values more robust; instead | COMMENT |
| MEDIUM | crates/sqllib/src/float.rs | 494 | /// This is used to make tests involving FP values more robust; instead | COMMENT |
| MEDIUM | crates/dbsp/src/circuit/circuit_builder.rs | 1450 | /// To leverage such optimizations, we adopt the best-effort approach: operators | COMMENT |
| MEDIUM | …dbsp/src/operator/dynamic/aggregate/chain_aggregate.rs | 321 | /// This design is robust against clock going back, clock input missing in some steps (e.g., in the middle of a tran | COMMENT |
| MEDIUM | crates/adapters/src/util.rs | 713 | // making the test robust against timing and scheduling variations. | COMMENT |
| MEDIUM | crates/adapters/src/server/stack_overflow_backtrace.rs | 75 | /// PRs to make this more robust are welcome | COMMENT |
| MEDIUM | crates/adapters/src/integrated/delta_table/input.rs | 106 | /// so the check is robust to the deeply nested errors DataFusion typically | COMMENT |
| MEDIUM | crates/adapters/src/integrated/postgres/cdc_input.rs | 1642 | // deterministic, just less robust to URI format variations. | COMMENT |
| MEDIUM | crates/fxp/src/fixed.rs | 747 | // Definitely does not fit. | COMMENT |
| MEDIUM | crates/rest-api/openapi.json | 5 | "description": "\nWith Feldera, users create data pipelines out of SQL programs.\nA SQL program comprises tables and | CODE |
| MEDIUM | python/tests/utils.py | 388 | # Bare (scheme-less) table path: the Rust FS harness reads tables | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | benchmark/feldera-sql/run.py | 27 | CODE | |
| LOW | benchmark/feldera-sql/run.py | 82 | CODE | |
| LOW | benchmark/feldera-sql/run.py | 232 | CODE | |
| LOW | python/tests/runtime_aggtest/aggtst_base.py | 256 | CODE | |
| LOW | python/tests/runtime_aggtest/atest_register_tests.py | 8 | CODE | |
| LOW | …n/tests/runtime_aggtest/orderby_tests/sqlite_runner.py | 127 | CODE | |
| LOW | python/tests/platform/test_cluster_health.py | 55 | CODE | |
| LOW | python/tests/platform/test_ingress_formats.py | 164 | CODE | |
| LOW | python/tests/platform/test_orchestration.py | 216 | CODE | |
| LOW | python/tests/platform/test_orchestration.py | 309 | CODE | |
| LOW | python/tests/workloads/test_jsonbench.py | 186 | CODE | |
| LOW | python/tests/workloads/test_tpch.py | 1467 | CODE | |
| LOW | python/tests/workloads/test_tpch.py | 31 | CODE | |
| LOW | python/tests/workloads/test_kafka_avro.py | 27 | CODE | |
| LOW | python/tests/workloads/test_kafka_avro.py | 404 | CODE | |
| LOW | python/feldera/_helpers.py | 65 | CODE | |
| LOW | python/feldera/rest/_httprequests.py | 189 | CODE | |
| LOW | python/feldera/rest/feldera_client.py | 184 | CODE | |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 167 | CODE | |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 608 | CODE | |
| LOW | python/dbt-feldera/dbt/adapters/feldera/cursor.py | 97 | CODE | |
| LOW | …n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py | 266 | CODE | |
| LOW | …n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py | 407 | CODE | |
| LOW | python/felderize/felderize/docs.py | 143 | CODE | |
| LOW | python/felderize/felderize/docs.py | 186 | CODE | |
| LOW | python/felderize/felderize/docs.py | 215 | CODE | |
| LOW | python/felderize/felderize/docs.py | 323 | CODE | |
| LOW | scripts/scalebench.py | 113 | CODE | |
| LOW | scripts/scalebench.py | 344 | CODE | |
| LOW | scripts/scalebench.py | 356 | CODE | |
| LOW | scripts/scalebench.py | 396 | CODE | |
| LOW | scripts/scalebench.py | 624 | CODE | |
| LOW | scripts/dashboard.py | 589 | CODE | |
| LOW | scripts/dashboard.py | 1103 | CODE | |
| LOW | scripts/backup_pipelines.py | 262 | CODE | |
| LOW | scripts/dummy_oidc.py | 135 | CODE | |
| LOW | scripts/dummy_oidc.py | 638 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 46 | token = rogue_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 57 | forged = rogue_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 59 | genuine = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 70 | "admin", email="admin@example.com", tenants=[TENANT], expires_in=-3600 | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 79 | "admin", email="admin@example.com", tenants=[TENANT], audience="some-other-api" | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 161 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW⚡ | python/tests/platform_rbac/test_3_negative.py | 170 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_3_negative.py | 263 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_3_negative.py | 298 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_3_negative.py | 333 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_3_negative.py | 361 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_3_negative.py | 384 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 84 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 110 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 165 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 207 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 251 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 300 | "admin", email="admin@example.com", tenants=[RENAMED_TENANT] | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 395 | "admin", email="admin@example.com", tenants=[TENANT, "beta"] | CODE |
| LOW | python/tests/platform_rbac/test_1_scenarios.py | 414 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | python/tests/platform_rbac/test_5_owner_revocation.py | 88 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[home]) | CODE |
| LOW | python/tests/platform_rbac/test_4_migration.py | 67 | admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT]) | CODE |
| LOW | docs.feldera.com/docs/sql/json.md | 553 | {"id": 123, "json": {"name": "John Doe", "scores": [8, 10]}} | CODE |
| LOW | scripts/rbac_demo.py | 86 | "admin": mint(args.oidc, "admin", "admin@example.com", [tenant]), | CODE |
| LOW | scripts/dummy_oidc.py | 47 | KID = "dummy-key-1" | CODE |
| LOW | scripts/dummy_oidc.py | 79 | "email": "admin@example.com", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/tests/__init__.py | 26 | __all__ = [ | CODE |
| LOW | python/tests/shared_test_pipeline.py | 14 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/tests/platform/helper.py | 42 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/tests/platform/helper.py | 299 | __all__ = [ | CODE |
| LOW | python/feldera/testutils.py | 26 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/feldera/pipeline.py | 49 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/feldera/rest/feldera_client.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | …thon/dbt-feldera/integration_tests/test_dbt_feldera.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/integration_tests/conftest.py | 15 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/integration_tests/docker_duckdb.py | 17 | logger = logging.getLogger(__name__) | CODE |
| LOW⚡ | python/dbt-feldera/integration_tests/docker_manager.py | 8 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/credentials.py | 7 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/connections.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 17 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/cursor.py | 10 | logger = logging.getLogger(__name__) | CODE |
| LOW | …n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py | 15 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/felderize/felderize/__init__.py | 31 | __all__ = [ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | crates/dbsp/src/circuit/circuit_builder.rs | 2764 | /// checks, but there are currently no guardrails in the system against | COMMENT |
| MEDIUM | python/feldera/pipeline.py | 237 | https://docs.feldera.com/connectors/#input-connector-orchestration | STRING |
| MEDIUM | python/feldera/pipeline.py | 256 | https://docs.feldera.com/connectors/#input-connector-orchestration | STRING |
| MEDIUM | python/feldera/rest/feldera_client.py | 1613 | <https://docs.feldera.com/connectors/#input-connector-orchestration> | STRING |
| MEDIUM | python/feldera/rest/feldera_client.py | 1638 | <https://docs.feldera.com/connectors/#input-connector-orchestration> | STRING |
| MEDIUM | docs.feldera.com/docs/connectors/orchestration.md | 1 | # Input connector orchestration | COMMENT |
| MEDIUM | docs.feldera.com/docs/connectors/orchestration.md | 125 | ## Automatic connector orchestration | COMMENT |
| MEDIUM | …ocs/use_cases/medallion_architecture/spark_notebook.py | 11 | # MAGIC no full re-scans, no orchestration. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/tests/platform/TEST_AUTH.md | 36 | export FELDERA_API_KEY="your-api-key" | CODE |
| HIGH | python/tests/platform/TEST_AUTH.md | 79 | export FELDERA_API_KEY="your-api-key" | CODE |
| HIGH | …era.com/docs/use_cases/medallion_architecture/part2.md | 25 | export FELDERA_API_KEY=<your-api-key> # only if your instance requires auth | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …lCompiler/compiler/frontend/CalciteToDBSPCompiler.java | 2242 | // Don't forget to drop the added field | COMMENT |
| MEDIUM | crates/dbsp/src/operator/trace.rs | 148 | /// * As discussed above, the retainment policy set using this method | COMMENT |
| MEDIUM | crates/dbsp/src/operator/accumulate_trace.rs | 149 | /// * As discussed above, the retainment policy set using this method | COMMENT |
| LOW | deploy/docker-compose.yml | 7 | # If you change the host side of the port mapping here, don't forget to | COMMENT |
| LOW | deploy/docker-compose.yml | 7 | # If you change the host side of the port mapping here, don't forget to | COMMENT |
| LOW | scripts/bump-versions.sh | 8 | # When pushing commits created by this script, don't forget to use the --follow-tags argument to `git push` | COMMENT |
| LOW | scripts/bump-versions.sh | 8 | # When pushing commits created by this script, don't forget to use the --follow-tags argument to `git push` | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sql-to-dbsp-compiler/build.sh | 36 | # Check if there is a valid checkout of Calcite | COMMENT |
| LOW | …untime_aggtest/orderby_tests/automate_orderby_views.py | 38 | # Assign names to views based on the table name and the value of the counter | COMMENT |
| LOW | python/tests/runtime/test_spreadsheet.py | 23 | # Read the file ../crates/pipeline-manager/demos/sql/10-spreadsheet.sql | COMMENT |
| LOW⚡ | python/tests/workloads/test_kafka_avro.py | 36 | # Check if Schema Registry is available | COMMENT |
| LOW⚡ | python/tests/workloads/test_kafka_avro.py | 39 | # Check if Kafka broker is available | COMMENT |
| LOW | python/feldera/testutils_oidc.py | 290 | # Check if token is already cached and still valid | COMMENT |
| LOW | …ldera/dbt/include/feldera/macros/adapters/metadata.sql | 14 | {# Check if a pipeline exists #} | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 116 | # Check if any values have decimal parts | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | crates/dbsp/src/dynamic/vec.rs | 391 | // TODO: implement `swap` as a method of `LeanVec` to reduce code size. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/index.rs | 169 | // TODO: implement consumers | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/distinct.rs | 1383 | // TODO: implement microstep-compatible versions of integrate_nested, etc. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/upsert.rs | 241 | // TODO: implement this check. | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 1346 | /// TODO: implement verification using the delta table API rather than | COMMENT |
| LOW | crates/adapters/src/format/json.rs | 71 | // TODO: implement support for parsing this format. | COMMENT |
| LOW | …line-manager/src/api/endpoints/pipeline_interaction.rs | 44 | // TODO: implement chunked and batch modes. | COMMENT |
| LOW | python/feldera/rest/feldera_client.py | 1056 | # TODO: implement this without using /stats when we have a better pipeline status reporting API. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …compiler/frontend/calciteCompiler/ConvertletTable.java | 343 | // windowed agg. I have added an optimizer rule | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | crates/adapters/src/transport/kafka/ft/input.rs | 510 | // Then replay as many steps as requested. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/tests/platform/test_checkpoint_sync.py | 79 | CODE | |
| LOW | python/tests/workloads/test_tpch.py | 31 | CODE | |
| LOW | python/feldera/runtime_config.py | 70 | CODE | |
| LOW | python/feldera/testutils.py | 417 | CODE | |
| LOW | python/feldera/pipeline.py | 1767 | CODE | |
| LOW | python/feldera/rest/config.py | 21 | CODE | |
| LOW | python/felderize/felderize/skills.py | 141 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | crates/iceberg/src/test/create_test_table_s3.py | 264 | # Create the DataFrame | COMMENT |
| MEDIUM | …n/tests/runtime_aggtest/orderby_tests/sqlite_runner.py | 29 | sqlite_db_path = ":memory:" # Create an in-memory database | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …dbt-feldera/integration_tests/scripts/run-dbt-local.sh | 6 | # Usage: | COMMENT |
| LOW | …nsole/src/lib/compositions/useReactiveWaiter.svelte.ts | 263 | // Example usage: | COMMENT |
| LOW | scripts/inotify.sh | 4 | # Usage: | COMMENT |