Onyx 0.10.0-beta8 发布了,Onyx 是一个无中心、支持云、容错的分布式计算系统,使用 Clojure 编写,支持批处理和流处理混合,提供信息模型用于描述和构建分布式工作流。 本次更新如下: Improve flow conditions validation errors. Adjust metrics to include slot-id in metrics tags. Add metric "offset" so that input plugins can report their medium's offset (e.g. kafka topic offset for a given slot-id / partition). Increase default subscriber / publisher timeout to 20000ms. Decrease heartbeat period from 5000ms to 1000ms. Fix bug in status updates that reduces latency of barrier status reporting. Fix bug in session windows which would cause it to lag one message behind. Add gen-class to aeron media driver to allow for main entry point when AOTd 点此查看完整更新日志 下载地址: Source code (zip) Source code (tar.gz) Onyx 0.10.0-beta8 发布,分布式计算系统下载地址