Materialize: COPY TO STDOUT not working

[pikulmar]

What version of Materialize are you using?

$ docker run --rm -it -p 6875:6875 materialize/materialized:v0.5.1 -v
materialized v0.5.1 (44e1c06b7c84297bfa8bdf656103eab46c75cde4)

How did you install Materialize?

• [x] Docker image
• [ ] Linux release tarball
• [ ] APT package
• [ ] macOS release tarball
• [ ] Homebrew tap
• [ ] Built from source

What was the issue?

After starting Materialize with

docker run --rm -it -p 6875:6875 materialize/materialized:v0.5.1 --workers=1

the following psql client session results in a Materialize panic:

$ psql postgres://localhost:6875/materialize
psql (12.4 (Ubuntu 12.4-0ubuntu0.20.04.1), server 9.5.0)
Type "help" for help.

materialize=> CREATE MATERIALIZED VIEW IF NOT EXISTS events (id) AS VALUES (1), (2);
CREATE VIEW

materialize=> SELECT * FROM events;
 id
----
  1
  2
(2 rows)

materialize=> COPY (TAIL events) TO STDOUT;
server closed the connection unexpectedly
        This probably means the server terminated abnormally
        before or while processing the request.
The connection to the server was lost. Attempting reset: Failed.
!> \q

Is the issue reproducible? If so, please provide reproduction instructions.

Yes, see issue description.

Please attach any applicable log files.

Docker container logs:

Nov 10 10:53:02.170  INFO materialized: booting server
materialized v0.5.1 (44e1c06b7)
OpenSSL 1.1.1g  21 Apr 2020
librdkafka v1.5.0
invoked as: materialized '--log-file=stderr' '--workers=1'
os: Ubuntu 18.4.0 [64-bit]
cpus: 8 logical, 4 physical
cpu0: Intel(R) Core(TM) i7-8665U CPU @ 1.90GHz 2112MHz
memory: 26074472KB total, 4601940KB used
swap: 7340032KB total, 15616KB used
Nov 10 10:53:02.215  INFO coord::catalog: create source mz_catalog.mz_dataflow_operators (s1000)
Nov 10 10:53:02.215  INFO coord::catalog: create index mz_catalog.mz_dataflow_operators_primary_idx (s1001)
Nov 10 10:53:02.215  INFO coord::catalog: create source mz_catalog.mz_dataflow_operator_addresses (s1002)
Nov 10 10:53:02.215  INFO coord::catalog: create index mz_catalog.mz_dataflow_operator_addresses_primary_idx (s1003)
Nov 10 10:53:02.215  INFO coord::catalog: create source mz_catalog.mz_dataflow_channels (s1004)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_dataflow_channels_primary_idx (s1005)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_scheduling_elapsed (s1006)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_scheduling_elapsed_primary_idx (s1007)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_scheduling_histogram (s1008)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_scheduling_histogram_primary_idx (s1009)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_scheduling_parks (s1010)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_scheduling_parks_primary_idx (s1011)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_arrangement_sizes (s1012)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_arrangement_sizes_primary_idx (s1013)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_arrangement_sharing (s1014)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_arrangement_sharing_primary_idx (s1015)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_materializations (s1016)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_materializations_primary_idx (s1017)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_materialization_dependencies (s1018)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_materialization_dependencies_primary_idx (s1019)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_worker_materialization_frontiers (s1020)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_worker_materialization_frontiers_primary_idx (s1021)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_peek_active (s1022)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_peek_active_primary_idx (s1023)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_peek_durations (s1024)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_peek_durations_primary_idx (s1025)
Nov 10 10:53:02.216  INFO coord::catalog: create source mz_catalog.mz_source_info (s1026)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_source_info_primary_idx (s1027)
Nov 10 10:53:02.216  INFO coord::catalog: create table mz_catalog.mz_view_keys (s2001)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_view_keys_primary_idx (s2002)
Nov 10 10:53:02.216  INFO coord::catalog: create table mz_catalog.mz_view_foreign_keys (s2003)
Nov 10 10:53:02.216  INFO coord::catalog: create index mz_catalog.mz_view_foreign_keys_primary_idx (s2004)
Nov 10 10:53:02.216  INFO coord::catalog: create table mz_catalog.mz_kafka_sinks (s2005)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_kafka_sinks_primary_idx (s2006)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_avro_ocf_sinks (s2007)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_avro_ocf_sinks_primary_idx (s2008)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_databases (s2009)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_databases_primary_idx (s2010)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_schemas (s2011)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_schemas_primary_idx (s2012)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_columns (s2013)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_columns_primary_idx (s2014)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_indexes (s2015)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_indexes_primary_idx (s2016)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_index_columns (s2017)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_index_columns_primary_idx (s2018)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_tables (s2019)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_tables_primary_idx (s2020)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_sources (s2021)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_sources_primary_idx (s2022)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_sinks (s2023)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_sinks_primary_idx (s2024)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_views (s2025)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_views_primary_idx (s2026)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_builtin_types (s2027)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_builtin_types_primary_idx (s2028)
Nov 10 10:53:02.217  INFO coord::catalog: create table mz_catalog.mz_map_types (s2029)
Nov 10 10:53:02.217  INFO coord::catalog: create index mz_catalog.mz_map_types_primary_idx (s2030)
Nov 10 10:53:02.218  INFO coord::catalog: create view mz_catalog.mz_relations (s3000)
Nov 10 10:53:02.219  INFO coord::catalog: create view mz_catalog.mz_objects (s3001)
Nov 10 10:53:02.221  INFO coord::catalog: create view mz_catalog.mz_catalog_names (s3002)
Nov 10 10:53:02.221  INFO coord::catalog: create view mz_catalog.mz_addresses_with_unit_length (s3003)
Nov 10 10:53:02.222  INFO coord::catalog: create view mz_catalog.mz_dataflow_names (s3004)
Nov 10 10:53:02.223  INFO coord::catalog: create view mz_catalog.mz_dataflow_operator_dataflows (s3005)
Nov 10 10:53:02.223  INFO coord::catalog: create view mz_catalog.mz_materialization_frontiers (s3006)
Nov 10 10:53:02.224  INFO coord::catalog: create view mz_catalog.mz_records_per_dataflow_operator (s3007)
Nov 10 10:53:02.225  INFO coord::catalog: create view mz_catalog.mz_records_per_dataflow (s3008)
Nov 10 10:53:02.225  INFO coord::catalog: create view mz_catalog.mz_records_per_dataflow_global (s3009)
Nov 10 10:53:02.226  INFO coord::catalog: create view mz_catalog.mz_perf_arrangement_records (s3010)
Nov 10 10:53:02.227  INFO coord::catalog: create view mz_catalog.mz_perf_peek_durations_core (s3011)
Nov 10 10:53:02.227  INFO coord::catalog: create view mz_catalog.mz_perf_peek_durations_bucket (s3012)
Nov 10 10:53:02.228  INFO coord::catalog: create view mz_catalog.mz_perf_peek_durations_aggregates (s3013)
Nov 10 10:53:02.229  INFO coord::catalog: create view mz_catalog.mz_perf_dependency_frontiers (s3014)
Nov 10 10:53:02.229  INFO coord::catalog: create view pg_catalog.pg_namespace (s3015)
Nov 10 10:53:02.230  INFO coord::catalog: create view pg_catalog.pg_class (s3016)
Nov 10 10:53:02.230  INFO coord::catalog: create view pg_catalog.pg_database (s3017)
Nov 10 10:53:02.230  INFO coord::catalog: create view pg_catalog.pg_index (s3018)
Nov 10 10:53:02.231  INFO coord::catalog: create view pg_catalog.pg_description (s3019)
Nov 10 10:53:02.231  INFO coord::catalog: create view pg_catalog.pg_attribute (s3020)
Nov 10 10:53:02.231  INFO coord::catalog: create view pg_catalog.pg_type (s3021)
Nov 10 10:53:02.231  INFO coord::catalog: create view pg_catalog.pg_proc (s3022)
Nov 10 10:53:02.232  INFO coord::catalog: create view pg_catalog.pg_range (s3023)
Nov 10 10:53:02.232  INFO coord::catalog: create view pg_catalog.pg_enum (s3024)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.bool (s4000)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.bytea (s4001)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.int8 (s4002)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.int4 (s4003)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.text (s4004)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.oid (s4005)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.float4 (s4006)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.float8 (s4007)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._bool (s4008)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._bytea (s4009)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._int4 (s4010)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._text (s4011)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._int8 (s4012)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._float4 (s4013)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._float8 (s4014)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._oid (s4015)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.date (s4016)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.time (s4017)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.timestamp (s4018)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._timestamp (s4019)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._date (s4020)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._time (s4021)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.timestamptz (s4022)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._timestamptz (s4023)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.interval (s4024)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._interval (s4025)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._numeric (s4026)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.numeric (s4027)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.record (s4028)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._record (s4029)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.uuid (s4030)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._uuid (s4031)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog.jsonb (s4032)
Nov 10 10:53:02.232  INFO coord::catalog: create type pg_catalog._jsonb (s4033)
=======================================================================
Thank you for trying Materialize!

We are interested in any and all feedback you have, which may be able
to improve both our software and your queries! Please reach out at:

    Web: https://materialize.io
    GitHub issues: https://github.com/MaterializeInc/materialize/issues
    Email: [email protected]
    Twitter: @MaterializeInc
=======================================================================

materialized v0.5.1 (44e1c06b7) listening on 0.0.0.0:6875...
Nov 10 10:53:02.240  INFO coord::timestamp: Starting Timestamping Thread. Frequency: 10 ms.
Nov 10 10:53:10.207  INFO coord::catalog: create view materialize.public.events (u1)
Nov 10 10:53:10.208  INFO coord::catalog: create index materialize.public.events_primary_idx (u2)
Nov 10 10:53:20.977 ERROR panic: tokio:worker: missing row description for ExecuteResponse::CopyTo
   0: materialized::handle_panic
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/materialized/src/bin/materialized/main.rs:540:65
   1: core::ops::function::Fn::call
             at usr/local/lib/rustlib/src/rust/library/core/src/ops/function.rs:70:5
   2: std::panicking::rust_panic_with_hook
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/std/src/panicking.rs:573:17
   3: std::panicking::begin_panic_handler::{{closure}}
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/std/src/panicking.rs:476:9
   4: std::sys_common::backtrace::__rust_end_short_backtrace
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/std/src/sys_common/backtrace.rs:153:18
   5: rust_begin_unwind
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/std/src/panicking.rs:475:5
   6: core::panicking::panic_fmt
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/core/src/panicking.rs:85:14
   7: core::option::expect_failed
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/core/src/option.rs:1213:5
   8: core::option::Option<T>::expect
             at usr/local/lib/rustlib/src/rust/library/core/src/option.rs:333:21
      pgwire::protocol::StateMachine<A>::send_execute_response::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/protocol.rs:727:21
   9: <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      pgwire::protocol::StateMachine<A>::one_query::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/protocol.rs:307:17
      <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      pgwire::protocol::StateMachine<A>::query::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/protocol.rs:327:19
      <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      pgwire::protocol::StateMachine<A>::advance_ready::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/protocol.rs:125:53
  10: <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      pgwire::protocol::StateMachine<A>::run::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/protocol.rs:105:37
      <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      pgwire::server::Server::handle_connection::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/pgwire/src/server.rs:68:31
  11: <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
      <pgwire::server::Server as materialized::mux::ConnectionHandler>::handle_connection::__handle_connection::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/materialized/src/mux.rs:139:9
      <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
  12: <core::pin::Pin<P> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/future.rs:121:9
      materialized::mux::handle_connection::{{closure}}
             at var/lib/buildkite-agent/builds/buildkite-builders-i-04ad70c412b35f581-1/materialize/tests/src/materialized/src/mux.rs:100:29
      <core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll
             at usr/local/lib/rustlib/src/rust/library/core/src/future/mod.rs:79:19
  13: tokio::runtime::task::core::Core<T,S>::poll::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/core.rs:173:17
      tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/loom/std/unsafe_cell.rs:14:9
      tokio::runtime::task::core::Core<T,S>::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/core.rs:158:13
      tokio::runtime::task::harness::Harness<T,S>::poll::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/harness.rs:107:27
      core::ops::function::FnOnce::call_once
             at usr/local/lib/rustlib/src/rust/library/core/src/ops/function.rs:227:5
      <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:308:9
  14: std::panicking::try::do_call
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:373:40
      std::panicking::try
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:337:19
      std::panic::catch_unwind
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:379:14
      tokio::runtime::task::harness::Harness<T,S>::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/harness.rs:89:19
      tokio::runtime::task::raw::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/raw.rs:104:5
  15: tokio::runtime::task::raw::RawTask::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/raw.rs:66:18
      tokio::runtime::task::Notified<S>::run
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/mod.rs:169:9
      tokio::runtime::thread_pool::worker::Context::run_task::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:353:13
      tokio::coop::with_budget::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/coop.rs:127:9
      std::thread::local::LocalKey<T>::try_with
             at usr/local/lib/rustlib/src/rust/library/std/src/thread/local.rs:265:16
      std::thread::local::LocalKey<T>::with
             at usr/local/lib/rustlib/src/rust/library/std/src/thread/local.rs:241:9
  16: tokio::coop::with_budget
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/coop.rs:120:5
      tokio::coop::budget
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/coop.rs:96:5
      tokio::runtime::thread_pool::worker::Context::run_task
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:352:9
  17: tokio::runtime::thread_pool::worker::Context::run
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:324:24
  18: tokio::runtime::thread_pool::worker::run::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:309:17
      tokio::macros::scoped_tls::ScopedKey<T>::set
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/macros/scoped_tls.rs:63:9
  19: tokio::runtime::thread_pool::worker::run
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:306:5
  20: tokio::runtime::thread_pool::worker::Launch::launch::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/thread_pool/worker.rs:285:45
      <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/blocking/task.rs:41:21
      tokio::runtime::task::core::Core<T,S>::poll::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/core.rs:173:17
      tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/loom/std/unsafe_cell.rs:14:9
      tokio::runtime::task::core::Core<T,S>::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/core.rs:158:13
  21: tokio::runtime::task::harness::Harness<T,S>::poll::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/harness.rs:107:27
      core::ops::function::FnOnce::call_once
             at usr/local/lib/rustlib/src/rust/library/core/src/ops/function.rs:227:5
      <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:308:9
  22: std::panicking::try::do_call
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:373:40
      std::panicking::try
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:337:19
      std::panic::catch_unwind
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:379:14
      tokio::runtime::task::harness::Harness<T,S>::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/harness.rs:89:19
  23: tokio::runtime::task::raw::RawTask::poll
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/raw.rs:66:18
      tokio::runtime::task::Notified<S>::run
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/task/mod.rs:169:9
      tokio::runtime::blocking::pool::Inner::run
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/blocking/pool.rs:230:17
  24: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}}::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/blocking/pool.rs:210:21
      tokio::runtime::context::enter
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/context.rs:72:5
  25: tokio::runtime::handle::Handle::enter
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/handle.rs:76:9
      tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}}
             at cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/runtime/blocking/pool.rs:209:17
      std::sys_common::backtrace::__rust_begin_short_backtrace
             at usr/local/lib/rustlib/src/rust/library/std/src/sys_common/backtrace.rs:137:18
  26: std::thread::Builder::spawn_unchecked::{{closure}}::{{closure}}
             at usr/local/lib/rustlib/src/rust/library/std/src/thread/mod.rs:458:17
      <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:308:9
      std::panicking::try::do_call
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:373:40
      std::panicking::try
             at usr/local/lib/rustlib/src/rust/library/std/src/panicking.rs:337:19
      std::panic::catch_unwind
             at usr/local/lib/rustlib/src/rust/library/std/src/panic.rs:379:14
      std::thread::Builder::spawn_unchecked::{{closure}}
             at usr/local/lib/rustlib/src/rust/library/std/src/thread/mod.rs:457:30
      core::ops::function::FnOnce::call_once{{vtable.shim}}
             at usr/local/lib/rustlib/src/rust/library/core/src/ops/function.rs:227:5
  27: <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/alloc/src/boxed.rs:1042:9
      <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/alloc/src/boxed.rs:1042:9
      std::sys::unix::thread::Thread::new::thread_start
             at rustc/18bf6b4f01a6feaf7259ba7cdae58031af1b7b39/library/std/src/sys/unix/thread.rs:87:17
  28: start_thread
  29: __clone

materialized encountered an internal error and crashed.

We rely on bug reports to diagnose and fix these errors. Please
copy and paste the above details and file a report at:

    https://materialize.io/s/bug

To protect your privacy, we do not collect crash reports automatically.

[umanwizard]

@mjibson could you please take a look?

[benesch]

I'm looking into this for the moment.

[benesch]

Sorry about this, @pikulmar, and thanks very much for the report! This bug is actually already fixed on the main branch, so if you're able to use unstable builds for a bit, COPY ... TO STDOUT should work via psql. If not, it'll ship in v0.5.2 next week or so. I've opened #4746 to get the issue documented.

[pikulmar]

Thanks a lot for the very prompt response/resolution @benesch. You and your colleagues have created a really great piece of software!