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...

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 速度非常快，一个测试在单节点上实现每秒一百万的组处理。

【声明】文章转载自：开源中国社区 [http://www.oschina.net]

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。