8000 recovery test: OccupiedError when creating subscription · Issue #21370 · risingwavelabs/risingwave · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

recovery test: OccupiedError when creating subscription #21370

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Open
kwannoel opened this issue Apr 14, 2025 · 1 comment
Open

recovery test: OccupiedError when creating subscription #21370

kwannoel opened this issue Apr 14, 2025 · 1 comment
Assignees
@xxhZs
Labels
type/bug Type: Bug. Only for issues. type/flaky-test Type: Flaky test failure.
Milestone
release-2.3

Comments

@kwannoel
Copy link
Contributor

Describe the bug

There's a double entry for a subscription catalog.

Error message/log

thread '<unnamed>' panicked at src/frontend/src/catalog/schema_catalog.rs:336:14:
called `Result::unwrap()` on an `Err` value: OccupiedError { key: "sub1", old_value: SubscriptionCatalog { id: SubscriptionId { subscription_id: 105 }, name: "sub1", definition: "CREATE SUBSCRIPTION sub1 FROM mv1 WITH (retention = '1D')", retention_seconds: 86400, database_id: 1, schema_id: 2, dependent_table_id: TableId { table_id: 82 }, owner: UserId { user_id: 1 }, initialized_at_epoch: Some(Epoch(2087131086848000)), created_at_epoch: Some(Epoch(2087131086848000)), created_at_cluster_version: Some("PostgreSQL 13.14.0-RisingWave-2.4.0-alpha (478c7ad228112b58895d0b3810007ff338c5945a)"), initialized_at_cluster_version: Some("PostgreSQL 13.14.0-RisingWave-2.4.0-alpha (478c7ad228112b58895d0b3810007ff338c5945a)") }, new_value: SubscriptionCatalog { id: SubscriptionId { subscription_id: 106 }, name: "sub1", definition: "CREATE SUBSCRIPTION sub1 FROM mv1 WITH (retention = '1D')", retention_seconds: 86400, database_id: 1, schema_id: 2, dependent_table_id: TableId { table_id: 82 }, owner: UserId { user_id: 1 }, initialized_at_epoch: Some(Epoch(2087131480064000)), created_at_epoch: Some(Epoch(2087131480064000)), created_at_cluster_version: Some("PostgreSQL 13.14.0-RisingWave-2.4.0-alpha (478c7ad228112b58895d0b3810007ff338c5945a)"), initialized_at_cluster_version: Some("PostgreSQL 13.14.0-RisingWave-2.4.0-alpha (478c7ad228112b58895d0b3810007ff338c5945a)") }, .. }
stack backtrace:
   0: rust_begin_unwind
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:695:5
   1: core::panicking::panic_fmt
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panicking.rs:75:14
   2: core::result::unwrap_failed
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/result.rs:1704:5
   3: unwrap<&mut alloc::sync::Arc<risingwave_frontend::catalog::subscription_catalog::SubscriptionCatalog, alloc::alloc::Global>, std::collections::hash::map::OccupiedError<alloc::string::String, alloc::sync::Arc<risingwave_frontend::catalog::subscription_catalog::SubscriptionCatalog, alloc::alloc::Global>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/result.rs:1109:23
   4: create_subscription
             at ./src/frontend/src/catalog/schema_catalog.rs:334:9
   5: handle_catalog_notification
             at ./src/frontend/src/observer/observer_manager.rs:331:47
   6: handle_notification
             at ./src/frontend/src/observer/observer_manager.rs:72:17
   7: {async_block#0}<risingwave_common_service::observer_manager::RpcNotificationClient, risingwave_frontend::observer::observer_manager::FrontendObserverNode>
             at ./src/common/common_service/src/observer_manager.rs:164:25
   8: {async_block#0}<risingwave_common_service::observer_manager::{impl#2}::start::{async_fn#0}::{async_block_env#0}<risingwave_common_service::observer_manager::RpcNotificationClient, risingwave_frontend::observer::observer_manager::FrontendObserverNode>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/task/mod.rs:645:28
   9: poll<madsim::sim::task::{impl#10}::spawn_inner::{closure#0}::{async_block_env#0}<risingwave_common_service::observer_manager::{impl#2}::start::{async_fn#0}::{async_block_env#0}<risingwave_common_service::observer_manager::RpcNotificationClient, risingwave_frontend::observer::observer_manager::FrontendObserverNode>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/async-task-4.4.0/src/runnable.rs:455:26
  10: run<core::pin::Pin<alloc::boxed::Box<async_task::runnable::{impl#6}::spawn_local::Checked<madsim::sim::task::{impl#10}::spawn_inner::{closure#0}::{async_block_env#0}<risingwave_common_service::observer_manager::{impl#2}::start::{async_fn#0}::{async_block_env#0}<risingwave_common_service::observer_manager::RpcNotificationClient, risingwave_frontend::observer::observer_manager::FrontendObserverNode>>>, alloc::alloc::Global>>, (), madsim::sim::task::{impl#10}::spawn_inner::{closure_env#1}<risingwave_common_service::observer_manager::{impl#2}::start::{async_fn#0}::{async_block_env#0}<risingwave_common_service::observer_manager::RpcNotificationClient, risingwave_frontend::observer::observer_manager::FrontendObserverNode>>, alloc::sync::Weak<madsim::sim::task::TaskInfo, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/async-task-4.4.0/src/raw.rs:563:17
  11: {closure#0}
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/task/mod.rs:287:50
  12: do_call<madsim::sim::task::{impl#3}::run_all_ready::{closure_env#0}, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40
  13: try<(), madsim::sim::task::{impl#3}::run_all_ready::{closure_env#0}>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19
  14: catch_unwind<madsim::sim::task::{impl#3}::run_all_ready::{closure_env#0}, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14
  15: run_all_ready
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/task/mod.rs:287:17
  16: block_on<risingwave_simulation::main::{closure#0}::{async_block_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/task/mod.rs:240:13
  17: block_on<risingwave_simulation::main::{closure#0}::{async_block_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/runtime/mod.rs:129:9
  18: {closure#0}<risingwave_simulation::main::{closure#0}::{async_block_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/madsim-0.2.31/src/sim/runtime/builder.rs:141:35
note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
context: node=4 "frontend-1", task=34086 (spawned at /risingwave/src/common/common_service/src/observer_manager.rs:155:9)
note: run with `MADSIM_TEST_SEED=5` environment variable to reproduce this error

To Reproduce

See recovery tests in https://buildkite.com/risingwavelabs/main-cron/builds/4837#01962fe1-d1e0-40cb-88b2-c0d9035a556c

Expected behavior

No response

How did you deploy RisingWave?

No response

The version of RisingWave

No response

Additional context

No response
@kwannoel kwannoel added the type/bug Type: Bug. Only for issues. label Apr 14, 2025
@github-actions github-actions bot added this to the release-2.3 milestone Apr 14, 2025
@xxhZs xxhZs self-assigned this Apr 14, 2025
@BugenZhao BugenZhao added the type/flaky-test Type: Flaky test failure. label Apr 14, 2025
@kwannoel
Copy link
Contributor Author
kwannoel commented May 7, 2025

Is this resolved @xxhZs

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@xxhZs xxhZs

Labels
type/bug Type: Bug. Only for issues. type/flaky-test Type: Flaky test failure.
Projects
None yet
Milestone
release-2.3
Development

No branches or pull requests
3 participants
@BugenZhao @kwannoel @xxhZs
0