benesch

May 03 00:40:46.542 DEBUG librdkafka: librdkafka: MEMBERID [thrd:app]: Group "materialize-kafka-u1/u2": updating member id "(not-set)" -> ""    
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups    
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: GroupCoordinator: Added new broker with NodeId -1    
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups    
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1    
May 03 00:40:46.542 DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v1.4.2 (0x10402ff) materialized#consumer-3 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,sasl_oauthbearer, CMAKE GNU GNU PKGCONFIG HDRHISTOGRAM ZLIB LIBDL PLUGINS SSL SASL_SCRAM SASL_OAUTHBEARER SASL_CYRUS C11THREADS C

benesch

diff --git a/src/coord/timestamp.rs b/src/coord/timestamp.rs
index e598528b..90a74aaf 100644
--- a/src/coord/timestamp.rs
+++ b/src/coord/timestamp.rs
@@ -20,7 +20,6 @@ use std::time::{Duration, SystemTime, UNIX_EPOCH};
 
 use avro::schema::Schema;
 use avro::types::Value;
-
 use lazy_static::lazy_static;

benesch

 285200 11897  core::ptr::real_drop_in_place
 273772 1913  core::iter::traits::iterator::Iterator::try_fold
 188306 2058  core::option::Option<T>::map
 160776  396  alloc::raw_vec::RawVec<T,A>::reserve_internal
  99375  895  core::result::Result<T,E>::map
  66836  232  serde::ser::Serializer::collect_seq
  62964  159  timely::dataflow::operators::generic::builder_rc::OperatorBuilder<G>::build::{{closure}}
  56983  277  <alloc::vec::Vec<T> as alloc::vec::SpecExtend<T,I>>::spec_extend
  55235  159  timely::dataflow::operators::generic::builder_rc::OperatorBuilder<G>::build
  52750 1029  core::iter::traits::iterator::Iterator::fold

benesch

Let {
  l5 = Distinct {
    group_key: [#3],
    Get { materialize.public.tab0 (u1) }
  }
} in
Let {
  l9 = Reduce {
    group_key: [#0],
    aggregates: [any(#0 = #2)],

benesch

benesch@langur$ cargo check
    Checking pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused imports: `Future`, `future`
  --> src/pgwire/lib.rs:21:15
   |
21 | use futures::{future, Future};
   |               ^^^^^^  ^^^^^^
   |
   = note: `#[warn(unused_imports)]` on by default

benesch

benesch@langur$ cargo check
    Checking pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused imports: `Future`, `future`
  --> src/pgwire/lib.rs:21:15
   |
21 | use futures::{future, Future};
   |               ^^^^^^  ^^^^^^
   |
   = note: `#[warn(unused_imports)]` on by default

benesch

benesch@langur$ cargo test -p materialized -- prepared
   Compiling pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire)
warning: unused import: `Row`
  --> src/pgwire/codec.rs:28:19
   |
28 | use repr::{Datum, Row, ScalarType};
   |                   ^^^
   |
   = note: `#[warn(unused_imports)]` on by default

benesch

diff --git a/Cargo.lock b/Cargo.lock
index b2d13ca..d88fd6c 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -36,7 +36,7 @@ dependencies = [
  "fnv 1.0.6 (registry+https://github.com/rust-lang/crates.io-index)",
  "serde 1.0.99 (registry+https://github.com/rust-lang/crates.io-index)",
  "serde_derive 1.0.99 (registry+https://github.com/rust-lang/crates.io-index)",
- "timely 0.10.0 (git+https://github.com/TimelyDataflow/timely-dataflow)",
+ "timely 0.10.0 (git+https://github.com/benesch/timely-dataflow.git?branch=sample)",

benesch

diff --git a/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go b/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
index a88e4f6068..e0702f3336 100644
--- a/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
+++ b/src/github.com/cockroachdb/cockroach/pkg/server/config_unix.go
@@ -22,6 +22,7 @@ import (

 	"github.com/cockroachdb/cockroach/pkg/storage/engine"
 	"github.com/cockroachdb/cockroach/pkg/util/log"
+	"github.com/pkg/errors"
 )

benesch

source root is source
unpacking source archive /nix/store/03fgfsvjcchgyg0jjy6i420ffvdql89d-rustup-1.16.0-vendor
patching sources
configuring
building
Running cargo build --release --features no-self-update
   Compiling semver-parser v0.7.0
   Compiling version_check v0.1.5
   Compiling rand_core v0.3.0
   Compiling void v1.0.2