This repository has been archived by the owner on Jun 16, 2023. It is now read-only.
New features
- Support exactly-once with async checkpoint via rocksdb and HDFS.
- Introduce new window mechanism
- supports tumbling window and sliding window.
- supports count window, processing time window, event time window, session window.
- doesn't hold all data before a window is triggered, computes on data arrival.
- Support gray upgrade
- supports per worker/component gray upgrade
- supports upgrade rollback
- Add memory/rocksdb-based KV store.
- HBase metrics plugin is open source
- Support multiple metrics uploaders.
- Add api in MetricClient to register topology-level metrics
- Support component stream metrics, i.e., stream metrics aggregated in components
Improvements
- Support deserialize for no-arg class in kryo
- add getValue method in AsmMetric for quick assert so that unit tests/integration tests don't have to get metrics from
nimbus
Bug Fix
- Fix the bug of incorrect computation of unstopped tasks when assigning topology
- Fix the bug that supervisor storm.yaml is always different from nimbus storm.yaml
- Fix the bug that kryo doesn't accept conf value of literal string "true"/"false"
- Thanks to @gohitbear @bryant1410 @oubenruing for doc fixes.
- Thanks to @zeromem @elloray @yunfan123 @iBuddha @Glowdable @waooog for bug fixes.