The Feldera Incremental Computation Engine
This report summarizes scanner evidence for feldera/feldera, a Rust project with 2,120 GitHub stars. SynthScan examined 1,020,780 lines of code across 3484 source files, recording 4413 pattern matches distributed across 25 syntactic categories. The legacy adjusted pattern signal is 6.7 (Moderate 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? 3076 finding(s).
Are imports declared and package/API names verified? 523 finding(s).
Are wrappers, guards, and repeated structures necessary? 1548 finding(s).
Which changes need focused human review? 4413 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 4413 distinct pattern matches across 25 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 |
|---|---|---|---|---|
| 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 | 268 | // ── helpers ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 279 | // ── combination generator ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 399 | // ── Recursive step ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 419 | // ── Base: all non-nullable — skip ────────────────────────────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 425 | // ── Base: ≥1 nullable, no const generics, wrap in Some() ────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 441 | // ── Base: ≥1 nullable, const generics present, wrap in Some() ───────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 457 | // ── Base: ≥1 nullable, no const generics, direct return ─────────────── | COMMENT |
| MEDIUM | crates/sqllib/src/lib.rs | 473 | // ── 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 |
| 449 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 141 | # - 7f8bb445 "Disable unsupported feature check." — downgrade the reader-side | COMMENT |
| LOW | Cargo.toml | 161 | # - 9c858990 "delta-rs: backport delta-io/delta-rs#4692 onto 0.32.3" — the | 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 | …r/visitors/outer/CollectExpensiveExpressionsTests.java | 181 | COMMENT | |
| LOW | …g/dbsp/sqlCompiler/compiler/sql/tools/TableParser.java | 501 | return new Change(extracted); | COMMENT |
| LOW | …lCompiler/compiler/sql/simple/ArrayFunctionsTests.java | 1121 | select array_insert(array(1, 2, 3), 3, cast(null as tinyint)); | COMMENT |
| LOW | …ler/compiler/sql/streaming/JoinGCIncrementalTests.java | 181 | List<TablePair<?>> pairs = createTablePairs(); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1001 | """, """ | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1081 | INSERT INTO orders VALUES(1, 0); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1241 | // Before this step, table contents (rows above the ==== line are | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1261 | // 10:00 | b | | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1441 | -------------------- | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1501 | -------------------- | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1561 | 2 | 200 | 1"""); | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1621 | id | ts | weight | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1641 | // ================ waterline = 260 - 100 | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1761 | // ts | v | | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1801 | // Before this step, table contents: | COMMENT |
| LOW | …sqlCompiler/compiler/sql/streaming/StreamingTests.java | 1881 | -------------------------------- | 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 | …compiler/visitors/outer/monotonicity/Monotonicity.java | 561 | // The only field which could have a waterline is the key (timestamp) | COMMENT |
| LOW | …mpiler/visitors/outer/monotonicity/InsertLimiters.java | 1861 | OutputPort merged = extend.outputPort(); | COMMENT |
| LOW | …er/compiler/frontend/aggregates/LeadLagAggregates.java | 81 | DBSPExpression row = DBSPTupleExpression.flatten( | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 341 | (cx, call) -> cx.convertExpression( | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 1901 | // power( | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2061 | } | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2141 | } | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2161 | // FOR CASE WHEN length < 0 THEN 0 ELSE length END) | COMMENT |
| LOW | …compiler/frontend/calciteCompiler/ConvertletTable.java | 2501 | // | COMMENT |
| LOW | …Compiler/compiler/backend/rust/ToRustInnerVisitor.java | 2361 | } | 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/tests/archived_ord.rs | 1 | //! Does comparing two values in their archived form, or an archived value | COMMENT |
| LOW | crates/sqllib/tests/archived_ord.rs | 61 | // `rkyv` puts the root last, which is how `archived_root` finds it. | COMMENT |
| LOW | crates/sqllib/tests/archived_ord.rs | 901 | // | COMMENT |
| LOW | crates/sqllib/tests/archived_ord.rs | 941 | /// its first entry descends through two inner nodes rather than one. | COMMENT |
| LOW | crates/sqllib/tests/archived_ord.rs | 1781 | // Splicing a run of keys into a merge output has to feed the output's | COMMENT |
| LOW | crates/sqllib/benches/flat_variant_serialize.rs | 1 | //! Serialization throughput for [`FlatVariant`], the flat-buffer SQL VARIANT. | COMMENT |
| 2030 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 | 182 | def checkpoint_sync_connection( | CODE |
| LOW | python/tests/utils.py | 747 | def ensure_delta_spark_fixture( | CODE |
| LOW | python/tests/utils.py | 816 | def _build_delta_spark_fixture( | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 27 | def _incarnation_mismatch_error() -> FelderaAPIError: | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 39 | def test_retries_transparently_on_incarnation_mismatch(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 62 | def test_handles_missing_incarnation_uuid_from_older_pipeline(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 79 | def test_non_mismatch_api_error_still_propagates(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 103 | def test_retries_transparently_on_incarnation_mismatch(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 136 | def test_handles_missing_incarnation_uuid_from_older_pipeline(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 159 | def test_checkpoint_response_returns_full_dict_without_wait(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 173 | def test_checkpoint_still_returns_bare_seq(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 185 | def test_sync_checkpoint_response_returns_full_dict_without_wait(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 199 | def test_sync_checkpoint_still_returns_bare_uuid(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 233 | def test_checkpoint_pipeline_returns_bare_int(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 245 | def test_checkpoint_pipeline_response_returns_full_dict(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 259 | def test_sync_checkpoint_returns_bare_str(self): | CODE |
| LOW | …thon/tests/unit/test_checkpoint_incarnation_restart.py | 271 | def test_sync_checkpoint_response_returns_full_dict(self): | CODE |
| LOW | python/tests/unit/test_input_pandas_token.py | 33 | def test_returns_token_of_last_chunk(self): | CODE |
| LOW | python/tests/unit/test_input_pandas_token.py | 43 | def test_empty_dataframe_returns_none(self): | CODE |
| LOW | python/tests/unit/test_output_handler.py | 23 | def test_reading_while_changes_arrive_loses_nothing(self): | 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_delta_fixture_build_lock.py | 86 | def test_concurrent_builders_build_once(tmp_path, fixture_subpath): | CODE |
| LOW | python/tests/unit/test_delta_fixture_build_lock.py | 135 | def test_half_placed_fixture_is_rebuilt(monkeypatch, fixture_subpath): | CODE |
| LOW | python/tests/unit/test_delta_fixture_build_lock.py | 191 | def test_stable_path_is_suite_namespaced(monkeypatch, tag, expected): | CODE |
| LOW⚡ | python/tests/unit/test_connector_metadata.py | 26 | def test_connector_metadata_is_sent_as_json(client: FelderaClient): | CODE |
| LOW⚡ | python/tests/unit/test_connector_metadata.py | 32 | def test_connector_metadata_is_omitted_by_default(client: FelderaClient): | CODE |
| LOW⚡ | python/tests/unit/test_connector_metadata.py | 37 | def test_connector_metadata_must_be_a_mapping(client: FelderaClient): | CODE |
| LOW | python/tests/unit/test_feldera_edition.py | 4 | def test_editions_parse_and_classify(): | 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_checkpoint_sync_status.py | 142 | def test_failure_carries_the_error(pipeline: Pipeline): | CODE |
| LOW | python/tests/unit/test_checkpoint_sync_status.py | 155 | def test_other_checkpoints_running_are_ignored(pipeline: Pipeline): | CODE |
| LOW | python/tests/unit/test_checkpoint_sync_status.py | 161 | def test_accepts_a_uuid_object(pipeline: Pipeline): | CODE |
| LOW | python/tests/unit/test_jwt_expiry.py | 46 | def test_states_nothing_rather_than_guessing(token): | CODE |
| LOW | python/tests/unit/test_jwt_expiry.py | 57 | def test_seconds_since_expiry_only_reports_the_past(): | CODE |
| LOW | python/tests/unit/test_jwt_expiry.py | 64 | def test_padding_is_restored_for_every_payload_length(): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 94 | def test_cursor_counts_the_lines_read(self): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 99 | def test_from_headers_reads_all_three(self): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 105 | def test_partial_position_is_an_error(self, dropped): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 113 | def test_first_connection_asks_for_the_whole_buffer(self): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 121 | def test_cursor_is_sent_as_given(self): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 127 | def test_position_of_a_resume_that_lost_lines(self): | CODE |
| LOW⚡ | python/tests/unit/test_pipeline_logs_cursor.py | 140 | def test_transient_failure_is_retried(self): | CODE |
| 664 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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/utils.py | 20 | 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 | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 32 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 33 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 34 | CODE | |
| LOW | python/tests/runtime_aggtest/aggregate_tests5/main.py | 35 | CODE | |
| 394 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 | 620 | "CREATE TABLE t1(id bigint not null, s varchar not null); " | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 673 | "id1 bigint not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 674 | "id2 bigint not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 675 | "str1 varchar not null," | CODE |
| HIGH⚡ | python/tests/platform/test_ingress_formats.py | 677 | "int1 bigint not null," | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 822 | # 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 | 388 | '{"id":1,"v":{"name":"Bob","scores":[1,2.5,null],"ok":true}}\n' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 392 | '{"id":5,"v":null}', | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 491 | 'CREATE TABLE t1("c1" integer not null,"C2" bool not null,"😁❤" varchar not null,' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 492 | "\"αβγ\" boolean not null, ΔΘ boolean not null) WITH ('materialized'='true');" | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 515 | sql = "CREATE TABLE t1(id bigint not null, s varchar not null, primary key(id)) " | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 563 | 'CREATE TABLE "TaBle1"(id bigint not null);' | CODE |
| HIGH | python/tests/platform/test_ingress_formats.py | 814 | '{"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 | 610 | # answering null, so drop the empty entries. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | crates/iceberg/src/test/create_test_table_s3.py | 129 | except: | CODE |
| HIGH | crates/iceberg/src/test/create_test_table_s3.py | 97 | except: | CODE |
| HIGH | crates/iceberg/src/test/follow_table.py | 73 | except Exception: | CODE |
| HIGH | crates/iceberg/src/test/follow_table.py | 77 | except Exception: | CODE |
| HIGH | python/tests/utils.py | 671 | except Exception: | CODE |
| HIGH | python/tests/utils.py | 675 | except Exception: | CODE |
| HIGH | python/tests/kafka.py | 36 | except Exception: | CODE |
| HIGH | python/tests/platform/test_pipeline_lifecycle.py | 879 | except RuntimeError: | CODE |
| HIGH | python/tests/platform/test_api_keys.py | 26 | except FelderaAPIError: | CODE |
| HIGH | python/tests/platform/negative_test.py | 76 | except Exception: | CODE |
| HIGH | python/tests/platform/negative_test.py | 116 | except Exception: | CODE |
| HIGH | python/tests/platform/test_connector_status.py | 108 | except FelderaAPIError: | CODE |
| HIGH | python/tests/platform/test_connector_status.py | 268 | except FelderaAPIError: | CODE |
| HIGH | python/tests/runtime/test_adhoc_queries.py | 199 | except OSError: | CODE |
| HIGH | python/tests/runtime/test_adhoc_queries.py | 533 | except OSError: | CODE |
| HIGH | python/tests/platform_rbac/idp.py | 122 | except requests.RequestException: | CODE |
| HIGH | python/tests/workloads/test_kafka_avro.py | 416 | except IndexError: | CODE |
| HIGH | python/feldera/testutils.py | 36 | except ImportError: | CODE |
| HIGH | python/feldera/pipeline_builder.py | 120 | except FelderaAPIError: | CODE |
| HIGH | python/feldera/rest/errors.py | 23 | except ValueError: | CODE |
| HIGH | …n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py | 351 | except Exception: | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 103 | except ModuleNotFoundError: | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 405 | except Exception: # noqa: BLE001 - cleanup must not mask the real result | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 409 | except Exception: # noqa: BLE001 | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 278 | except (ValueError, OverflowError): | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 262 | except Exception: # noqa: BLE001 | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 270 | except Exception: # noqa: BLE001 | CODE |
| HIGH | python/felderize/tests/e2e/run_tests.py | 728 | except Exception: # noqa: BLE001 - fall through and re-run if the cache is unreadable | CODE |
| HIGH | python/felderize/felderize/docs.py | 376 | except yaml.YAMLError: | CODE |
| HIGH | scripts/scalebench.py | 856 | except OSError: | CODE |
| 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 | 484 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 506 | // 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 | 1225 | // Step 0: add edges 1->2, 2->3; mark 2 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1230 | // Step 1: extend chain with 3->4; mark 3 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1232 | // Step 2: extend chain with 4->5; mark 4 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1234 | // Step 3: remove key point 3 (paths via 3 should disappear). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1236 | // Step 4: remove edge 2->3 (breaks the original chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1238 | // Step 5: add shortcut edge 2->5 (bypasses missing 3->4). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1240 | // Step 6: add 5->6 and mark 5,6 as key points. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1242 | // Step 7: add edge 6->2 (introduce a cycle). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1244 | // Step 8: remove key point 2 (cycle still exists but via non-key). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1246 | // 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 | 1248 | // 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 | 1250 | // 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 | 1252 | // Step 12: add new branch 3->7 and mark 7 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1254 | // Step 13: add edge 7->5 (reconnect branch to existing node). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1256 | // Step 14: add edge 5->8 and mark 8 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1258 | // Step 15: remove edge 2->5 (drop the shortcut). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1260 | // Step 16: remove key point 4 (paths via 4 should drop). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1262 | // Step 17: add edge 8->2 (new cycle through 8). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1264 | // Step 18: remove edge 7->5 (break branch reconnection). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1266 | // Step 19: remove key point 7 and edge 8->2 (collapse new cycle). | COMMENT |
| LOW | crates/adapters/src/controller/test.rs | 8219 | // Step 0: initiated, evaluated, and delivered by the endpoint. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 3027 | // Step 1: two appends => two parquet files, one Delta version each. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 3032 | // Step 2: OPTIMIZE coalesces the two files into one. Every action has | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 3055 | // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching file | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 3078 | // Step 4: real change. CDC tables encode an in-place row update as a | COMMENT |
| LOW⚡ | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 679 | // Step 1: a superuser start with the default configuration, stopped only | COMMENT |
| LOW⚡ | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 686 | // Step 2: the documented CREATE ROLE and GRANT statements. | COMMENT |
| LOW | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 702 | // Step 3: the runtime role resumes the bootstrap pipeline with the source | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1111 | // Step 1: insert a couple of values. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1131 | // Step 2: replace an entry. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1148 | // Step 3: delete an entry. | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1129 | # Step 2: Create checkpoint and sync | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1133 | # Step 3: Start standby pipeline | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1385 | # Step 1: push a checkpoint to the source pipeline (becomes read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1461 | # Step 1: create the source pipeline (becomes read_bucket for standby). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1641 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1726 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1886 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1107 | # Step 1: Start main pipeline | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1154 | # Step 4: Add more data and make 3-10 checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1176 | # Step 5: Stop main and activate standby | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1187 | # Step 6: Validate standby has all expected records | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1292 | # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1317 | # Step 2: start the main pipeline with an empty bucket and read_bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1405 | # Step 2: push a checkpoint to the main pipeline's own bucket. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1425 | # Step 3: restart with both bucket (has main data) and read_bucket (has | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1481 | # Step 2: start the main pipeline; it will push newer checkpoints to | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1494 | # Step 3: start the standby pipeline with empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1516 | # Step 4: main pipeline inserts data and pushes multiple checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1534 | # Step 5: activate standby — it should have tracked the latest bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1661 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| 35 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 | 484 | // Step 1: Compute R0 and R1. | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/group/row_number.rs | 506 | // 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 | 1225 | // Step 0: add edges 1->2, 2->3; mark 2 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1230 | // Step 1: extend chain with 3->4; mark 3 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1232 | // Step 2: extend chain with 4->5; mark 4 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1234 | // Step 3: remove key point 3 (paths via 3 should disappear). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1236 | // Step 4: remove edge 2->3 (breaks the original chain). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1238 | // Step 5: add shortcut edge 2->5 (bypasses missing 3->4). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1240 | // Step 6: add 5->6 and mark 5,6 as key points. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1242 | // Step 7: add edge 6->2 (introduce a cycle). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1244 | // Step 8: remove key point 2 (cycle still exists but via non-key). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1246 | // 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 | 1248 | // 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 | 1250 | // 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 | 1252 | // Step 12: add new branch 3->7 and mark 7 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1254 | // Step 13: add edge 7->5 (reconnect branch to existing node). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1256 | // Step 14: add edge 5->8 and mark 8 as key point. | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1258 | // Step 15: remove edge 2->5 (drop the shortcut). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1260 | // Step 16: remove key point 4 (paths via 4 should drop). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1262 | // Step 17: add edge 8->2 (new cycle through 8). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1264 | // Step 18: remove edge 7->5 (break branch reconnection). | COMMENT |
| LOW⚡ | crates/dbsp/src/operator/dynamic/multijoin/star_join.rs | 1266 | // Step 19: remove key point 7 and edge 8->2 (collapse new cycle). | COMMENT |
| LOW | crates/adapters/src/controller/test.rs | 8219 | // Step 0: initiated, evaluated, and delivered by the endpoint. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 3027 | // Step 1: two appends => two parquet files, one Delta version each. | COMMENT |
| LOW⚡ | crates/adapters/src/integrated/delta_table/test.rs | 3032 | // Step 2: OPTIMIZE coalesces the two files into one. Every action has | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 3055 | // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching file | COMMENT |
| LOW | crates/adapters/src/integrated/delta_table/test.rs | 3078 | // Step 4: real change. CDC tables encode an in-place row update as a | COMMENT |
| LOW⚡ | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 679 | // Step 1: a superuser start with the default configuration, stopped only | COMMENT |
| LOW⚡ | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 686 | // Step 2: the documented CREATE ROLE and GRANT statements. | COMMENT |
| LOW | …dapters/src/integrated/postgres/test/cdc_privileges.rs | 702 | // Step 3: the runtime role resumes the bootstrap pipeline with the source | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1111 | // Step 1: insert a couple of values. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1131 | // Step 2: replace an entry. | COMMENT |
| LOW | crates/adapters/src/static_compile/catalog.rs | 1148 | // Step 3: delete an entry. | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1129 | # Step 2: Create checkpoint and sync | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1133 | # Step 3: Start standby pipeline | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1385 | # Step 1: push a checkpoint to the source pipeline (becomes read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1461 | # Step 1: create the source pipeline (becomes read_bucket for standby). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1641 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1726 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW⚡ | python/tests/platform/test_checkpoint_sync.py | 1886 | # Step 1: source pipeline creates a checkpoint (will become read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1107 | # Step 1: Start main pipeline | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1154 | # Step 4: Add more data and make 3-10 checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1176 | # Step 5: Stop main and activate standby | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1187 | # Step 6: Validate standby has all expected records | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1292 | # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket). | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1317 | # Step 2: start the main pipeline with an empty bucket and read_bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1405 | # Step 2: push a checkpoint to the main pipeline's own bucket. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1425 | # Step 3: restart with both bucket (has main data) and read_bucket (has | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1481 | # Step 2: start the main pipeline; it will push newer checkpoints to | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1494 | # Step 3: start the standby pipeline with empty bucket, read_bucket=source. | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1516 | # Step 4: main pipeline inserts data and pushes multiple checkpoints | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1534 | # Step 5: activate standby — it should have tracked the latest bucket | COMMENT |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1661 | # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced). | COMMENT |
| 5 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | crates/iceberg/src/test/follow_table.py | 73 | except Exception: | CODE |
| LOW | crates/iceberg/src/test/follow_table.py | 77 | except Exception: | CODE |
| LOW | python/tests/utils.py | 671 | except Exception: | CODE |
| LOW | python/tests/utils.py | 675 | 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 | 311 | except Exception as e: | CODE |
| LOW | python/tests/runtime_aggtest/aggtst_base.py | 390 | 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 |
| LOW | python/tests/platform/test_checkpoint_sync.py | 55 | except Exception as e: | CODE |
| LOW | python/tests/platform/test_checkpoint_sync.py | 1345 | 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 | 152 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/tests/platform/test_ingress_formats.py | 188 | except Exception as e: | CODE |
| LOW | python/tests/runtime/test_checkpoint_runtime_upgrade.py | 338 | except Exception as e: | CODE |
| LOW | python/tests/runtime/test_adhoc_queries.py | 210 | except Exception: | STRING |
| LOW | python/tests/workloads/test_jsonbench.py | 458 | except Exception as e: | STRING |
| LOW | python/tests/workloads/test_jsonbench.py | 561 | 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 | 301 | except Exception as error: | CODE |
| LOW⚡ | python/feldera/testutils.py | 306 | except Exception as error: | CODE |
| LOW⚡ | python/feldera/testutils.py | 312 | except Exception as error: | CODE |
| LOW | python/feldera/testutils.py | 395 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 634 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 652 | except Exception as e: | CODE |
| LOW | python/feldera/testutils.py | 666 | 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 | 143 | except Exception as e: | CODE |
| LOW | python/feldera/rest/errors.py | 73 | except Exception: | CODE |
| LOW | python/feldera/rest/feldera_client.py | 144 | 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 |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 226 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 295 | except Exception as exc: | CODE |
| LOW | python/dbt-feldera/dbt/adapters/feldera/impl.py | 351 | except Exception as exc: | CODE |
| 39 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 | 444 | 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 | 1447 | .with_product(self.inner.status.pipeline_config.given_name.as_ref()) | CODE |
| CRITICAL | crates/adapters/src/controller.rs | 9082 | 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 | 174 | // 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 | 1449 | /// To leverage such optimizations, we adopt the best-effort approach: operators | COMMENT |
| MEDIUM | …dbsp/src/operator/dynamic/aggregate/chain_aggregate.rs | 324 | /// 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 | 914 | // 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 | 118 | /// so the check is robust to the deeply nested errors DataFusion typically | COMMENT |
| MEDIUM | crates/adapters/src/integrated/postgres/cdc_input.rs | 3488 | // 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 | 636 | # 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 | sql-to-dbsp-compiler/check-keyword-drift.py | 48 | 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 | 168 | CODE | |
| LOW | python/tests/platform/test_orchestration.py | 226 | CODE | |
| LOW | python/tests/platform/test_orchestration.py | 319 | CODE | |
| LOW | python/tests/platform/test_shared_pipeline.py | 822 | CODE | |
| LOW | python/tests/runtime/test_bloom_filter_eviction.py | 85 | CODE | |
| LOW | python/tests/workloads/test_jsonbench.py | 181 | 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 | 285 | CODE | |
| LOW | python/feldera/rest/feldera_client.py | 200 | 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/file_changelog_release.py | 66 | 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 | 643 | 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 | 571 | {"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 | 24 | __all__ = [ | CODE |
| LOW | python/tests/shared_test_pipeline.py | 14 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/tests/platform/helper.py | 43 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/tests/platform/helper.py | 373 | __all__ = [ | CODE |
| LOW | python/feldera/testutils.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/feldera/pipeline.py | 51 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/feldera/rest/feldera_config.py | 4 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/feldera/rest/feldera_client.py | 26 | 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 |
|---|---|---|---|---|
| LOW | sql-to-dbsp-compiler/build.sh | 36 | # Check if there is a valid checkout of Calcite | COMMENT |
| LOW | sql-to-dbsp-compiler/build.sh | 89 | # Check if the list of reserved keywords is up-to-date | 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 |
| LOW | .github/workflows/fred-observe.yml | 46 | # Set CI_SKIP_JOBS to 'fred-observe' to turn the observer off on its own. | 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 | 2114 | // 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 | 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 | 172 | // TODO: implement consumers | COMMENT |
| LOW | crates/dbsp/src/operator/dynamic/distinct.rs | 1388 | // 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 | 1509 | /// 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 | 46 | // TODO: implement chunked and batch modes. | COMMENT |
| LOW | python/feldera/rest/feldera_client.py | 1114 | # TODO: implement this without using /stats when we have a better pipeline status reporting API. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | crates/dbsp/src/circuit/circuit_builder.rs | 2759 | /// checks, but there are currently no guardrails in the system against | COMMENT |
| MEDIUM | docs.feldera.com/docs/connectors/orchestration.md | 1 | # Connector orchestration | COMMENT |
| MEDIUM | docs.feldera.com/docs/connectors/orchestration.md | 128 | ## 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 |
|---|---|---|---|---|
| LOW | python/tests/platform/test_checkpoint_sync.py | 77 | CODE | |
| LOW | python/tests/workloads/test_tpch.py | 31 | CODE | |
| LOW | python/feldera/runtime_config.py | 22 | CODE | |
| LOW | python/feldera/runtime_config.py | 74 | CODE | |
| LOW | python/feldera/testutils.py | 360 | CODE | |
| LOW | python/feldera/pipeline.py | 2006 | CODE | |
| LOW | python/feldera/rest/config.py | 44 | CODE | |
| LOW | python/feldera/rest/feldera_client.py | 59 | CODE | |
| LOW | python/feldera/rest/feldera_client.py | 1261 | CODE | |
| LOW | python/felderize/felderize/skills.py | 141 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …compiler/frontend/calciteCompiler/ConvertletTable.java | 350 | // windowed agg. I have added an optimizer rule | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | crates/adapters/src/transport/kafka/ft/input.rs | 542 | // Then replay as many steps as requested. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | crates/iceberg/src/test/create_test_table_s3.py | 212 | # 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 |