8000 feat: print backtrace in pg_protocol in debug mode by xxchan · Pull Request #21756 · risingwavelabs/risingwave · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

feat: print backtrace in pg_protocol in debug mode #21756

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
Closed
wants to merge 9 commits into from
Closed

feat: print backtrace in pg_protocol in debug mode #21756

wants to merge 9 commits into from

Conversation

xxchan
Copy link
Member
@xxchan xxchan commented May 7, 2025

While troubleshooting #21751 , the error contains limited context, making it quite hard to debug.

2025-05-03T16:14:54.873906933Z ERROR handle_query: pgwire::pg_protocol: error when process message error=Failed to run the query: Scheduler error: Unexpected => try_lock failed because the operation would block mode="simple query" session_id=4 sql=SELECT count(*) FROM iceberg_t1_source

Signed-off-by: xxchan xxchan22f@gmail.com

I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

Checklist

  • I have written necessary rustdoc comments.
  • I have added necessary unit tests and integration tests.
  • I have added test labels as necessary.
  • I have added fuzzing tests or opened an issue to track them.
  • My PR contains breaking changes.
  • My PR changes performance-critical code, so I will run (micro) benchmarks and present the results.
  • I have checked the Release Timeline and Currently Supported Versions to determine which release branches I need to cherry-pick this PR into.

Documentation

  • My PR needs documentation updates.
Release note

@xxchan
feat: print backtrace in pg_protocol in debug mode
31e43ee 
While troubleshooting #21751 , the error contains limited context, making it quite hard to debug.
```
2025-05-03T16:14:54.873906933Z ERROR handle_query: pgwire::pg_protocol: error when process message error=Failed to run the query: Scheduler error: Unexpected => try_lock failed because the operation would block mode="simple query" session_id=4 sql=SELECT count(*) FROM iceberg_t1_source
```

Signed-off-by: xxchan <xxchan22f@gmail.com>
xxchan added 6 commits May 7, 2025 18:25
@xxchan
...
3911889 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
.....
237a24f 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
refine
2a9f7da 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
.
20234aa 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
trytry
19563fc 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
test other cases also
11b0984 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
Copy link
Member Author
xxchan commented May 7, 2025 •
edited
Loading

After adding .contexts, it seems the error is not from iceberg...

2025-05-07T13:34:31.690204861Z ERROR handle_query: pgwire::pg_protocol: error when process message error=Failed to run the query: Scheduler error: Unexpected => try_lock failed because the operation would block mode="simple query" session_id=8 sql=SELECT count(*) FROM iceberg_t1_source

Wait, the => should be an iceberg::Error ....

@xxchan
Debug print
0d264c4 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan
Copy link
Member Author
xxchan commented May 9, 2025

successfully got the backtrace:

2025-05-08T13:02:22.885191999Z ERROR handle_query: pgwire::pg_protocol: error when process message error=Failed to run the query: Scheduler error: Unexpected => try_lock failed because the operation would block mode="simple query" session_id=7 sql=SELECT count(*) FROM iceberg_t1_source
2025-05-08T13:02:22.885240098Z ERROR handle_query: pgwire::pg_protocol: Debug error error=SimpleQueryError(Scheduler error: Unexpected => try_lock failed because the operation would block

Backtrace:
   0: from<iceberg::error::Error>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/anyhow-1.0.86/src/backtrace.rs:27:14
   1: {closure#5}
             at ./src/connector/src/source/iceberg/mod.rs:408:59
   2: map_err<iceberg::scan::task::FileScanTask, iceberg::error::Error, anyhow::Error, risingwave_connector::source::iceberg::{impl#9}::list_splits_batch_scan::{async_fn#0}::{closure_env#5}>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/result.rs:856:27
   3: {async_fn#0}
             at ./src/connector/src/source/iceberg/mod.rs:408:42
   4: {async_fn#0}
             at ./src/connector/src/source/iceberg/mod.rs:360:14
   5: {async_fn#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:394:22
   6: {async_block#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:765:18
   7: poll<alloc::boxed::Box<(dyn core::future::future::Future<Output=core::result::Result<http::response::Response<axum_core::body::Body>, core::convert::Infallible>> + core::marker::Send), alloc::alloc::Global>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
   8: {async_block#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:836:14
   9: poll<alloc::boxed::Box<(dyn core::future::future::Future<Output=core::result::Result<http::response::Response<axum_core::body::Body>, core::convert::Infallible>> + core::marker::Send), alloc::alloc::Global>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  10: {async_block#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:836:14
  11: poll<alloc::boxed::Box<(dyn core::future::future::Future<Output=core::result::Result<(), risingwave_frontend::scheduler::error::SchedulerError>> + core::marker::Send), alloc::alloc::Global>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  12: {async_fn#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:731:10
  13: {async_fn#0}
             at ./src/frontend/src/scheduler/plan_fragmenter.rs:933:14
  14: {async_fn#0}
             at ./src/frontend/src/handler/query.rs:430:59
  15: {async_fn#0}
             at ./src/frontend/src/handler/query.rs:486:73
  16: {async_fn#0}
             at ./src/frontend/src/handler/query.rs:68:55
  17: {async_fn#0}
             at ./src/frontend/src/handler/mod.rs:594:88
  18: {async_fn#0}
             at ./src/frontend/src/session.rs:1581:57
  19: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:726:69
  20: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:710:18
  21: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:690:60
  22: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:493:45
  23: poll<alloc::boxed::Box<pgwire::pg_protocol::{impl#2}::do_process_inner::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  24: {closure#0}<alloc::sync::Weak<(dyn core::any::Any + core::marker::Send + core::marker::Sync), alloc::alloc::Global>, core::pin::Pin<alloc::boxed::Box<pgwire::pg_protocol::{impl#2}::do_process_inner::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:391:31
  25: scope_inner<alloc::sync::Weak<(dyn core::any::Any + core::marker::Send + core::marker::Sync), alloc::alloc::Global>, tokio::task::task_local::{impl#4}::poll::{closure_env#0}<alloc::sync::Weak<(dyn core::any::Any + core::marker::Send + core::marker::Sync), alloc::alloc::Global>, core::pin::Pin<alloc::boxed::Box<pgwire::pg_protocol::{impl#2}::do_process_inner::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, core::option::Option<core::task::poll::Poll<core::result::Result<(), pgwire::error::PsqlError>>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:217:19
  26: poll<alloc::sync::Weak<(dyn core::any::Any + core::marker::Send + core::marker::Sync), alloc::alloc::Global>, core::pin::Pin<alloc::boxed::Box<pgwire::pg_protocol::{impl#2}::do_process_inner::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:387:19
  27: {async_block#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:334:53
  28: poll<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:297:9
  29: {closure#0}<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-util-0.3.31/src/future/future/catch_unwind.rs:37:42
  30: call_once<core::task::poll::Poll<core::result::Result<(), pgwire::error::PsqlError>>, futures_util::future::future::catch_unwind::{impl#1}::poll::{closure_env#0}<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:272:9
  31: do_call<core::panic::unwind_safe::AssertUnwindSafe<futures_util::future::future::catch_unwind::{impl#1}::poll::{closure_env#0}<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>, core::task::poll::Poll<core::result::Result<(), pgwire::error::PsqlError>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40
  32: try<core::task::poll::Poll<core::result::Result<(), pgwire::error::PsqlError>>, core::panic::unwind_safe::AssertUnwindSafe<futures_util::future::future::catch_unwind::{impl#1}::poll::{closure_env#0}<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19
  33: catch_unwind<core::panic::unwind_safe::AssertUnwindSafe<futures_util::future::future::catch_unwind::{impl#1}::poll::{closure_env#0}<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>, core::task::poll::Poll<core::result::Result<(), pgwire::error::PsqlError>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14
  34: poll<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/futures-util-0.3.31/src/future/future/catch_unwind.rs:37:9
  35: {closure#0}<(), futures_util::future::future::catch_unwind::CatchUnwind<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:391:31
  36: scope_inner<(), tokio::task::task_local::{impl#4}::poll::{closure_env#0}<(), futures_util::future::future::catch_unwind::CatchUnwind<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>, core::option::Option<core::task::poll::Poll<core::result::Result<core::result::Result<(), pgwire::error::PsqlError>, alloc::boxed::Box<(dyn core::any::Any + core::marker::Send), alloc::alloc::Global>>>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:217:19
  37: poll<(), futures_util::future::future::catch_unwind::CatchUnwind<core::panic::unwind_safe::AssertUnwindSafe<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/task_local.rs:387:19
  38: {async_block#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:344:18
  39: poll<&mut pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  40: poll<core::pin::Pin<&mut pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:112:9
  41: poll<&mut core::pin::Pin<&mut pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/time/timeout.rs:202:33
  42: {async_block#3}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:360:62
  43: {async_block#4}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:377:30
  44: poll<pgwire::pg_protocol::{impl#2}::do_process::{async_fn#0}::{async_block_env#4}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tracing-0.1.40/src/instrument.rs:321:9
  45: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:416:19
  46: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:284:30
  47: {async_block#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:264:35
  48: poll<&mut pgwire::pg_protocol::{impl#2}::run::{async_fn#0}::{async_block_env#1}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  49: {closure#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/macros/select.rs:708:49
  50: poll<pgwire::pg_protocol::{impl#2}::run::{async_fn#0}::__tokio_select_util::Out<!, bool>, pgwire::pg_protocol::{impl#2}::run::{async_fn#0}::{closure_env#2}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/poll_fn.rs:151:9
  51: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_protocol.rs:268:17
  52: {async_fn#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>
             at ./src/utils/pgwire/src/pg_server.rs:335:10
  53: poll<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/future/future.rs:124:9
  54: poll<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tracing-0.1.40/src/instrument.rs:321:9
  55: {closure#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/core.rs:331:17
  56: with_mut<tokio::runtime::task::core::Stage<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>>, core::task::poll::Poll<()>, tokio::runtime::task::core::{impl#6}::poll::{closure_env#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/loom/std/unsafe_cell.rs:16:9
  57: poll<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/core.rs:320:30
  58: {closure#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:532:19
  59: call_once<core::task::poll::Poll<()>, tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:272:9
  60: do_call<core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>>, core::task::poll::Poll<()>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40
  61: try<core::task::poll::Poll<()>, core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19
  62: catch_unwind<core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>>, core::task::poll::Poll<()>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14
  63: poll_future<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:520:18
  64: poll_inner<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:209:27
  65: poll<tracing::instrument::Instrumented<core::pin::Pin<alloc::boxed::Box<pgwire::pg_server::handle_connection::{async_fn_env#0}<pgwire::net::Stream, risingwave_frontend::session::SessionManagerImpl>, alloc::alloc::Global>>>, alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:154:15
  66: poll
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/raw.rs:201:18
  67: run<alloc::sync::Arc<tokio::runtime::scheduler::multi_thread::handle::Handle, alloc::alloc::Global>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/mod.rs:463:9
  68: {closure#0}
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:600:18
  69: with_budget<core::result::Result<alloc::boxed::Box<tokio::runtime::scheduler::multi_thread::worker::Core, alloc::alloc::Global>, ()>, tokio::runtime::scheduler::multi_thread::worker::{impl#1}::run_task::{closure_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/coop/mod.rs:167:5
  70: budget<core::result::Result<alloc::boxed::Box<tokio::runtime::scheduler::multi_thread::worker::Core, alloc::alloc::Global>, ()>, tokio::runtime::scheduler::multi_thread::worker::{impl#1}::run_task::{closure_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/task/coop/mod.rs:133:5
  71: run_task
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:594:9
  72: run
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:542:24
  73: {closure#0}
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:507:21
  74: set<tokio::runtime::scheduler::Context, tokio::runtime::scheduler::multi_thread::worker::run::{closure#0}::{closure_env#0}, ()>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/context/scoped.rs:40:9
  75: {closure#0}<(), tokio::runtime::scheduler::multi_thread::worker::run::{closure#0}::{closure_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/context.rs:180:26
  76: try_with<tokio::runtime::context::Context, tokio::runtime::context::set_scheduler::{closure_env#0}<(), tokio::runtime::scheduler::multi_thread::worker::run::{closure#0}::{closure_env#0}>, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/thread/local.rs:311:12
  77: with<tokio::runtime::context::Context, tokio::runtime::context::set_scheduler::{closure_env#0}<(), tokio::runtime::scheduler::multi_thread::worker::run::{closure#0}::{closure_env#0}>, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/thread/local.rs:275:15
  78: set_scheduler<(), tokio::runtime::scheduler::multi_thread::worker::run::{closure#0}::{closure_env#0}>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/context.rs:180:9
  79: {closure#0}
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:502:9
  80: enter_runtime<tokio::runtime::scheduler::multi_thread::worker::run::{closure_env#0}, ()>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/context/runtime.rs:65:16
  81: run
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:494:5
  82: {closure#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/scheduler/multi_thread/worker.rs:435:41
  83: poll<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>, ()>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/blocking/task.rs:42:21
  84: poll<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tracing-0.1.40/src/instrument.rs:321:9
  85: {closure#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/core.rs:331:17
  86: with_mut<tokio::runtime::task::core::Stage<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>>, core::task::poll::Poll<()>, tokio::runtime::task::core::{impl#6}::poll::{closure_env#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/loom/std/unsafe_cell.rs:16:9
  87: poll<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/core.rs:320:30
  88: {closure#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:532:19
  89: call_once<core::task::poll::Poll<()>, tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:272:9
  90: do_call<core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>>, core::task::poll::Poll<()>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40
  91: try<core::task::poll::Poll<()>, core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19
  92: catch_unwind<core::panic::unwind_safe::AssertUnwindSafe<tokio::runtime::task::harness::poll_future::{closure_env#0}<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>>, core::task::poll::Poll<()>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14
  93: poll_future<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:520:18
  94: poll_inner<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:209:27
  95: poll<tracing::instrument::Instrumented<tokio::runtime::blocking::task::BlockingTask<tokio::runtime::scheduler::multi_thread::worker::block_in_place::{closure#0}::{closure_env#0}<risingwave_frontend::optimizer::rule::source_to_iceberg_scan_rule::{impl#0}::apply::{closure_env#0}, core::result::Result<(alloc::vec::Vec<alloc::string::String, alloc::alloc::Global>, bool), risingwave_connector::error::ConnectorError>>>>, tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/harness.rs:154:15
  96: run<tokio::runtime::blocking::schedule::BlockingSchedule>
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/task/mod.rs:500:9
  97: run
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/blocking/pool.rs:161:9
  98: run
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/blocking/pool.rs:511:17
  99: {closure#0}
             at ./.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.0/src/runtime/blocking/pool.rs:469:13
 100: __rust_begin_short_backtrace<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/sys/backtrace.rs:152:18
 101: {closure#0}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/thread/mod.rs:559:17
 102: call_once<(), std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:272:9
 103: do_call<core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>>, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40
 104: try<(), core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>>>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19
 105: catch_unwind<core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>>, ()>
             at /r
8000
ustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14
 106: {closure#1}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/thread/mod.rs:557:30
 107: call_once<std::thread::{impl#0}::spawn_unchecked_::{closure_env#1}<tokio::runtime::blocking::pool::{impl#6}::spawn_thread::{closure_env#0}, ()>, ()>
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/ops/function.rs:250:5
 108: <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/alloc/src/boxed.rs:1972:9
 109: <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/alloc/src/boxed.rs:1972:9
 110: std::sys::pal::unix::thread::Thread::new::thread_start
             at /rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/sys/pal/unix/thread.rs:109:17
 111: <unknown>
 112: clone

) mode="simple query" session_id=7 sql=SELECT count(*) FROM iceberg_t1_source

@xxchan xxchan requested a review from a team as a code owner May 13, 2025 13:29
@xxchan xxchan requested a review from xiangjinwu May 13, 2025 13:29
@xxchan
try try fix iceberg
d847a54 
Signed-off-by: xxchan <xxchan22f@gmail.com>
@xxchan xxchan force-pushed the xxchan/prominent-bovid branch from 7f9bb64 to d847a54 Compare May 13, 2025 13:32
@xxchan xxchan mentioned this pull request May 13, 2025
Merged
8 tasks
@xxchan
Copy link
Member Author
xxchan commented May 14, 2025

#21849

@xxchan xxchan closed this May 14, 2025
@xxchan xxchan mentioned this pull request May 14, 2025
Merged
8 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@xiangjinwu xiangjinwu Awaiting requested review from xiangjinwu xiangjinwu is a code owner automatically assigned from risingwavelabs/cargo-lock

Assignees
No one assigned
Labels
ci/main-cron/run-selected ci/run-e2e-iceberg-tests type/feature Type: New feature.
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
1 participant
@xxchan
0