Apache Storm 1.2.0，1.1.2 和 1.0.6 发布

Apache Storm 1.2.0，1.1.2 和 1.0.6 发布了。主要更新内容及下载地址如下：

1.2.0

New Feature

• [STORM-2383] – [storm-hbase] Support HBase as state backend
• [STORM-2484] – Flux: support bolt+spout memory configuration
• [STORM-2648] – Kafka spout can’t show acks/fails and complete latency when auto commit is enabled
• [STORM-2694] – Create a listener to handle tuple state changes of the KafkaSpout

Improvement

• [STORM-2153] – New Metrics Reporting API
• [STORM-2160] – Expose interface to MetricRegistry via TopologyContext
• [STORM-2164] – Create simple generic plugin system to register codahale reporters
• [STORM-2369] – [storm-redis] Use binary type for State management
• [STORM-2379] – [storm-elasticsearch] switch ES client to Java REST API

更多

下载地址

1.1.2

Improvement

• [STORM-2512] – Change KafkaSpoutConfig in storm-kafka-client to make it work with flux
• [STORM-2616] – Document the built in metrics (just in time to replace them???)
• [STORM-2657] – Update SECURITY.MD
• [STORM-2663] – Backport STORM-2558 and deprecate storm.cmd on 1.x-branch
• [STORM-2712] – accept arbitrary number of rows per tuple in storm-cassandra
• [STORM-2775] – Improve KafkaPartition Metric Names
• [STORM-2807] – Integration test should shut down topologies immediately after the test
• [STORM-2862] – More flexible logging in multilang (Python, Ruby, JS)
• [STORM-2877] – Introduce an option to configure pagination in Storm UI
• [STORM-2917] – Check the config(nimbus.host) before using it to connect

Bug

• [STORM-2231] – NULL in DisruptorQueue while multi-threaded ack
• [STORM-2426] – First tuples fail after worker is respawn
• [STORM-2500] – waitUntilReady in PacemakerClient cannot be invoked
• [STORM-2525] – Fix flaky integration tests
• [STORM-2535] – test-reset-timeout is flaky. Replace with a more reliable test.

更多

下载地址

1.0.6

Improvement

• [STORM-2877] – Introduce an option to configure pagination in Storm UI
• [STORM-2917] – Check the config(nimbus.host) before using it to connect

Bug

• [STORM-2451] – windows storm.cmd does not set log4j2 config file correctly by default
• [STORM-2690] – resurrect invocation of ISupervisor.assigned() & make Supervisor.launchDaemon() accessible
• [STORM-2751] – Remove AsyncLoggingContext from Supervisor

更多

下载地址

Apache Storm 是一个免费开源的分布式实时计算系统。简化了流数据的可靠处理，像 Hadoop 一样实现实时批处理。Storm 很简单，可用于任意编程语言。Apache Storm 采用 Clojure 开发。

Storm 有很多应用场景，包括实时数据分析、联机学习、持续计算、分布式 RPC、ETL 等。Storm 速度非常快，一个测试在单节点上实现每秒一百万的组处理。