sept17-nightly-panic

gistfile1.txt

thread 'tokio-runtime-worker' panicked at 'Map must not be polled after it returned `Poll::Ready`', /rust/lib/rustlib/src/rust/src/libstd/macros.rs:13:23
stack backtrace:
   0:     0x55ebd9dd41b1 - backtrace::backtrace::libunwind::trace::hc1c4a1d8ad423b97
                               at /cargo/registry/src/github.com-1ecc6299db9ec823/backtrace-0.3.46/src/backtrace/libunwind.rs:86
   1:     0x55ebd9dd41b1 - backtrace::backtrace::trace_unsynchronized::h82274781060cb056
                               at /cargo/registry/src/github.com-1ecc6299db9ec823/backtrace-0.3.46/src/backtrace/mod.rs:66
   2:     0x55ebd9dd41b1 - std::sys_common::backtrace::_print_fmt::h2a45d89b653a4da8
                               at src/libstd/sys_common/backtrace.rs:78
   3:     0x55ebd9dd41b1 - <std::sys_common::backtrace::_print::DisplayBacktrace as core::fmt::Display>::fmt::h41a0a93ab85e6aa1
                               at src/libstd/sys_common/backtrace.rs:59
   4:     0x55ebd983933c - core::fmt::write::hdaea18585065a96d
                               at src/libcore/fmt/mod.rs:1069
   5:     0x55ebd9dd3a04 - std::io::Write::write_fmt::h0cea70c809005252
                               at src/libstd/io/mod.rs:1504
   6:     0x55ebd9dd31e6 - std::sys_common::backtrace::_print::hd95f9978cc145ca4
                               at src/libstd/sys_common/backtrace.rs:62
   7:     0x55ebd9dd31e6 - std::sys_common::backtrace::print::hfb25ca2291be47d0
                               at src/libstd/sys_common/backtrace.rs:49
   8:     0x55ebd9dd31e6 - std::panicking::default_hook::{{closure}}::h44f76cee5dc8591c
                               at src/libstd/panicking.rs:198
   9:     0x55ebd9dd2634 - std::panicking::default_hook::h198e1a712910f1e6
                               at src/libstd/panicking.rs:218
  10:     0x55ebd9dd2634 - std::panicking::rust_panic_with_hook::hc0b4730bb8013f9d
                               at src/libstd/panicking.rs:511
  11:     0x55ebd9e72744 - std::panicking::begin_panic::h44cbf538e5ec2643
  12:     0x55ebda4ee8e5 - <futures_util::future::future::NeverError<Fut> as core::future::future::Future>::poll::h20568bd948200749
  13:     0x55ebda4ee78f - <futures_util::compat::compat03as01::Compat<Fut> as futures::future::Future>::poll::hb8c895e15a0d5bf5
  14:     0x55ebda8e32cc - <vector::sinks::util::sink::BatchSink<S,B,Request> as futures::sink::Sink>::poll_complete::h3001033deda9ac13
  15:     0x55ebda8e1b90 - <futures::sink::map_err::SinkMapErr<S,F> as futures::sink::Sink>::start_send::hb53d4c163fd2a380
  16:     0x55ebd9743b73 - <futures_util::future::future::Inspect<Fut,F> as core::future::future::Future>::poll::hd71826e475648f92
  17:     0x55ebdaccee24 - futures::task_impl::Spawn<T>::enter::{{closure}}::h1ec97cae90834d80
  18:     0x55ebdacceacf - <futures_util::compat::compat01as03::Compat01As03<Fut> as core::future::future::Future>::poll::hc1a22cd5dc620899
  19:     0x55ebdaccfd85 - tokio::runtime::task::raw::poll::h69cc3ceebe3efc74
  20:     0x55ebd9e02778 - tokio::runtime::thread_pool::worker::Context::run_task::h687bfabf878ede55
  21:     0x55ebd9e00b5e - tokio::runtime::thread_pool::worker::run::h267dfe3e1fefad0e
  22:     0x55ebd9dff787 - tokio::runtime::task::raw::poll::h864c965c892d94f0
  23:     0x55ebd9dfefd3 - std::sys_common::backtrace::__rust_begin_short_backtrace::h3f4eb75a4270382e
  24:     0x55ebd9dfeb72 - core::ops::function::FnOnce::call_once{{vtable.shim}}::h9badbba0802f3acf
  25:     0x55ebd9dedf8a - <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once::h1f1fac7de7dd9691
                               at /rustc/49cae55760da0a43428eba73abcb659bb70cf2e4/src/liballoc/boxed.rs:1008
  26:     0x55ebd9dedf8a - <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once::ha031f48633a6af54
                               at /rustc/49cae55760da0a43428eba73abcb659bb70cf2e4/src/liballoc/boxed.rs:1008
  27:     0x55ebd9dedf8a - std::sys::unix::thread::Thread::new::thread_start::h241864caf436e182
                               at src/libstd/sys/unix/thread.rs:87
  28:     0x7f082d95cfa3 - start_thread
  29:     0x7f082d6c44cf - clone
  30:                0x0 - <unknown>
Sep 17 22:04:13.089 ERROR sink{name=elasticsearch type=elasticsearch}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.089 ERROR transform{name=remove_fields type=remove_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.089  INFO vector: Vector has stopped.
Sep 17 22:04:13.089 ERROR transform{name=remove_fields type=remove_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.089 ERROR transform{name=add_fields type=add_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.090 ERROR transform{name=add_fields type=add_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.090 ERROR transform{name=add_kubernetes_index type=add_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.090 ERROR transform{name=add_kubernetes_index type=add_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.090 ERROR transform{name=add_kube_audit_index type=add_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.090 ERROR transform{name=add_kube_audit_index type=add_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.090 ERROR transform{name=add_rke_index type=add_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.090 ERROR transform{name=add_rke_index type=add_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.090 ERROR transform{name=add_system_index type=add_fields}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.090 ERROR transform{name=add_system_index type=add_fields}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.091 ERROR transform{name=router.kube_audit_logs type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.091 ERROR transform{name=router.kube_audit_logs type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.091 ERROR transform{name=kafka_parser type=json_parser}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.126 ERROR transform{name=router.rke_logs type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.126 ERROR transform{name=router.rke_logs type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.126 ERROR transform{name=kafka_parser type=json_parser}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.126 ERROR transform{name=router.syslog_auth_logs type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.126 ERROR transform{name=router.syslog_auth_logs type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.126 ERROR transform{name=kafka_parser type=json_parser}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.132 ERROR transform{name=container_logs.unstructured type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.132  INFO vector::topology: Shutting down... Waiting on: router.kubernetes_logs, container_logs.structured, structured_parser, dedot_labels, kafka_parser, container_logs.unstructured, kafka. 59 seconds left
Sep 17 22:04:13.132 ERROR transform{name=container_logs.unstructured type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.132 ERROR transform{name=dedot_labels type=lua}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.143 ERROR transform{name=structured_parser type=json_parser}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.143 ERROR transform{name=structured_parser type=json_parser}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.145 ERROR transform{name=container_logs.structured type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.145 ERROR transform{name=container_logs.structured type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.147 ERROR transform{name=dedot_labels type=lua}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.147 ERROR transform{name=dedot_labels type=lua}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.148 ERROR transform{name=router.kubernetes_logs type=swimlane}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.148 ERROR transform{name=router.kubernetes_logs type=swimlane}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.148 ERROR transform{name=kafka_parser type=json_parser}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.148 ERROR transform{name=kafka_parser type=json_parser}: vector::topology: An error occurred that vector couldn't handle.
Sep 17 22:04:13.148 ERROR source{name=kafka type=kafka}: vector::buffers: sender error: SendError("...")
Sep 17 22:04:13.148 ERROR source{name=kafka type=kafka}: vector::topology: An error occurred that vector couldn't handle.