Alibaba JStorm
2.4.0
16 May 2017
JStorm is a distributed and fault-tolerant realtime computation system. It was inspired by and is API-wise a superset of Apache Storm, but reimplemented fully in Java. JStorm adds many new features, and is already widely used in business and enterprise environments.
minor feature: 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. . 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 . 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. 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. The of incorrect computation of unstopped tasks when assigning topology. The that supervisor storm.yaml is always different from nimbus storm.yaml. The that kryo doesn't accept conf value of literal string "true"/"false". Thanks to @gohitbear @bryant1410 @oubenruing for doc. Thanks to @zeromem @elloray @yunfan123 @iBuddha @Glowdable @waooog for.
