Apache Storm 1.2.0,1.1.2 和 1.0.6 发布了。主要更新内容及下载地址如下:
1.2.0
New Feature
[storm-hbase] Support HBase as state backend
Flux: support bolt+spout memory configuration
Kafka spout can't show acks/fails and complete latency when auto commit is enabled
Create a listener to handle tuple state changes of the KafkaSpout
Improvement
New Metrics Reporting API
Expose interface to MetricRegistry via TopologyContext
Create simple generic plugin system to register codahale reporters
[storm-redis] Use binary type for State management
[storm-elasticsearch] switch ES client to Java REST API
更多:http://storm.apache.org/2018/02/15/storm120-released.html
下载地址:http://storm.apache.org/downloads.html
1.1.2
Improvement
Change KafkaSpoutConfig in storm-kafka-client to make it work with flux
Document the built in metrics (just in time to replace them???)
Update SECURITY.MD
Backport STORM-2558 and deprecate storm.cmd on 1.x-branch
accept arbitrary number of rows per tuple in storm-cassandra
Improve KafkaPartition Metric Names
Integration test should shut down topologies immediately after the test
More flexible logging in multilang (Python, Ruby, JS)
Introduce an option to configure pagination in Storm UI
Check the config(nimbus.host) before using it to connect
Bug
NULL in DisruptorQueue while multi-threaded ack
First tuples fail after worker is respawn
waitUntilReady in PacemakerClient cannot be invoked
Fix flaky integration tests
test-reset-timeout is flaky. Replace with a more reliable test.
更多:http://storm.apache.org/2018/02/15/storm112-released.html
下载地址:http://storm.apache.org/downloads.html
1.0.6
Improvement
Introduce an option to configure pagination in Storm UI
Check the config(nimbus.host) before using it to connect
Bug
windows storm.cmd does not set log4j2 config file correctly by default
resurrect invocation of ISupervisor.assigned() & make Supervisor.launchDaemon() accessible
Remove AsyncLoggingContext from Supervisor
更多:http://storm.apache.org/2018/02/14/storm106-released.html
下载地址:http://storm.apache.org/downloads.html
Apache Storm 是一个免费开源的分布式实时计算系统。简化了流数据的可靠处理,像 Hadoop 一样实现实时批处理。Storm 很简单,可用于任意编程语言。Apache Storm 采用 Clojure 开发。
Storm 有很多应用场景,包括实时数据分析、联机学习、持续计算、分布式 RPC、ETL 等。Storm 速度非常快,一个测试在单节点上实现每秒一百万的组处理。
来自:开源中国社区