TimelyDataflow/timely-dataflow

Issues

• Change DEFAULT_PROGRESS_MODE to TIMELY_PROGRESS_MODE

  #347 opened 4 years ago by rjnn
  1

• Failed to compile `timely_communication`

  #584 opened 2 months ago by nooberfsh
  0

• Broadcast message to all worker nodes while in closure of custom binary frontier operator

  #583 opened 2 months ago by cygithub54
  1

• Replace/augment Instant::now() so Timely could run in the browser

  #531 opened 7 months ago by sergiyprotsiv
  1

• Unreproducible release for timely 0.12.0

  #559 opened 7 months ago by paolobarbolini
  0

• Single element stream

  #549 opened 8 months ago by LennardEc
  1

• Introduce unordered timestamps do a dataflow

  #532 opened a year ago by rafaelcgs10
  4

• Dynamically adding/removing workers

  #529 opened a year ago by conradoverta
  2

• Cannot run basic example on fresh clone of repo

  #528 opened a year ago by tgeorg-ethz
  2

• Passing empty containers to `Session::give_container` can stall downstream frontier

  #523 opened a year ago by teskje
  3

• Remove `Core` variants of various types

  #510 opened 2 years ago by antiguru
  0

• Make MutableAntichain consolidate even without frontier advancement

  #504 opened 2 years ago by teskje
  0

• Build timely cluster

  #483 opened 2 years ago by QiZhang1997
  2

• Primes example... slower with more workers?

  #479 opened 2 years ago by davideger
  1

• Activator: Bound memory utilization by compaction and de-duplication

  #470 opened 2 years ago by antiguru
  0

• Should provide python api?

  #324 opened 5 years ago by zhanglistar
  2

• Promote `bincode` to the default serialization implementation

  #433 opened 3 years ago by antiguru
  0

• Feedback docs mention `limit`, which is not defined or used anywhere else

  #424 opened 3 years ago by umanwizard
  1

• Cannot exchange serde_json::Value

  #423 opened 3 years ago by ankrgyl
  2

• Wordcount Example does not compile (no method named `retain`)

  #422 opened 3 years ago by ankrgyl
  2

• Support serializing internal state

  #344 opened 4 years ago by Kixiron
  5

• `timely::CommunicationConfig::Cluster`: Syscall param socketcall.sendto(msg) points to uninitialised byte(s)

  #399 opened 3 years ago by dreraic
  4

• Wasm Support?

  #402 opened 3 years ago by joshpoll
  0

• Notificator notification count is always 1

  #395 opened 3 years ago by antiguru
  0

• Lazy memory allocation in channel pushers.

  #394 opened 3 years ago by ryzhyk
  6

• Allow making conditional regions

  #392 opened 3 years ago by Kixiron
  1

• builder_rc::OperatorBuilder lacks shape methods

  #390 opened 3 years ago by Kixiron
  0

• Consider a robust TCP / etc communication fabric

  #386 opened 4 years ago by frankmcsherry
  0

• Regions have non-trivial overhead

  #382 opened 4 years ago by Kixiron
  0

• Too casually nested regions / scopes hang

  #377 opened 4 years ago by frankmcsherry
  4

• Provide re-usable shared `MutableAntichain`

  #368 opened 4 years ago by frankmcsherry
  0

• Scaling issue when there are more workers than cores.

  #362 opened 4 years ago by ryzhyk
  6

• Consider marking streams as `MustUse`.

  #358 opened 4 years ago by frankmcsherry
  1

• Allow TimelyProgressEvent to be used with serde

  #356 opened 4 years ago by Kixiron
  0

• Add a FilterMap operator

  #355 opened 4 years ago by Kixiron
  3

• Changing default allocation size in `channel/mod.rs`

  #346 opened 4 years ago by ryzhyk
  6

• Your documentation text is superb

  #345 opened 4 years ago by jvivaspatternag
  1

• Tracking progress towards completion.

  #340 opened 4 years ago by ryzhyk
  1

• Fn vs FnMut in operators

  #341 opened 4 years ago by amosonn
  1

• Exchange to zero-th worker?

  #336 opened 4 years ago by longbinlai
  4

• Rust Playground won't run examples.

  #303 opened 4 years ago by dswalter
  1

• Disable asynchronous message transfer?

  #334 opened 4 years ago by cheonruen
  1

• Accumulate Weird Behaviour

  #328 opened 4 years ago by dbyr
  1

• Research Question For Highly Concurrent Systems

  #323 opened 5 years ago by gatoWololo
  0

• [Docs] Clarify failure modes of multiple workers and clusters

  #319 opened 5 years ago by tarqd
  2

• How to: Pass resource into Map closure

  #318 opened 5 years ago by gregberns
  5

• `state_machine` may act on inputs before the frontier has advanced past them (or maybe not)

  #316 opened 5 years ago by utaal
  3

• Dataflow construction seems slow-ish

  #308 opened 5 years ago by frankmcsherry
  1

• What's the right way to ingest real world datasets?

  #307 opened 5 years ago by top1select
  2

• Pro-active dataflow termination

  #306 opened 5 years ago by frankmcsherry
  0