Run cargo test --features integration_tests --test test_fluss -p fluss-rs
Updating crates.io index
Compiling fluss-rs v1.0.0 (/home/runner/work/fluss/fluss/fluss-rust/crates/fluss)
Compiling fluss-test-cluster v1.0.0 (/home/runner/work/fluss/fluss/fluss-rust/crates/fluss-test-cluster)
Finished `test` profile [unoptimized + debuginfo] target(s) in 32.20s
Running tests/test_fluss.rs (target/debug/deps/test_fluss-253b8c8a4edf590a)
running 56 tests
test integration::admin::admin_test::test_bootstrap_from_tablet_server ... ok
test integration::admin::admin_test::test_error_database_already_exist ... ok
test integration::admin::admin_test::test_create_database ... ok
test integration::admin::admin_test::test_error_table_not_exist ... ok
test integration::admin::admin_test::test_error_database_not_exist ... ok
test integration::admin::admin_test::test_error_table_already_exist ... ok
test integration::admin::admin_test::test_fluss_error_response ... ok
test integration::admin::admin_test::test_get_server_nodes ... ok
test integration::admin::admin_test::test_error_table_not_partitioned ... ok
test integration::admin::admin_test::test_create_table ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_rejects_invalid_bucket ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_projects_non_contiguous_columns ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_rejects_non_arrow_log_format ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_rejects_non_positive_limit ... ok
test integration::admin::admin_test::test_partition_apis ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_returns_appended_rows_then_none ... ok
test integration::batch_scanner::batch_scanner_test::limit_is_rejected_by_log_scanners ... ok
test integration::batch_scanner::batch_scanner_test::batch_scanner_reads_primary_key_table ... ok
test integration::dynamic_batch_size::dynamic_batch_size_test::concurrent_appends_share_estimator_without_corruption ... ok
test integration::dynamic_batch_size::dynamic_batch_size_test::disabled_keeps_static_batch_size ... ok
test integration::dynamic_batch_size::dynamic_batch_size_test::small_rows_shrink_batch_size ... ok
test integration::dynamic_batch_size::dynamic_batch_size_test::shrink_then_grow_batch_size ... ok
test integration::kv_changelog::kv_changelog_test::subscribe_kv_table_changelog ... ok
test integration::kv_table::kv_table_test::batched_concurrent_lookups ... ok
test integration::kv_table::kv_table_test::batched_concurrent_lookups_partitioned ... ok
test integration::kv_table::kv_table_test::all_supported_datatypes ... ok
test integration::kv_table::kv_table_test::composite_primary_keys ... ok
test integration::kv_table::kv_table_test::prefix_lookup ... ok
test integration::kv_table::kv_table_test::prefix_lookup_partitioned ... ok
test integration::kv_table::kv_table_test::prefix_lookup_validation_errors ... ok
test integration::kv_table::kv_table_test::partial_update ... ok
test integration::kv_table::kv_table_test::upsert_and_prefix_lookup_with_paimon_format_v1 ... ok
test integration::kv_table::kv_table_test::partitioned_table_upsert_and_lookup ... ok
test integration::log_table::table_test::all_supported_datatypes ... ok
test integration::log_table::table_test::append_record_batch_and_scan ... ok
test integration::log_table::table_test::partitioned_table_append_scan ... ok
test integration::log_table::table_test::list_offsets ... ok
test integration::kv_table::kv_table_test::upsert_and_lookup_with_paimon_format_v2 ... ok
test integration::log_table::table_test::projection_with_compound_types ... ok
test integration::kv_table::kv_table_test::upsert_delete_and_lookup ... ok
test integration::log_table::table_test::test_project ... ok
test integration::record_batch_log_reader::reader_test::until_latest_reads_non_partitioned_table ... ok
test integration::record_batch_log_reader::reader_test::until_latest_reads_partitioned_table ... ok
test integration::log_table::table_test::schema_evolution_add_column_log_scanner_dynamic_schema ... ok
test integration::record_batch_log_reader::reader_test::until_offsets_multi_bucket ... ok
test integration::record_batch_log_reader::reader_test::until_offsets_stops_at_explicit_offset ... ok
test integration::log_table::table_test::schema_evolution_add_column_log_scanner_fixed_schema ... ok
test integration::sasl_auth::sasl_auth_test::test_sasl_client_to_plaintext_server ... ok
test integration::sasl_auth::sasl_auth_test::test_sasl_connect_with_second_user ... ok
test integration::sasl_auth::sasl_auth_test::test_sasl_connect_with_unknown_user ... ok
test integration::record_batch_log_reader::reader_test::until_offsets_with_empty_range ... ok
test integration::sasl_auth::sasl_auth_test::test_sasl_connect_with_wrong_password ... ok
test integration::sasl_auth::sasl_auth_test::test_sasl_connect_with_valid_credentials ... ok
test integration::table_remote_scan::table_remote_scan_test::test_scan_remote_log ... ok
test integration::record_batch_log_reader::reader_test::until_offsets_past_end_of_log ... ok
test integration::log_table::table_test::test_poll_batches ... FAILED
failures:
---- integration::log_table::table_test::test_poll_batches stdout ----
thread 'integration::log_table::table_test::test_poll_batches' (4155) panicked at crates/fluss/tests/integration/log_table.rs:566:32:
index out of bounds: the len is 0 but the index is 0
stack backtrace:
0: 0x559029b7a178 - std[bcb96dfbba0ab899]::backtrace_rs::backtrace::libunwind::trace
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
1: 0x559029b7a178 - std[bcb96dfbba0ab899]::backtrace_rs::backtrace::trace_unsynchronized::<std[bcb96dfbba0ab899]::sys::backtrace::_print_fmt::{closure#1}>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
2: 0x559029b7a178 - std[bcb96dfbba0ab899]::sys::backtrace::_print_fmt
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/backtrace.rs:74:9
3: 0x559029b7a178 - <<std[bcb96dfbba0ab899]::sys::backtrace::BacktraceLock>::print::DisplayBacktrace as core[940e698046960fd5]::fmt::Display>::fmt
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/backtrace.rs:44:26
4: 0x559029b940ca - <core[940e698046960fd5]::fmt::rt::Argument>::fmt
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/fmt/rt.rs:152:76
5: 0x559029b940ca - core[940e698046960fd5]::fmt::write
6: 0x559029b7fd82 - std[bcb96dfbba0ab899]::io::default_write_fmt::<alloc[2ea6bcb46fca0c42]::vec::Vec<u8>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/io/mod.rs:622:11
7: 0x559029b7fd82 - <alloc[2ea6bcb46fca0c42]::vec::Vec<u8> as std[bcb96dfbba0ab899]::io::Write>::write_fmt
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/io/mod.rs:1977:13
8: 0x559029b540a6 - <std[bcb96dfbba0ab899]::sys::backtrace::BacktraceLock>::print
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/backtrace.rs:47:9
9: 0x559029b540a6 - std[bcb96dfbba0ab899]::panicking::default_hook::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:292:27
10: 0x559029b6fa59 - std[bcb96dfbba0ab899]::panicking::default_hook
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:316:9
11: 0x5590281952ec - <alloc[2ea6bcb46fca0c42]::boxed::Box<dyn for<'a, 'b> core[940e698046960fd5]::ops::function::Fn<(&'a std[bcb96dfbba0ab899]::panic::PanicHookInfo<'b>,), Output = ()> + core[940e698046960fd5]::marker::Sync + core[940e698046960fd5]::marker::Send> as core[940e698046960fd5]::ops::function::Fn<(&std[bcb96dfbba0ab899]::panic::PanicHookInfo,)>>::call
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/alloc/src/boxed.rs:2289:9
12: 0x5590281952ec - test[75d6903177b1d7e9]::test_main_inner::<test[75d6903177b1d7e9]::test_main_static::{closure#0}>::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:155:21
13: 0x559029b6fcd2 - <alloc[2ea6bcb46fca0c42]::boxed::Box<dyn for<'a, 'b> core[940e698046960fd5]::ops::function::Fn<(&'a std[bcb96dfbba0ab899]::panic::PanicHookInfo<'b>,), Output = ()> + core[940e698046960fd5]::marker::Sync + core[940e698046960fd5]::marker::Send> as core[940e698046960fd5]::ops::function::Fn<(&std[bcb96dfbba0ab899]::panic::PanicHookInfo,)>>::call
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/alloc/src/boxed.rs:2289:9
14: 0x559029b6fcd2 - std[bcb96dfbba0ab899]::panicking::panic_with_hook
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:833:13
15: 0x559029b54162 - std[bcb96dfbba0ab899]::panicking::panic_handler::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:698:13
16: 0x559029b4b1b9 - std[bcb96dfbba0ab899]::sys::backtrace::__rust_end_short_backtrace::<std[bcb96dfbba0ab899]::panicking::panic_handler::{closure#0}, !>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/backtrace.rs:182:18
17: 0x559029b551ed - __rustc[6c289b9f9c454d21]::rust_begin_unwind
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:689:5
18: 0x559029b9493c - core[940e698046960fd5]::panicking::panic_fmt
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/panicking.rs:80:14
19: 0x559029b946fc - core[940e698046960fd5]::panicking::panic_bounds_check
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/panicking.rs:271:5
20: 0x559027fd65d4 - <usize as core[940e698046960fd5]::slice::index::SliceIndex<[fluss[f8e10ec65b77f351]::record::ScanBatch]>>::index
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/slice/index.rs:272:10
21: 0x5590280f3bd3 - <[fluss[f8e10ec65b77f351]::record::ScanBatch] as core[940e698046960fd5]::ops::index::Index<usize>>::index
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/slice/index.rs:19:15
22: 0x5590280f3bd3 - <alloc[2ea6bcb46fca0c42]::vec::Vec<fluss[f8e10ec65b77f351]::record::ScanBatch> as core[940e698046960fd5]::ops::index::Index<usize>>::index
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/alloc/src/vec/mod.rs:3864:9
23: 0x559027ec5224 - test_fluss[44c4d214288eeae9]::integration::log_table::table_test::test_poll_batches::{closure#0}
at /home/runner/work/fluss/fluss/fluss-rust/crates/fluss/tests/integration/log_table.rs:566:32
24: 0x559028064e62 - <core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>> as core[940e698046960fd5]::future::future::Future>::poll
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/future/future.rs:133:9
25: 0x559028064f3d - <core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>> as core[940e698046960fd5]::future::future::Future>::poll
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/future/future.rs:133:9
26: 0x5590280dc69d - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:778:70
27: 0x5590280dc36b - tokio[87d0428d008f6d55]::task::coop::with_budget::<core[940e698046960fd5]::task::poll::Poll<()>, <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/task/coop/mod.rs:167:5
28: 0x5590280dc36b - tokio[87d0428d008f6d55]::task::coop::budget::<core[940e698046960fd5]::task::poll::Poll<()>, <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/task/coop/mod.rs:133:5
29: 0x5590280dc36b - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:778:25
30: 0x5590280c40f0 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Context>::enter::<core[940e698046960fd5]::task::poll::Poll<()>, <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:451:19
31: 0x5590280d8cfd - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:777:44
32: 0x5590280d73e4 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:865:68
33: 0x55902812cadb - <tokio[87d0428d008f6d55]::runtime::context::scoped::Scoped<tokio[87d0428d008f6d55]::runtime::scheduler::Context>>::set::<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}, (alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>)>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/context/scoped.rs:40:9
34: 0x559027e98f69 - tokio[87d0428d008f6d55]::runtime::context::set_scheduler::<(alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>), <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}>::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/context.rs:181:38
35: 0x559027ea9932 - <std[bcb96dfbba0ab899]::thread::local::LocalKey<tokio[87d0428d008f6d55]::runtime::context::Context>>::try_with::<tokio[87d0428d008f6d55]::runtime::context::set_scheduler<(alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>), <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>)>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/thread/local.rs:462:12
36: 0x559027ea8eae - <std[bcb96dfbba0ab899]::thread::local::LocalKey<tokio[87d0428d008f6d55]::runtime::context::Context>>::with::<tokio[87d0428d008f6d55]::runtime::context::set_scheduler<(alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>), <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>)>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/thread/local.rs:426:20
37: 0x559027e73bbd - tokio[87d0428d008f6d55]::runtime::context::set_scheduler::<(alloc[2ea6bcb46fca0c42]::boxed::Box<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::Core>, core[940e698046960fd5]::option::Option<()>), <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>::{closure#0}>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/context.rs:181:17
38: 0x5590280cbca0 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>::{closure#0}, core[940e698046960fd5]::option::Option<()>>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:865:27
39: 0x5590280cc496 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[940e698046960fd5]::pin::Pin<&mut core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:765:24
40: 0x5590280d5390 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>::{closure#0}
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:205:33
41: 0x55902806d2e3 - tokio[87d0428d008f6d55]::runtime::context::runtime::enter_runtime::<<tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CurrentThread>::block_on<core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>::{closure#0}, ()>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/context/runtime.rs:65:16
42: 0x5590280c0c41 - <tokio[87d0428d008f6d55]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/scheduler/current_thread/mod.rs:193:9
43: 0x559027f59384 - <tokio[87d0428d008f6d55]::runtime::runtime::Runtime>::block_on_inner::<core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/runtime.rs:371:52
44: 0x559027f5971f - <tokio[87d0428d008f6d55]::runtime::runtime::Runtime>::block_on::<core[940e698046960fd5]::pin::Pin<&mut dyn core[940e698046960fd5]::future::future::Future<Output = ()>>>
at /home/runner/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.52.3/src/runtime/runtime.rs:345:18
45: 0x559027eff424 - test_fluss[44c4d214288eeae9]::integration::log_table::table_test::test_poll_batches
at /home/runner/work/fluss/fluss/fluss-rust/crates/fluss/tests/integration/log_table.rs:566:61
46: 0x559027eb1217 - test_fluss[44c4d214288eeae9]::integration::log_table::table_test::test_poll_batches::{closure#0}
at /home/runner/work/fluss/fluss/fluss-rust/crates/fluss/tests/integration/log_table.rs:461:33
47: 0x559027e211b6 - <test_fluss[44c4d214288eeae9]::integration::log_table::table_test::test_poll_batches::{closure#0} as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/ops/function.rs:250:5
48: 0x5590281883cb - <fn() -> core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String> as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/ops/function.rs:250:5
49: 0x5590281883cb - test[75d6903177b1d7e9]::__rust_begin_short_backtrace::<core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String>, fn() -> core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:724:18
50: 0x559028195c45 - test[75d6903177b1d7e9]::run_test_in_process::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:747:74
51: 0x559028195c45 - <core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<test[75d6903177b1d7e9]::run_test_in_process::{closure#0}> as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/panic/unwind_safe.rs:275:9
52: 0x559028195c45 - std[bcb96dfbba0ab899]::panicking::catch_unwind::do_call::<core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<test[75d6903177b1d7e9]::run_test_in_process::{closure#0}>, core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:581:40
53: 0x559028195c45 - std[bcb96dfbba0ab899]::panicking::catch_unwind::<core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String>, core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<test[75d6903177b1d7e9]::run_test_in_process::{closure#0}>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:544:19
54: 0x559028195c45 - std[bcb96dfbba0ab899]::panic::catch_unwind::<core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<test[75d6903177b1d7e9]::run_test_in_process::{closure#0}>, core[940e698046960fd5]::result::Result<(), alloc[2ea6bcb46fca0c42]::string::String>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panic.rs:359:14
55: 0x559028195c45 - test[75d6903177b1d7e9]::run_test_in_process
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:747:27
56: 0x559028195c45 - test[75d6903177b1d7e9]::run_test::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:668:43
57: 0x5590281907a4 - test[75d6903177b1d7e9]::run_test::{closure#1}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/test/src/lib.rs:698:41
58: 0x5590281907a4 - std[bcb96dfbba0ab899]::sys::backtrace::__rust_begin_short_backtrace::<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/backtrace.rs:166:18
59: 0x559028198cc2 - std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked::<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/thread/lifecycle.rs:70:13
60: 0x559028198cc2 - <core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}> as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/panic/unwind_safe.rs:275:9
61: 0x559028198cc2 - std[bcb96dfbba0ab899]::panicking::catch_unwind::do_call::<core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:581:40
62: 0x559028198cc2 - std[bcb96dfbba0ab899]::panicking::catch_unwind::<(), core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panicking.rs:544:19
63: 0x559028198cc2 - std[bcb96dfbba0ab899]::panic::catch_unwind::<core[940e698046960fd5]::panic::unwind_safe::AssertUnwindSafe<std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/panic.rs:359:14
64: 0x559028198cc2 - std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked::<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/thread/lifecycle.rs:68:26
65: 0x559028198cc2 - <std[bcb96dfbba0ab899]::thread::lifecycle::spawn_unchecked<test[75d6903177b1d7e9]::run_test::{closure#1}, ()>::{closure#1} as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/core/src/ops/function.rs:250:5
66: 0x559029b78fcf - <alloc[2ea6bcb46fca0c42]::boxed::Box<dyn core[940e698046960fd5]::ops::function::FnOnce<(), Output = ()> + core[940e698046960fd5]::marker::Send> as core[940e698046960fd5]::ops::function::FnOnce<()>>::call_once
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/alloc/src/boxed.rs:2275:9
67: 0x559029b78fcf - <std[bcb96dfbba0ab899]::sys::thread::unix::Thread>::new::thread_start
at /rustc/2d8144b7880597b6e6d3dfd63a9a9efae3f533d3/library/std/src/sys/thread/unix.rs:118:17
68: 0x7f9db8c9caa4 - <unknown>
69: 0x7f9db8d29c6c - <unknown>
70: 0x0 - <unknown>
failures:
integration::log_table::table_test::test_poll_batches
test result: FAILED. 55 passed; 1 failed; 0 ignored; 0 measured; 0 filtered out; finished in 25.24s
error: test failed, to rerun pass `-p fluss-rs --test test_fluss`
Search before asking
Fluss version
0.9.0 (latest release)
Please describe the bug 🐞
Solution
No response
Are you willing to submit a PR?