risingwave

risingwave copied to clipboard

**Describe the bug** For different streaming jobs aka. `create materialized view`, it's reasonable to let them create different SourceExecutors for one source. However, things get different inside a streaming job:...

fuyufjh

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? use `SourceError` and try to elimate anyhow::error and RwError...

cnissnzg

fix(dashboard): fix outdated proto & add new operators

1

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? a

xxchan

feat(batch):add metrics for batch exchange executor

3

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? add 'receive row number' metrics in batch exchange executor....

ZENOTME

feat(storage): move sync_uncommitted tasks and ssts from the shared buffer to the local version

1

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? Move sync_uncommitted tasks and ssts from the shared buffer...

xxhZs

**Is your feature request related to a problem? Please describe.** Window deduplication is a common demand in streaming processing. I found that PostgreSQL supports [DISTINCT ON](https://www.postgresql.org/docs/current/sql-select.html#SQL-DISTINCT) clause, which can meet...

TennyZhuang

fragmenter: remove 1v1 exchange rule & move the optimization to compute node

5

We've introduced the "1v1 exchange rewrite" in #1745 that split multiple stateful operators into different fragments, then connect them with `no-shuffle` exchange. However, this breaks the assumption that _every fragment...

BugenZhao

refactor(state_store): use binary-search for get prune sst

1

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? As for now every sstable is in Non-Overlapping level,...

xinchengxx

The approach dealing with selective distinct aggregates is wrong!

2

**Describe the bug** We currently add columns referred by filter of aggregates to subset when converting distinct aggregates. However, this is wrong because some columns that should be set to...

likg227

row id generator spin cause heartbeat timeout

1

**Describe the bug** A clear and concise description of what the bug is. When running ci-1cn-1fe with datagen, when sequence id reaches its upper bound, the row id generator will...

MrCroxx