ErrLookup › risingwavelabs/risingwave
risingwavelabs/risingwave
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale. · Rust · 2,963 source files
Analyzed at 6469eb736d on 2026-09-12. 1998 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Change log retention miss: table {table_id}, epoch {epoch} | exception | error | storage, hummock, change-log, retention, epoch |
| broken broadcast_channel | error_code | error | batch, channel, exchange |
| infinite | panic | critical | retry, backoff, panic, sink-coordination, rust |
| Time-travel version expired: table {table_id}, epoch {epoch} | exception | error | storage, hummock, time-travel, retention, epoch |
| object {object_id} is rejected from being committed since it | exception | error | hummock, object-storage, gc, clock-skew, risingwave-meta |
| iceberg pk-index writer {} replacement input closed before i | exception | critical | streaming, internal-invariant, barrier, iceberg, rust |
| unreachable (prev != curr) | panic | error | streaming, watermark, invariant-violation, rust, panic |
| Failed to parse source definition SQL | exception | error | sql, meta, source, catalog |
| {serde_json deserialization error for PulsarConfig from prop | validation | error | rust, serde, pulsar, sink, config |
| when any of the stream reaches the end, it should be right a | exception | error | streaming, log-store, state-machine, data-corruption |
| failed to read Lance transaction history | exception | error | lancedb, rust, storage, transaction-history, commit |
| list finished actors mismatch: expected: {:?}, actual: {:?} | error_code | error | streaming-meta, reschedule, consistency |
| `enable_pk_index` is only supported for upsert iceberg sink | validation | error | iceberg, sink, config-validation, risingwave |
| Streaming vnode mapping has not been initialized | error_code | error | |
| catalog error: {0} | error_code | error | catalog, sql, object-resolution, risingwave |
| could not convert url {} to file path | error_code | error | url, file-path, schema-ref |
| Invalid table name format '{}'. For SQL Server CDC, you must | validation | error | cdc, sql-server, table-name-format, frontend |
| JniError {error} | exception | error | jni, rust, java, native-binding |
| epoch {} does not match with current epoch {} | exception | error | streaming, epoch, barrier, state-machine |
| value {:?} out of range, expect {:?} | validation | error | meta, system-parameter, validation, database |
| anyhow!(err_msg) | exception | warning | cdc, channel, jni, error-propagation |
| failed to convert JSON schema to Avro schema: {} | error_code | error | schema, avro, conversion, panic |
| Missing watermark serde | exception | error | streaming, watermark, state-table, missing-config |
| Invalid jsonb encoding | error_code | error | rust, value-encoding, jsonb, deserialization, risingwave |
| dynamic filter condition eval must return bool array | panic | error | rust, streaming, panic, executor, type-mismatch |
| expect a string or a json array for privatelink.endpoint, bu | validation | error | kafka, config, aws-privatelink, source-creation |
| SQL Server table {} metadata error | validation | error | sqlserver, sink, metadata-query, database |
| iceberg_compaction_send_task_fail | exception | warning | fail-point, fault-injection, iceberg, compaction, testing |
| CompactionExecutor error: {0} | exception | error | storage, hummock, compaction, executor |
| iceberg catalog did not reflect committed pk-index snapshot | exception | error | iceberg, catalog, eventual-consistency, retry-exhausted, streaming-sink |
| config conflict: `commit_checkpoint_interval` larger than 1 | validation | error | sink, config, risingwave |
| (dynamic serde_json deserialization error for AdbcSnowflakeS | validation | error | snowflake, source, serde, deserialization, state-recovery |
| unreachable | panic | error | rust, stream-optimizer, kafka-scan, panic |
| dependent_table_id {dependent_table_id} not exists | exception | error | cursor, snapshot, catalog, streaming |
| should be set for vector index | panic | error | vector-index, missing-argument, sql, frontend |
| unknown minimal compatible type for {a:?} and {b:?} | panic | error | types, type-coercion, panic, internal |
| end of new output request | error_code | error | streaming, channel-closed, actor-lifecycle, rust |
| unrecognized configs: {:?} | validation | error | config, session, validation, risingwave |
| Unsupported attribute argument, expected a string literal pr | validation | error | |
| snapshot backfill epoch set again: {} {} {} | error_code | error | meta, streaming, internal-invariant |
| Turbopuffer document id column must be an integer or varchar | http | error | turbopuffer, sink, type-mismatch, primary-key |
| iceberg sink: schema evolution not supported; expect schema | exception | error | iceberg, schema-evolution, sink, rust, config-conflict |
| previous fragment info for {} not found | error_code | error | reschedule, fragment, scale |
| Barrier read is unavailable for now. Likely the cluster is r | exception | warning | storage, hummock, barrier, transient, recovery |
| Committed epoch mismatch: table {table_id}, committed_epoch | exception | error | storage, hummock, epoch, consistency, race-condition |
| multiple arguments are not supported for non-option function | panic | critical | proc-macro, compile-time, codegen, unimplemented |
| invalid license key | error_code | error | license, jwt, rust, configuration |
| task {:?} is not running | error_code | error | |
| (dataset guard acquisition error) | exception | error | lancedb, rust, storage, object-store, io |
| Expected at most 1 clean_watermark_index per table, got {:?} | error_code | error | streaming, watermark, hash-join, sql, optimizer |
| ROWS, RANGE, or GROUPS | validation | error | sql, parser, window-function, syntax |
| StorageError {error} | exception | error | storage, hummock, object-store, jni |
| wait for pk-index sink commit epoch before seeding merger st | exception | error | iceberg, epoch, meta-service, rpc, streaming-sink |
| delete file {} missing referenced_data_file | exception | error | iceberg, internal-invariant-violation, delete-file, recovery |
| pk index {pk_index} is out of range for parquet schema with | validation | error | parquet, schema, iceberg-sink, compaction |
| config deserialization error: {e} | validation | error | sink, config, serialization, azblob |
| Invalid list encoding: {0} | error_code | error | rust, value-encoding, list, array, deserialization |
| Streaming vnode mapping not found for fragment {0} | error_code | error | |
| Unsupported task type in iceberg compaction task: {task_type | exception | error | rust, iceberg, compaction, unsupported-operation |
| Scalar subquery produced more than one row. | exception | error | batch-executor, subquery, scalar-subquery, runtime-check |
| double inserting a join state entry | exception | error | streaming, hash-join, state, rust |
| fetch finished actors mismatch: expected: {:?}, actual: {:?} | error_code | error | streaming-meta, reschedule, consistency |
| task {:?} not found | error_code | error | |
| cannot create a duplicate task with the same ID: {:?} | error_code | error | |
| Input stream terminated unexpectedly during normal ingestion | exception | error | rust, streaming, materialized-view, upstream-failure |
| locality provider upstream ended unexpectedly during backfil | exception | critical | streaming, backfill, upstream, barrier, rust |
| Gap interval expression returned null | validation | error | streaming, gap-fill, null-value, configuration, sql |
InvalidInput Input end error | error_code | error | postgres-protocol, utf8, encoding, startup-message |
| `job_id` column not found in source backfill table catalog | validation | error | frontend, optimizer, catalog, backfill |
| meta client is required for iceberg pk-index compaction reso | exception | error | rust, streaming, iceberg, meta-client |
| open parquet reader for {path} | exception | error | parquet, object-storage, iceberg-sink, compaction |
| Invalid flag: {0:b} | error_code | error | rust, value-encoding, row-encoding, header, deserialization |
| Invalid vector item: {0} {1} | error_code | error | rust, value-encoding, decoding, vector |
| failed to send the commit response for epoch {} | exception | warning | rust, meta, sink-coordinator, channel-closed |
| error converting Arrow schema to Iceberg schema: {err} | exception | error | iceberg, arrow, schema-conversion, sink |
| File sink can only be created with sink_decouple enabled. Pl | validation | error | sink, file-sink, configuration, checkpointing |
| Lance fragment write task stopped before accepting a record | exception | error | lancedb, rust, async, channel, sink |
| LDAP bind failed | exception | error | ldap, authentication, bind, credentials |
| removing a join state entry but it is not in the cache | exception | error | streaming, hash-join, state, rust |
| when any of the stream reaches the end, other stream should | exception | warning | streaming, log-store, debug-assert, barrier-alignment |
| Failed to choose a compute node for fast insert | http | error | cluster, compute-node, http-503, webhook |
| manual Full compaction is rejected while an automatic round | exception | warning | iceberg, compaction, state-conflict, concurrency |
| missing system param {:?} | exception | error | meta, system-params, invariant |
| RisingWave is not compiled with feature `sink-{}` | validation | error | feature-flags, build, sink, compile-time |
| auto schema change with drop column only supports Project wi | error_code | error | meta-service, schema-change, streaming-graph, unsupported-operation |
| expect PbNodeBody::Sink but got: {:?} | validation | error | risingwave, streaming-graph, meta-node, plan-validation |
| no value found at column: {}, index: {} | exception | error | mysql, cdc, column-index, schema-drift |
| Sink error: {0} | error_code | error | sink, connector, meta-node |
| only iceberg table can be altered as sink | validation | error | sink, iceberg, meta, validation |
| column type mismatch: {:?} vs {:?}, column name: {:?} | validation | error | sink, type-mismatch, sql, create-sink |
| normalized URL isn't the same as the original one | http | warning | http, url, proxy, rust |
| BUG: Worker not found for new actor {} | error_code | error | reschedule, invariant, scale |
| MATCH_RECOGNIZE carries only one of the two WITHIN expressio | validation | error | streaming, match-recognize, invariant, within-clause |
| truncate at a later offset {:?} than the current latest offs | error_code | error | truncation, offset, invariant, log-store |
| corrupt MATCH_RECOGNIZE state row: seq column must be a non- | exception | error | rust, streaming, state-corruption, recovery |
| Debezium Mongo needs a `_id` column in table | validation | error | cdc, debezium, mongo, schema, primary-key |
| {e} | validation | error | starrocks, sink, config, serde |
| feature {feature:?} is not available based on your license | validation | error | license, snowflake, sink, feature-gating |
| FileCache error: {0} | exception | error | storage, hummock, file-cache, io |
| Invalid struct encoding: {0} | error_code | error | rust, value-encoding, struct, deserialization, schema-mismatch |