Storm 2.6.0.2 «iPhone Trending»

FROM openjdk:11-jre-slim RUN wget https://archive.apache.org/dist/storm/apache-storm-2.6.0.2/apache-storm-2.6.0.2.tar.gz RUN tar -xzf apache-storm-2.6.0.2.tar.gz ENV STORM_HOME=/apache-storm-2.6.0.2 CMD ["bin/storm", "nimbus"] End of paper.

| Metric | Storm 2.5.4 | Storm 2.6.0.2 | Improvement | |--------|-------------|---------------|--------------| | Avg latency (p99) | 47 ms | 38 ms | 19% | | Max throughput (no backpressure) | 85k msg/s | 102k msg/s | 20% | | Worker OOM errors (24h run) | 4 | 0 | 100% | | Kafka rebalance time | 12 sec | 5 sec | 58% | storm 2.6.0.2

supervisor.memory.safety.margin.mb: 512 Prevents supervisor from oversubscribing worker memory. Prometheus endpoint enabled by default on Nimbus and Supervisor ports: FROM openjdk:11-jre-slim RUN wget https://archive