Skip to content

Commit

Permalink
0.12 changes (#372)
Browse files Browse the repository at this point in the history
  • Loading branch information
frankmcsherry authored Mar 10, 2021
1 parent 13b7397 commit ac0a326
Show file tree
Hide file tree
Showing 23 changed files with 19 additions and 1,785 deletions.
4 changes: 3 additions & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

All notable changes to this project will be documented in this file.

## Unreleased
## 0.12.0

The `Timestamp` trait has a new method `minimim()` that replaces Timely's use of `Default::default()` for default capabilities. The most pressing reason for this is the use of signed integers for timestamps, where Timely would effectively prevent the use of negative numbers by providing the default value of zero for capabilities. This should not have reduced any functionality, but might provide surprising output for programs that use integer timestamps and do not first advance timestamps (the tidy `0` will be replaced with `_::min_value()`).

Expand All @@ -18,6 +18,8 @@ Removed all deprecated methods and traits.

Timely no longer responds to the `DEFAULT_PROGRESS_MODE` environment variable. Instead, it uses the newly added `worker::Config`.

Removed the `sort` crate, whose sorting methods are interesting but not currently a core part of timely dataflow.

### Changed

The default progress mode changed from "eager" to "demand driven", which causes progress updates to be accumulated for longer before transmission. The eager default had the potential to produce catastrophically large volumes of progress update messages, for the benefit of a reduced critical path latency. The demand-driven default removes the potential for catastrophic failure at the expense of an increase minimal latency. This should give a better default experience as one scales up the to large numbers of workers.
Expand Down
1 change: 0 additions & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ members = [
"communication",
"kafkaesque",
"logging",
# "sort",
"timely",
]

Expand Down
2 changes: 1 addition & 1 deletion bytes/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "timely_bytes"
version = "0.11.0"
version = "0.12.0"
authors = ["Frank McSherry <[email protected]>"]
edition = "2018"

Expand Down
6 changes: 3 additions & 3 deletions communication/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "timely_communication"
version = "0.11.1"
version = "0.12.0"
authors = ["Frank McSherry <[email protected]>"]
description = "Communication layer for timely dataflow"
edition = "2018"
Expand All @@ -23,6 +23,6 @@ serde_derive = "1.0"
serde = "1.0"
abomonation = "0.7"
abomonation_derive = "0.5"
timely_bytes = { path = "../bytes", version = "0.11" }
timely_logging = { path = "../logging", version = "0.11" }
timely_bytes = { path = "../bytes", version = "0.12" }
timely_logging = { path = "../logging", version = "0.12" }
crossbeam-channel = "0.5.0"
2 changes: 1 addition & 1 deletion kafkaesque/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "kafkaesque"
version = "0.1.0"
version = "0.12.0"
authors = ["Frank McSherry <[email protected]>"]
edition = "2018"

Expand Down
2 changes: 1 addition & 1 deletion logging/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "timely_logging"
version = "0.11.1"
version = "0.12.0"
authors = ["Frank McSherry <[email protected]>"]
edition = "2018"

Expand Down
2 changes: 0 additions & 2 deletions sort/.gitignore

This file was deleted.

24 changes: 0 additions & 24 deletions sort/Cargo.toml

This file was deleted.

22 changes: 0 additions & 22 deletions sort/LICENSE

This file was deleted.

37 changes: 0 additions & 37 deletions sort/README.md

This file was deleted.

Loading

0 comments on commit ac0a326

Please sign in to comment.