INFO nimbus - [Storm 2.6.0.2] Nimbus server started with leader-id ... INFO worker - Successfully registered with supervisor using new backpressure controller. | Symptom | Likely Cause | Fix in 2.6.0.2 | |---------|--------------|------------------| | KryoException: Class not registered | Strict deserialization | Set topology.kryo.register.required: false (temporary) or migrate to registered classes. | | Worker fails to start with Address already in use | Netty port range collision | Recalculate supervisor.slots.ports ; 2.6.0.2 validates overlapping ports at startup. | | ZooKeeper ConnectionLoss loop | Legacy ZK chroot path | Ensure storm.zookeeper.root ends with a slash (e.g., /storm-app/ ). Fixed parsing in this version. | Part 4: Performance Benchmark – Storm 2.6.0.2 vs 2.5.0 To illustrate the real-world impact of this release, a benchmark was run on a 5-node cluster (c5.2xlarge on AWS, 8 vCPUs, 16GB RAM per node). The topology: a simple IntegerGeneratorSpout -> DoubleBolt -> LoggerBolt , 64 executors, 4 parallelism.
Test conducted with 4KB tupls, at-least-once mode, Kafka spout disabled. storm 2.6.0.2
| Metric | Storm 2.5.0 | Storm 2.6.0.2 | Δ | |--------|-------------|---------------|----| | (p99) | 23.4 ms | 12.1 ms | -48% | | Throughput (tuples/sec) | 118k | 157k | +33% | | Worker GC pause (ms) | 450 ms (major) | 210 ms (major) | -53% | | Backpressure trigger rate (per minute) | 12 events | 2 events | Improved | INFO nimbus - [Storm 2