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
{{ message }}
This repository was archived by the owner on Feb 12, 2022. It is now read-only.
-[PR-37](https://github.com/salesforce/storm-dynamic-spout/pull/37) Added hasStep() and getStep() to `FilterChain` and added a specific exception for serializing/deserializing `FilterChainStep` objects.
15
+
-[PR-40](https://github.com/salesforce/storm-dynamic-spout/pull/40) Timer metrics will now publish a counter metric containing the total time spent within each metric key. Start publishing developer performance metrics within VirtualSpout via MetricRecorder.
16
+
-[PR-45](https://github.com/salesforce/storm-dynamic-spout/pull/45) MetricRecorder is now passed into Consumer interface via open() method.
17
+
-[PR-55](https://github.com/salesforce/storm-dynamic-spout/pull/55) Refactored how DynamicSpout coordinates with VirtualSpouts internally.
15
18
-[PR-85](https://github.com/salesforce/storm-dynamic-spout/pull/85) Fix ordering bug in DefaultRetryManager. Always retry the earliest messageId.
16
19
-[PR-90](https://github.com/salesforce/storm-dynamic-spout/pull/90) Adds new 'Permanently Failed' output stream. Tuples that exceed the configured retry limit will now be emitted out a 'failed' stream un-anchored. This allows you to do your own error handling within the topology by subscribing to this stream. The name of this output stream defaults to 'failed', but is configurable via the `spout.permanently_failed_output_stream_id` configuration item.
20
+
-[PR-101](https://github.com/salesforce/storm-dynamic-spout/pull/101) Fix NPE in RatioMessageBuffer on Spout deploy.
21
+
-[PR-104](https://github.com/salesforce/storm-dynamic-spout/pull/104) Allow curator exceptions to bubble up
17
22
-[PR-110](https://github.com/salesforce/storm-dynamic-spout/pull/110) Fix exponential retry delay growth in DefaultRetryManager.
18
-
-[ISSUE-100](https://github.com/salesforce/storm-dynamic-spout/issues/100) Fix NPE in RatioMessageBuffer on Spout deploy.
23
+
-[PR-111](https://github.com/salesforce/storm-dynamic-spout/pull/111) Update dependencies and cleanup
19
24
20
25
#### Removed
21
26
-[PR-45](https://github.com/salesforce/storm-dynamic-spout/pull/45) Removed getMaxLag() from Consumer interface.
22
27
-[PR-81](https://github.com/salesforce/storm-dynamic-spout/pull/81) Removed getPersistenceAdapter() from Consumer interface.
23
28
24
-
#### Improvements
25
-
-[PR-37](https://github.com/salesforce/storm-dynamic-spout/pull/37) Added hasStep() and getStep() to `FilterChain` and added a specific exception for serializing/deserializing FilterChainSteps.
26
-
-[PR-40](https://github.com/salesforce/storm-dynamic-spout/pull/40) Timer metrics will now publish a counter metric containing the total time spent within each metric key. Start publishing developer performance metrics within VirtualSpout via MetricRecorder.
27
-
-[PR-45](https://github.com/salesforce/storm-dynamic-spout/pull/45) MetricRecorder is now passed into Consumer interface via open() method.
28
-
-[PR-55](https://github.com/salesforce/storm-dynamic-spout/pull/55) Refactored how DynamicSpout coordinates with VirtualSpouts internally.
29
-
30
29
### Sideline Framework
31
30
In this release the 'stop' sideline state was split into 'resume' and 'resolve', allowing for one to begin processing a sideline without designating an ending offset and then applying an ending offset later on. Based upon our experience this is a more practical division of state for sidelining.
0 commit comments