This repository has been archived by the owner on Jun 16, 2023. It is now read-only.
0.9.4 release
Big features
- Add transaction programming mode
- Rewrite netty code
- use share boss/worker thread pool
- async send batch tuples
- single thread to do reconnect job
- receive batch tuples
- Add metrics and statics
- Merge Alimama storm branch into this version, submit jar with -conf, -D, -lib
Enhancement
- add setting when supervisor has been shutdown, worker will shutdown automatically
- add LocalFristGrouping api
- enable cgroup for normal user
Bug fix:
- Setting buffer size when upload jar
- Add lock between ZK watch and timer thread when refresh connection
- Enable nimbus monitor thread only when topology is running in cluster mode
- Fix exception when failed to read old assignment of ZK
- classloader fix when both parent and current classloader load the same class
- Fix log view null pointer exception