You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: CHANGELOG.md
+4-1
Original file line number
Diff line number
Diff line change
@@ -1,5 +1,8 @@
1
1
## Unreleased
2
2
3
+
NOTE: The change from 0.7.0 in which OutputCollector no longer assumes immutable inputs has been reverted to support optimized sending of tuples to colocated tasks
4
+
5
+
* Messages sent to colocated tasks are sent in-memory, skipping serialization (useful in conjunction with localOrShuffle grouping) (thanks xumingming)
3
6
* Upgrade to Clojure 1.4 (thanks sorenmacbeth)
4
7
* Can override the hostname that supervisors report using "storm.local.hostname" config.
5
8
* Make request timeout within DRPC server configurable via "drpc.request.timeout.secs"
@@ -69,7 +72,7 @@
69
72
* Logging now always goes to logs/ in the Storm directory, regardless of where you launched the daemon (thanks haitaoyao)
70
73
* Improved Clojure DSL: can emit maps and Tuples implement the appropriate interfaces to integrate with Clojure's seq functions (thanks schleyfox)
71
74
* Added "ui.childopts" config (thanks ddillinger)
72
-
* Bug fix: OutputCollector no longer assumes immutable inputs
75
+
* Bug fix: OutputCollector no longer assumes immutable inputs[NOTE: this was reverted in 0.7.2 because it conflicts with sending tuples to colocated tasks without serialization]
73
76
* Bug fix: DRPC topologies now throw a proper error when no DRPC servers are configured instead of NPE (thanks danharvey)
74
77
* Bug fix: Fix local mode so multiple topologies can be run on one LocalCluster
75
78
* Bug fix: "storm supervisor" now uses supervisor.childopts instead of nimbus.childopts (thanks ddillinger)
0 commit comments