LiebingYu opened a new issue, #3693: URL: https://github.com/apache/fluss/issues/3693
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Fluss version 0.9.0 (latest release) ### Please describe the bug 🐞 ``` 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` ``` ### Solution _No response_ ### Are you willing to submit a PR? - [x] I'm willing to submit a PR! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
