Apache Storm v1.0.2发布，一个分布式实时计算系统

   <p style="text-align: center;"><img alt="" src="https://simg.open-open.com/show/c02efb06223c905f64f9be990f9246cc.png" /></p>    <p>Apache Storm 的前身是 推ter Storm 平台，目前已经归于 Apache 基金会管辖。</p>    <p>Apache Storm 是一个免费开源的分布式实时计算系统。简化了流数据的可靠处理，像 Hadoop 一样实现实时批处理。Storm 很简单，可用于任意编程语言。</p>    <p><img alt="" src="https://simg.open-open.com/show/9fbe0dfdcf8d3870f7231da4456c6289.png" /></p>    <p>Storm 有很多应用场景，包括实时数据分析、联机学习、持续计算、分布式 RPC、ETL 等。Storm 速度非常快，一个测试在单节点上实现每秒一百万的组处理。</p>    <p>目前已经有包括阿里百度在内的数家大型互联网公司在使用该平台。</p>    <h2>更新日志</h2>    <ul>     <li>STORM-1939: Frequent InterruptedException raised by ShellBoltMessageQueue.poll</li>     <li>STORM-1968: Storm logviewer does not work for nimbus.log in secure cluster</li>     <li>STORM-1928: ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync</li>     <li>STORM-1922: Supervisor summary default order by host</li>     <li>STORM-1956: Disabling Backpressure by default</li>     <li>STORM-1934: Fix race condition between sync-supervisor and sync-processes</li>     <li>STORM-1895: blobstore replication-factor argument</li>     <li>STORM-118: Docs: typo in transactional-commit-flow.png</li>     <li>STORM-1633: Document blobstore to command-line-client.md</li>     <li>STORM-1899: Release HBase connection when topology shutdown</li>     <li>STORM-1844: Some tests are flaky due to low timeout</li>     <li>STORM-1946: initialize lastHeartbeatTimestamp before starting heartbeat task</li>     <li>STORM-1941 Nimbus discovery can fail when zookeeper reconnect happens</li>     <li>STORM-1937 Fix WindowTridentProcessor cause NullPointerException</li>     <li>STORM-1924: Add a config file parameter to HDFS test topologies</li>     <li>STORM-1705: Cap number of retries for a failed message</li>     <li>STORM-1884: Prioritize pendingPrepare over pendingCommit</li>     <li>STORM-1575: fix 推terSampleSpout NPE on close</li>     <li>STORM-1874: Update logger private permissions</li>     <li>STORM-1865: update command line client document</li>     <li>STORM-1771: HiveState should flushAndClose before closing old or idle Hive connections</li>     <li>STORM-1882: Expose TextFileReader public</li>     <li>STORM-1864 : StormSubmitter should throw respective exceptions and log respective errors for registered submitter hook invocation</li>     <li>STORM-1887: Fixed help message for set_log_level command</li>     <li>STORM-1878: Flux can now handle IStatefulBolts</li>     <li>STORM-1861: Storm submit command returns exit code of 0 even when it fails.</li>     <li>STORM-1755: Revert the kafka client version upgrade in storm-kafka module</li>     <li>STORM-1853: Replace ClassLoaderObjectInputStream with ObjectInputStream</li>     <li>STORM-1868: Modify TridentKafkaWordCount to run in distributed mode</li>     <li>STORM-1859: Ack late tuples in windowed mode</li>     <li>STORM-1851: Fix default nimbus impersonation authorizer config</li>     <li>STORM-1848: Make KafkaMessageId and Partition serializable to support event logging</li>     <li>STORM-1862: Flux ShellSpout and ShellBolt can't emit to named streams</li>     <li>Storm-1728: TransactionalTridentKafkaSpout error</li>     <li>STORM-1850: State Checkpointing Documentation update</li>     <li>STORM-1674: Idle KafkaSpout consumes more bandwidth than needed</li>     <li>STORM-1842: Forward references in storm.thrift cause tooling issues</li>     <li>STORM-1745: Add partition to log output in PartitionManager</li>     <li>STORM-1735: Nimbus should log that replication succeeded when min replicas was reached exactly</li>     <li>STORM-1835: add lock info in thread dump</li>     <li>STORM-1749: Fix storm-starter github links</li>     <li>STORM-1764: Pacemaker is throwing some stack traces</li>     <li>STORM-1761: Storm-Solr Example Throws ArrayIndexOutOfBoundsException in Remote Cluster Mode</li>     <li>STORM-1756: Explicitly null KafkaServer reference in KafkaTestBroker to prevent out of memory on large test classes.</li>     <li>STORM-1750: Ensure worker dies when report-error-and-die is called.</li>     <li>STORM-1715: using Jedis Protocol.DEFAULT_HOST to replace DEFAULT_HOST</li>     <li>STORM-1713: Replace NotImplementedException with UnsupportedOperationException</li>     <li>STORM-1678: abstract batch processing to common api <code>BatchHelper</code></li>     <li>STORM-1773: Utils.javaDeserialize() doesn't work with primitive types</li>     <li>STORM-1661: Introduce a config to turn off blobstore acl validation in insecure mode</li>    </ul>    <h2>下载</h2>    <ul>     <li><a href="/misc/goto?guid=4958993128009458168">apache-storm-1.0.2.tar.gz</a> [<a href="/misc/goto?guid=4958993128118264486">PGP</a>] [<a href="/misc/goto?guid=4958993128222392693">SHA512</a>] [<a href="/misc/goto?guid=4958993128314190860">MD5</a>]</li>     <li><a href="/misc/goto?guid=4958993128426017863">apache-storm-1.0.2.zip</a> [<a href="/misc/goto?guid=4958993128514997010">PGP</a>] [<a href="/misc/goto?guid=4958993128617020024">SHA512</a>] [<a href="/misc/goto?guid=4958993128717725844">MD5</a>]</li>     <li><a href="/misc/goto?guid=4958993128819366765">apache-storm-1.0.2-src.tar.gz</a> [<a href="/misc/goto?guid=4958993128917174411">PGP</a>] [<a href="/misc/goto?guid=4958993129016150578">SHA512</a>] [<a href="/misc/goto?guid=4958993129122092382">MD5</a>]</li>     <li><a href="/misc/goto?guid=4958993129213607342">apache-storm-1.0.2-src.zip</a> [<a href="/misc/goto?guid=4958993129308431966">PGP</a>] [<a href="/misc/goto?guid=4958993129414492322">SHA512</a>] [<a href="/misc/goto?guid=4958993129514431840">MD5</a>]</li>    </ul>    <p> </p>    <p>本站原创，转载时保留以下信息：<br /> 本文转自：深度开源（open-open.com）<br /> 原文地址：<a href="http://www.open-open.com/news/view/65c4aab6">http://www.open-open.com/news/view/65c4aab6</a></p>    <p> </p>