http://git-wip-us.apache.org/repos/asf/storm-site/blob/d070189e/content/feed.xml ---------------------------------------------------------------------- diff --git a/content/feed.xml b/content/feed.xml new file mode 100644 index 0000000..0610834 --- /dev/null +++ b/content/feed.xml @@ -0,0 +1,1191 @@ +<?xml version="1.0" encoding="UTF-8"?> +<rss version="2.0" xmlns:atom="http://www.w3.org/2005/Atom";> + <channel> + <title>Apache Storm</title> + <description></description> + <link>http://storm.apache.org/</link> + <atom:link href="http://storm.apache.org/feed.xml"; rel="self" type="application/rss+xml"/> + <pubDate>Tue, 01 Aug 2017 14:48:07 -0400</pubDate> + <lastBuildDate>Tue, 01 Aug 2017 14:48:07 -0400</lastBuildDate> + <generator>Jekyll v3.0.3</generator> + + <item> + <title>Storm 1.1.1 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.1.1 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-2659: Add daemon.name variable to storm.cmd to fix log4j logging</li> +<li>STORM-2652: fix error in open method of JmsSpout</li> +<li>STORM-2645: Update storm.py to be python3 compatible</li> +<li>STORM-2621: add tuple_population metric</li> +<li>STORM-2639: Kafka Spout incorrectly computes numCommittedOffsets due to voids in the topic (topic compaction)</li> +<li>STORM-2544: Fixing issue in acking of tuples that hit retry limit under manual commit mode</li> +<li>STORM-2618: Add TridentKafkaStateUpdater for storm-kafka-client</li> +<li>STORM-2608: Remove any pending offsets that are no longer valid</li> +<li>STORM-2503: Fix lgtm.com alerts on equality and comparison operations</li> +<li>STORM-2478: Fix BlobStoreTest.testDeleteAfterFailedCreate on Windows</li> +<li>STORM-2602: storm.zookeeper.topology.auth.payload doesn&#39;t work even you set it</li> +<li>STORM-2597: Don&#39;t parse passed in class paths</li> +<li>STORM-2564: We should provide a template for storm-cluster-auth.yaml</li> +<li>STORM-2568: Fix getTopicsString</li> +<li>STORM-2563: Remove the workaround to handle missing UGI.loginUserFromSubject</li> +<li>STORM-2552: KafkaSpoutMessageId should be serializable</li> +<li>STORM-2562: Use stronger key size than default for blow fish key generator and get rid of stack trace</li> +<li>STORM-2557: A bug in DisruptorQueue causing severe underestimation of queue arrival rates</li> +<li>STORM-2449: Ensure same key appears only once in State iterator</li> +<li>STORM-2516: Fix timing issues with testPrepareLateTupleStreamWithoutBuilder</li> +<li>STORM-2489: Overlap and data loss on WindowedBolt based on Duration</li> +<li>STORM-2528: Bump log4j version to 2.8.2</li> +<li>STORM-2527: Initialize java.sql.DriverManager earlier to avoid deadlock</li> +<li>STORM-2413: Make new Kafka spout respect tuple retry limits</li> +<li>STORM-2518: Handles empty name for &quot;USER type&quot; ACL when normalizing ACLs</li> +<li>STORM-2511: Submitting a topology with name containing unicode getting failed</li> +<li>STORM-2496: Dependency artifacts should be uploaded to blobstore with READ permission for all</li> +<li>STORM-2505: Spout to support topic compaction</li> +<li>STORM-2498: Fix Download Full File link</li> +<li>STORM-2343: New Kafka spout can stop emitting tuples if more than maxUncommittedOffsets tuples fail at once.</li> +<li>STORM-2486: Prevent cd from printing target directory to avoid breaking classpath</li> +<li>STORM-2488: The UI user Must be HTTP.</li> +<li>STORM-2481: Upgrade Aether version to resolve Aether bug BUG-451566</li> +<li>STORM-2435: Logging in storm.js inconsistent to console.log and does not support log levels</li> +<li>STORM-2315: New kafka spout can&#39;t commit offset when ack is disabled</li> +<li>STORM-2467: Use explicit charset when decoding from array backed buffer</li> +<li>STORM-1114: Race condition in trident zookeeper zk-node create/delete</li> +<li>STORM-2448: Add in Storm and JDK versions when submitting a topology</li> +<li>STORM-2343: Fix new Kafka spout stopping processing if more than maxUncommittedOffsets tuples fail at once</li> +<li>STORM-2431: the default blobstore.dir is storm.local.dir/blobs which is different from distcache-blobstore.md</li> +<li>STORM-2429: Properly validate supervisor.scheduler.meta</li> +<li>STORM-2451: windows storm.cmd does not set log4j2 config file correctly by default</li> +<li>STORM-2450: Write resources into correct local director</li> +<li>STORM-2440: Kill process if executor catches <code>java.net.SocketTimeoutException</code></li> +<li>STORM-2432: Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With UNCOMMITTED_LATEST Strategy</li> +</ul> +</description> + <pubDate>Tue, 01 Aug 2017 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2017/08/01/storm111-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2017/08/01/storm111-released.html</guid> + + + </item> + + <item> + <title>Storm 1.0.4 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.0.4 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-2627: Update docs for storm.zookeeper.topology.auth.scheme</li> +<li>STORM-2597: Don&#39;t parse passed in class paths</li> +<li>STORM-2524: Set Kafka client.id with storm-kafka</li> +<li>STORM-2448: Add in Storm and JDK versions when submitting a topology</li> +<li>STORM-2511: Submitting a topology with name containing unicode getting failed</li> +<li>STORM-2498: Fix Download Full File link</li> +<li>STORM-2486: Prevent cd from printing target directory to avoid breaking classpath</li> +<li>STORM-1114: Race condition in trident zookeeper zk-node create/delete</li> +<li>STORM-2429: Properly validate supervisor.scheduler.meta</li> +<li>STORM-2194: Stop ignoring socket timeout error from executor</li> +<li>STORM-2450: Write resources into correct local director</li> +<li>STORM-2414: Skip checking meta&#39;s ACL when subject has write privileges for any blobs</li> +<li>STORM-2038: Disable symlinks with a config option</li> +<li>STORM-2038: No symlinks for local cluster </li> +<li>STORM-2403: Fix KafkaBolt test failure: tick tuple should not be acked</li> +<li>STORM-2361: Kafka spout - after leader change, it stops committing offsets to ZK</li> +<li>STORM-2296: Kafka spout - no duplicates on leader changes</li> +<li>STORM-2387: Handle tick tuples properly for Bolts in external modules </li> +<li>STORM-2345: Type mismatch in ReadClusterState&#39;s ProfileAction processing Map</li> +<li>STORM-2104: New Kafka spout crashes if partitions are reassigned while tuples are in-flight</li> +<li>STORM-2396: setting interrupted status back before throwing a RuntimeException</li> +<li>STORM-2395: storm.cmd supervisor calls the wrong class name</li> +<li>STORM-2385: pacemaker_state_factory.clj does not compile on branch-1.0.x</li> +<li>STORM-2389: Avoid instantiating Event Logger when topology.eventlogger.executors=0</li> +<li>STORM-2386: Fail-back Blob deletion also fails in BlobSynchronizer.syncBlobs</li> +<li>STORM-2360: Storm-Hive: Thrift version mismatch with storm-core</li> +<li>STORM-2372: Pacemaker client doesn&#39;t clean up heartbeats properly</li> +<li>STORM-2326: Upgrade log4j and slf4j</li> +<li>STORM-2350: Storm-HDFS&#39;s listFilesByModificationTime is broken</li> +</ul> +</description> + <pubDate>Fri, 28 Jul 2017 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2017/07/28/storm104-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2017/07/28/storm104-released.html</guid> + + + </item> + + <item> + <title>Storm 1.1.0 released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.1.0 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This release represents a major milestone in the evolution of Apache Storm, and includes a large number of new features, usability and performance improvements, some of which are highlighted below.</p> + +<h2 id="streaming-sql">Streaming SQL</h2> + +<p>Storm 1.1.0 supports native Streaming SQL, powered by <a href="http://calcite.apache.org">Apache Calcite</a>, that allows users to run SQL queries over streaming data as well update external systems and data stores such as <a href="http://hive.apache.org">Apache Hive</a>. To deploy an SQL-based topology users define the SQL query in a text file and use the <code>storm sql</code> command to submit the resulting topology to a Storm cluster. Behind the scenes Storm will compile the SQL into a Trident topology and run it on the cluster.</p> + +<p>Storm&#39;s SQL support includes the following features:</p> + +<ul> +<li>Streaming from/to external sources including Apache Kafka, HDFS, MongoDB, and Redis</li> +<li>Tuple filtering</li> +<li>Projections</li> +<li>User-defined paralallism of generated components</li> +<li>User Defined Functions (UDFs)</li> +<li>CSV, TSV, and Avro input/output formats</li> +<li>Extensibility to additional data sources via the <code>ISqlTridentDataSource</code> interface</li> +</ul> + +<p>For more information about Storm&#39;s SQL support including examples, refer to the following resources:</p> + +<ul> +<li><a href="/releases/1.1.0/storm-sql.html">Storm SQL Overview</a></li> +<li><a href="/releases/1.1.0/storm-sql-example.html">Storm SQL Examples</a></li> +<li><a href="/releases/1.1.0/storm-sql-reference.html">Storm SQL Reference</a></li> +</ul> + +<h2 id="apache-kafka-integration-improvements">Apache Kafka Integration Improvements</h2> + +<p>In addition to the traditional support for Kafka version 0.8/0.9 based on the Kafka simple consumer, Storm includes support for Kafka 0.10 and later based on the new Kafka consumer API. Storm&#39;s integration with Kafka 0.10 and later version is highly flexible and extensible, some of the features include:</p> + +<ul> +<li>Enhanced configuration API</li> +<li>Fine-grained offset control (at start and after failure)</li> +<li>Consumer group support</li> +<li>Plugable record translators</li> +<li>Wildcard topics</li> +<li>Multiple stream support</li> +<li>Manual partition control</li> +<li>Kafka security support</li> +</ul> + +<p>For more information on Storm&#39;s Kafka integration please refer to the following documentation:</p> + +<ul> +<li><a href="/releases/1.1.0/storm-kafka-client.html">Kafka Integration (0.10 and later)</a></li> +<li><a href="/releases/1.1.0/storm-kafka.html">Kafka Integration (0.8/0.9)</a></li> +</ul> + +<h2 id="pmml-predictive-model-markup-language-support">PMML (Predictive Model Markup Language) Support</h2> + +<p>In order to better support machine learning use cases, Storm now includes support for executing PMML models in topoliges via a generic PMML bolt. The <code>PMMLPredictorBolt</code> allows users to specify a model, the raw input, and the resulting streams and output fields. At runtime the bolt will process incoming raw data, execute the model with the given input, and output tuples with scores for predicted fields and output fields.</p> + +<p>More information on Storm&#39;s PMML support can be found <a href="https://github.com/apache/storm/blob/v1.1.0/external/storm-pmml/README.md">here</a>.</p> + +<h2 id="druid-integration">Druid Integration</h2> + +<p><a href="http://druid.io">Druid</a> is a scalable, high-performance, column oriented, distributed data store popular for real time analytics use cases. Storm 1.1.0 introduces a Storm bolt and Trident state implementations for streaming data into a Druid data store.</p> + +<p>Documentation for Storm&#39;s Druid integration can be found <a href="https://github.com/apache/storm/blob/v1.1.0/external/storm-druid/README.md">here</a>.</p> + +<h2 id="opentsdb-integration">OpenTSDB Integration</h2> + +<p><a href="http://opentsdb.net">OpenTSDB</a> is a highly scalable time series database based on Apache HBase. Storm 1.1.0 adds a Storm bolt and Trident state implementations for writing data to OpenTSDB. Storm&#39;s OpenTSDB integration gives users fine-grained control over how Storm tuples map to OpenTSDB data structure by providing a simple interface (<code>ITupleOpenTsdbDatapointMapper</code>) that performs the translation.</p> + +<p>Move information about Storm&#39;s OpenTSDB integration can be found <a href="https://github.com/apache/storm/blob/v1.1.0/external/storm-opentsdb/README.md">here</a>.</p> + +<h2 id="aws-kinesis-support">AWS Kinesis Support</h2> + +<p>For users looking to integrate with Amazon&#39;s Kinesis service, Storm 1.1.0 now includes a spout for consuming message streams from Kinesis. Like most of Storm&#39;s external system integration components, the Kinesis spout provides a simple interface (<code>RecordToTupleMapper</code>)for controlling how Kinesis messages are translated to Storm tuples. The Kinesis spout provides an additional interface (<code>FailedMessageRetryHandler</code>) that allows users to customize the Spout&#39;s failure handling logic.</p> + +<p>Documentation for the Kinesis spout can be found <a href="https://github.com/apache/storm/blob/v1.1.0/external/storm-kinesis/README.md">here</a>.</p> + +<h2 id="hdfs-spout">HDFS Spout</h2> + +<p>Storm&#39;s HDFS integration now includes a spout that continuously streams data from the HDFS filesystem. Storm&#39;s HDFS spout monitors a configurable directory for new files and feeds that data into a topology. When the spout has completed processing a file, it will be moved to the configured archive directory. In the event a file is corrupt or is otherwise not processable, the corresponding file will be moved to a specific directory. Parallelism of the spout is made possible through a locking mechanism that ensures each file is &quot;owned&quot; by a single spout instance. The HDFS spout supports connecting to HDFS instances that are secured with Kerberos authentication.</p> + +<p>More information on using the HDFS spout can be found in the <a href="https://github.com/apache/storm/blob/v1.1.0/external/storm-hdfs/README.md">Storm HDFS Documentation</a></p> + +<h2 id="flux-improvements">Flux Improvements</h2> + +<p>Flux is a framework and set of utilities that allow users to declaratively define Storm topologies and avoid hard-coding configuration values in topology components. Storm 1.1.0 introduces the following enhancements to the Flux framework:</p> + +<ul> +<li>Flux topology visualization in Storm UI</li> +<li>Support for Stateful bolts and windowing</li> +<li>Support for named streams</li> +<li>Support for lists of references</li> +</ul> + +<p>More information about Flux can be found in the <a href="/releases/1.1.0/flux.html">Flux documentation</a>.</p> + +<h2 id="topology-deployment-enhancements">Topology Deployment Enhancements</h2> + +<p>In previous versions of Storm it was typically necessary to include all topology dependences in a shaded &quot;uber jar,&quot; or by making them available on Storm&#39;s classpath. In Storm 1.1.0 the <code>storm jar</code> command now includes options to upload additional dependency jars during topology submission. The <code>--jars</code> command line option allows users to specify local jar files to upload. Alternatively, the <code>storm jar</code> command offers the <code>--artifacts</code> option for specifying additional jar file dependencies by their Maven coordinates. Finally, for Maven artifacts outside the Maven Central, the <code>--artifactRepository</code> option allows users to specify additional repositories for dependency resolution.</p> + +<p>More informaton about available options of the <code>storm jar</code> command can be found by runnng the <code>storm help jar</code> command.</p> + +<h2 id="resource-aware-scheduler-ras-improvements">Resource Aware Scheduler (RAS) Improvements</h2> + +<p>The Resource Aware Scheduler introduced in Storm 1.0 added a scheduler implementation that takes into account both the memory (on-heap and off-heap) and CPU resources available in a cluster. In Storm 1.1.0 the RAS algorithm has been overhauled to dramatically improve cluster resource utilization and introduces rack awareness into the scheduling strategy.</p> + +<p>More information on the new RAS capabilities can be found in the <a href="/releases/1.1.0/Resource_Aware_Scheduler_overview.html">RAS documentation</a> and the <a href="https://issues.apache.org/jira/browse/STORM-1766">JIRA ticket</a> introducing the new rack awareness algorithm.</p> + +<h2 id="important-changes-in-the-binary-distribution">Important Changes in the Binary Distribution</h2> + +<p>In order to minimize the file size of the binary distribution, external component (i.e. &quot;connector&quot;) binaries and compiled examples are no longer included. Examples are included in source form only, but can easily compiled with the Maven <code>mvn install</code> command.</p> + +<h3 id="external-components-moved-to-maven-central">External Components Moved to Maven Central</h3> + +<p>Most external components are now hosted exclusively in Maven Central. External component directories will contain a README.md file, but no jar files. We encourage users to leverage a build system with Maven style dependency resolution (Maven, Gradle, etc.) to build topology jars and avoid building topology jars manually.</p> + +<p>Maven coordinates for these components can be determined as follows:</p> + +<p>Group ID: org.apache.storm +Artifact ID: <a href="e.g." title="storm-kafka-client&quot;, &quot;storm-hdfs">component directory name</a> +Version: 1.1.0</p> + +<p>For users who cannot use Maven for building, external component jar files can be downloaded from Maven Central with the following URL pattern:</p> +<div class="highlight"><pre><code class="language-" data-lang="">http://repo1.maven.org/maven2/org/apache/storm/${artifactID}/${version}/${artifactId}-${version}.jar +</code></pre></div> +<p>For example, to download the storm-kafka-client jar file the URL would be:</p> +<div class="highlight"><pre><code class="language-" data-lang="">http://repo1.maven.org/maven2/org/apache/storm/storm-kafka-client/1.1.0/storm-kafka-client-1.1.0.jar +</code></pre></div> +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<p>The full changelog for this release is listed below.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-2425: Storm Hive Bolt not closing open transactions</li> +<li>STORM-2409: Storm-Kafka-Client KafkaSpout Support for Failed and NullTuples</li> +<li>STORM-2423: Join Bolt should use explicit instead of default window anchoring for emitted tuples</li> +<li>STORM-2416: Improve Release Packaging to Reduce File Size</li> +<li>STORM-2414: Skip checking meta&#39;s ACL when subject has write privileges for any blobs</li> +<li>STORM-2038: Disable symlinks with a config option</li> +<li>STORM-2240: STORM PMML Bolt - Add Support to Load Models from Blob Store</li> +<li>STORM-2412: Nimbus isLeader check while waiting for max replication</li> +<li>STORM-2408: build failed if storm.kafka.client.version = 0.10.2.0</li> +<li>STORM-2403: Fix KafkaBolt test failure: tick tuple should not be acked</li> +<li>STORM-2361: Kafka spout - after leader change, it stops committing offsets to ZK</li> +<li>STORM-2353: Replace kafka-unit by kafka_2.11 and kafka-clients to test kafka-clients:0.10.1.1</li> +<li>STORM-2387: Handle tick tuples properly for Bolts in external modules</li> +<li>STORM-2345: Type mismatch in ReadClusterState&#39;s ProfileAction processing Map</li> +<li>STORM-2400: Upgraded Curator to 2.12.0 and made respective API changes</li> +<li>STORM-2396: setting interrupted status back before throwing a RuntimeException</li> +<li>STORM-1772: Adding Perf module with topologies for measuring performance</li> +<li>STORM-2395: storm.cmd supervisor calls the wrong class name</li> +<li>STORM-2391: Move HdfsSpoutTopology from storm-starter to storm-hdfs-examples</li> +<li>STORM-2389: Avoid instantiating Event Logger when topology.eventlogger.executors=0</li> +<li>STORM-2386: Fail-back Blob deletion also fails in BlobSynchronizer.syncBlobs.</li> +<li>STORM-2388: JoinBolt breaks compilation against JDK 7</li> +<li>STORM-2374: Storm Kafka Client Test Topologies Must be Serializable</li> +<li>STORM-2372: Pacemaker client doesn&#39;t clean up heartbeats properly</li> +<li>STORM-2326: Upgrade log4j and slf4j</li> +<li>STORM-2334: Join Bolt implementation</li> +<li>STORM-1363: TridentKafkaState should handle null values from TridentTupleToKafkaMapper.getMessageFromTuple()</li> +<li>STORM-2365: Support for specifying output stream in event hubs spout </li> +<li>STORM-2250: Kafka spout refactoring to increase modularity and testability</li> +<li>STORM-2340: fix AutoCommitMode issue in KafkaSpout</li> +<li>STORM-2344: Flux YAML File Viewer for Nimbus UI</li> +<li>STORM-2350: Storm-HDFS&#39;s listFilesByModificationTime is broken</li> +<li>STORM-2270 Kafka spout should consume from latest when ZK partition commit offset bigger than the latest offset</li> +<li>STORM-1464: storm-hdfs support for multiple output files and partitioning</li> +<li>STORM-2320: DRPC client printer class reusable for local and remote DRPC</li> +<li>STORM-2281: Running Multiple Kafka Spouts (Trident) Throws Illegal State Exception</li> +<li>STORM-2296: Kafka spout no dup on leader changes</li> +<li>STORM-2244: Some shaded jars doesn&#39;t exclude dependency signature files</li> +<li>STORM-2014: New Kafka spout duplicates checking if failed messages have reached max retries</li> +<li>STORM-1443: [Storm SQL] Support customizing parallelism in StormSQL</li> +<li>STORM-2148: [Storm SQL] Trident mode: back to code generate and compile Trident topology</li> +<li>STORM-2331: Emitting from JavaScript should work when not anchoring.</li> +<li>STORM-2225: change spout config to be simpler.</li> +<li>STORM-2323: Precondition for Leader Nimbus should check all topology blobs and also corresponding dependencies</li> +<li>STORM-2330: Fix storm sql code generation for UDAF with non standard sql types</li> +<li>STORM-2298: Don&#39;t kill Nimbus when ClusterMetricsConsumer is failed to initialize</li> +<li>STORM-2301: [storm-cassandra] upgrade cassandra driver to 3.1.2</li> +<li>STORM-1446: Compile the Calcite logical plan to Storm Trident logical plan</li> +<li>STORM-2303: [storm-opentsdb] Fix list invariant issue for JDK 7</li> +<li>STORM-2236: storm kafka client should support manual partition management</li> +<li>STORM-2295: KafkaSpoutStreamsNamedTopics should return output fields with predictable ordering</li> +<li>STORM-2300: [Flux] support list of references</li> +<li>STORM-2297: [storm-opentsdb] Support Flux for OpenTSDBBolt</li> +<li>STORM-2294: Send activate and deactivate command to ShellSpout</li> +<li>STORM-2280: Upgrade Calcite version to 1.11.0</li> +<li>STORM-2278: Allow max number of disruptor queue flusher threads to be configurable</li> +<li>STORM-2277: Add shaded jar for Druid connector</li> +<li>STORM-2274: Support named output streams in Hdfs Spout</li> +<li>STORM-2204: Adding caching capabilities in HBaseLookupBolt</li> +<li>STORM-2267: Use user&#39;s local maven repo. directory to local repo.</li> +<li>STORM-2254: Provide Socket time out for nimbus thrift client</li> +<li>STORM-2200: [Storm SQL] Drop Aggregate &amp; Join support on Trident mode</li> +<li>STORM-2266: Close NimbusClient instances appropriately</li> +<li>STORM-2203: Add a getAll method to KeyValueState interface</li> +<li>STORM-1886: Extend KeyValueState iface with delete</li> +<li>STORM-2022: update Fields test to match new behavior</li> +<li>STORM-2020: Stop using sun internal classes</li> +<li>STORM-1228: port fields_test to java</li> +<li>STORM-2104: New Kafka spout crashes if partitions are reassigned while tuples are in-flight</li> +<li>STORM-2257: Add built in support for sum function with different types.</li> +<li>STORM-2082: add sql external module storm-sql-hdfs</li> +<li>STORM-2256: storm-pmml breaks on java 1.7</li> +<li>STORM-2223: PMML Bolt.</li> +<li>STORM-2222: Repeated NPEs thrown in nimbus if rebalance fails</li> +<li>STORM-2190: reduce contention between submission and scheduling</li> +<li>STORM-2239: Handle InterruptException in new Kafka spout</li> +<li>STORM-2087: Storm-kafka-client: Failed tuples are not always replayed</li> +<li>STORM-2238: Add Timestamp extractor for windowed bolt</li> +<li>STORM-2235: Introduce new option: &#39;add remote repositories&#39; for dependency resolver</li> +<li>STORM-2215: validate blobs are present before submitting</li> +<li>STORM-2170: [Storm SQL] Add built-in socket datasource to runtime</li> +<li>STORM-2226: Fix kafka spout offset lag ui for kerberized kafka</li> +<li>STORM-2224: Exposed a method to override in computing the field from given tuple in FieldSelector</li> +<li>STORM-2220: Added config support for each bolt in Cassandra bolts, fixed the bolts to be used also as sinks.</li> +<li>STORM-2205: Racecondition in getting nimbus summaries while ZK connectionions are reconnected</li> +<li>STORM-2182: Refactor Storm Kafka Examples Into Own Modules.</li> +<li>STORM-1694: Kafka Spout Trident Implementation Using New Kafka Consumer API</li> +<li>STORM-2173: [SQL] Support CSV as input / output format</li> +<li>STORM-2177: [SQL] Support TSV as input / output format</li> +<li>STORM-2172: [SQL] Support Avro as input / output format</li> +<li>STORM-2185: Storm Supervisor doesn&#39;t delete directories properly sometimes</li> +<li>STORM-2103: [SQL] Introduce new sql external module: storm-sql-mongodb</li> +<li>STORM-2175: fix double close of workers</li> +<li>STORM-2109: Under supervisor V2 SUPERVISOR_MEMORY_CAPACITY_MB and SUPERVISOR_CPU_CAPACITY must be Doubles</li> +<li>STORM-2110: in supervisor v2 filter out empty command line args</li> +<li>STORM-2117: Supervisor V2 with local mode extracts resources directory to topology root directory instead of temporary directory</li> +<li>STORM-2131: Add blob command to worker-launcher, make stormdist directory not writeable by topo owner</li> +<li>STORM-2018: Supervisor V2</li> +<li>STORM-2139: Let ShellBolts and ShellSpouts run with scripts from blobs</li> +<li>STORM-2072: Add map, flatMap with different outputs (T-&gt;V) in Trident</li> +<li>STORM-2134: improving the current scheduling strategy for RAS</li> +<li>STORM-2125: Use Calcite&#39;s implementation of Rex Compiler</li> +<li>STORM-1546: Adding Read and Write Aggregations for Pacemaker to make it HA compatible</li> +<li>STORM-1444: Support EXPLAIN statement in StormSQL</li> +<li>STORM-2099: Introduce new sql external module: storm-sql-redis</li> +<li>STORM-2097: Improve logging in trident core and examples</li> +<li>STORM-2144: Fix Storm-sql group-by behavior in standalone mode</li> +<li>STORM-2066: make error message in IsolatedPool.java more descriptive</li> +<li>STORM-1870: Allow FluxShellBolt/Spout set custom &quot;componentConfig&quot; via yaml</li> +<li>STORM-2126: fix NPE due to race condition in compute-new-sched-assignâ¦</li> +<li>STORM-2124: show requested cpu mem for each component</li> +<li>STORM-2089: Replace Consumer of ISqlTridentDataSource with SqlTridentConsumer</li> +<li>STORM-2118: A few fixes for storm-sql standalone mode</li> +<li>STORM-2105: Cluster/Supervisor total and available resources displayed in the UI</li> +<li>STORM-2078: enable paging in worker datatable</li> +<li>STORM-1664: Allow Java users to start a local cluster with a Nimbus Thrift server.</li> +<li>STORM-1872: Release Jedis connection when topology shutdown</li> +<li>STORM-2100: Fix Trident SQL join tests to not rely on ordering</li> +<li>STORM-1837: Fix complete-topology and prevent message loss</li> +<li>STORM-2098: DruidBeamBolt: Pass DruidConfig.Builder as constructor argument</li> +<li>STORM-2092: optimize TridentKafkaState batch sending</li> +<li>STORM-1979: Storm Druid Connector implementation.</li> +<li>STORM-2057: Support JOIN statement in Storm SQL</li> +<li>STORM-1970: external project examples refator</li> +<li>STORM-2074: fix storm-kafka-monitor NPE bug</li> +<li>STORM-1459: Allow not specifying producer properties in read-only Kafka table in StormSQL</li> +<li>STORM-2052: Kafka Spout New Client API - Log Improvements and Parameter Tuning for Better Performance.</li> +<li>STORM-2050: [storm-sql] Support User Defined Aggregate Function for Trident mode</li> +<li>STORM-1434: Support the GROUP BY clause in StormSQL</li> +<li>STORM-2016: Topology submission improvement: support adding local jars and maven artifacts on submission</li> +<li>STORM-1994: Add table with per-topology &amp; worker resource usage and components in (new) supervisor and topology pages</li> +<li>STORM-2042: Nimbus client connections not closed properly causing connection leaks</li> +<li>STORM-1766: A better algorithm server rack selection for RAS</li> +<li>STORM-1913: Additions and Improvements for Trident RAS API</li> +<li>STORM-2037: debug operation should be whitelisted in SimpleAclAuthorizer.</li> +<li>STORM-2023: Add calcite-core to dependency of storm-sql-runtime</li> +<li>STORM-2036: Fix minor bug in RAS Tests</li> +<li>STORM-1979: Storm Druid Connector implementation.</li> +<li>STORM-1839: Storm spout implementation for Amazon Kinesis Streams.</li> +<li>STORM-1876: Option to build storm-kafka and storm-kafka-client with different kafka client version</li> +<li>STORM-2000: Package storm-opentsdb as part of external dir in installation</li> +<li>STORM-1989: X-Frame-Options support for Storm UI</li> +<li>STORM-1962: support python 3 and 2 in multilang</li> +<li>STORM-1964: Unexpected behavior when using count window together with timestamp extraction</li> +<li>STORM-1890: ensure we refetch static resources after package build</li> +<li>STORM-1988: Kafka Offset not showing due to bad classpath.</li> +<li>STORM-1966: Expand metric having Map type as value into multiple metrics based on entries</li> +<li>STORM-1737: storm-kafka-client has compilation errors with Apache Kafka 0.10</li> +<li>STORM-1968: Storm logviewer does not work for nimbus.log in secure cluster</li> +<li>STORM-1910: One topology cannot use hdfs spout to read from two locations</li> +<li>STORM-1960: Add CORS support to STORM UI Rest api</li> +<li>STORM-1959: Add missing license header to KafkaPartitionOffsetLag</li> +<li>STORM-1950: Change response json of &quot;Topology Lag&quot; REST API to keyed by spoutId, topic, partition.</li> +<li>STORM-1833: Simple equi-join in storm-sql standalone mode</li> +<li>STORM-1866: Update Resource Aware Scheduler Documentation</li> +<li>STORM-1930: Kafka New Client API - Support for Topic Wildcards</li> +<li>STORM-1924: Adding conf options for Persistent Word Count Topology</li> +<li>STORM-1956: Disabling Backpressure by default</li> +<li>STORM-1934: Fix race condition between sync-supervisor and sync-processes</li> +<li>STORM-1919: Introduce FilterBolt on storm-redis</li> +<li>STORM-1945: Fix NPE bugs on topology spout lag for storm-kafka-monitor</li> +<li>STORM-1888: add description for shell command</li> +<li>STORM-1902: add a simple &amp; flexible FileNameFormat for storm-hdfs</li> +<li>STORM-1914: Storm Kafka Field Topic Selector</li> +<li>STORM-1907: PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException</li> +<li>STORM-1925: Remove Nimbus thrift call from Nimbus itself</li> +<li>STORM-1909: Update HDFS spout documentation</li> +<li>STORM-1136: Command line module to return kafka spout offsets lag and display in storm ui</li> +<li>STORM-1911: IClusterMetricsConsumer should use seconds to timestamp unit</li> +<li>STORM-1893: Support OpenTSDB for storing timeseries data.</li> +<li>STORM-1723: Introduce ClusterMetricsConsumer</li> +<li>STORM-1700: Introduce &#39;whitelist&#39; / &#39;blacklist&#39; option to MetricsConsumer</li> +<li>STORM-1698: Asynchronous MetricsConsumerBolt</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 TwitterSampleSpout 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-1873: Implement alternative behaviour for late tuples</li> +<li>STORM-1719: Introduce REST API: Topology metric stats for stream</li> +<li>STORM-1887: Fixed help message for set_log_level command</li> +<li>STORM-1878: Flux can now handle IStatefulBolts</li> +<li>STORM-1864: StormSubmitter should throw respective exceptions and log respective errors forregistered submitter hook invocation</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</li> +<li>STORM-1862: Flux ShellSpout and ShellBolt can&#39;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-1730: LocalCluster#shutdown() does not terminate all storm threads/thread pools.</li> +<li>STORM-1709: Added group by support in storm sql standalone mode</li> +<li>STORM-1720: Support GEO in storm-redis</li> +</ul> +</description> + <pubDate>Wed, 29 Mar 2017 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2017/03/29/storm110-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2017/03/29/storm110-released.html</guid> + + + </item> + + <item> + <title>Storm 1.0.3 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.0.3 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-2197: NimbusClient connectins leak due to leakage in ThriftClient</li> +<li>STORM-2321: Handle blobstore zk key deletion in KeySequenceNumber.</li> +<li>STORM-2324: Fix deployment failure if resources directory is missing in topology jar</li> +<li>STORM-2335: Fix broken Topology visualization with empty &#39;:transferred&#39; in executor stats</li> +<li>STORM-2336: Close Localizer and AsyncLocalizer when supervisor is shutting down</li> +<li>STORM-2338: Subprocess exception handling is broken in storm.py on Windows environment</li> +<li>STORM-2337: Broken documentation generation for storm-metrics-profiling-internal-actions.md and windows-users-guide.md</li> +<li>STORM-2325: Logviewer doesn&#39;t consider &#39;storm.local.hostname&#39;</li> +<li>STORM-1742: More accurate &#39;complete latency&#39;</li> +<li>STORM-2176: Workers do not shutdown cleanly and worker hooks don&#39;t run when a topology is killed</li> +<li>STORM-2293: hostname should only refer node&#39;s &#39;storm.local.hostname&#39;</li> +<li>STORM-2246: Logviewer download link has urlencoding on part of the URL</li> +<li>STORM-1906: Window count/length of zero should be disallowed</li> +<li>STORM-1841: Address a few minor issues in windowing and doc</li> +<li>STORM-2268: Fix integration test for Travis CI build</li> +<li>STORM-2283: Fix DefaultStateHandler kryo multithreading issues</li> +<li>STORM-2264: OpaqueTridentKafkaSpout failing after STORM-2216</li> +<li>STORM-2276: Remove twitter4j usages due to license issue (JSON.org is catalog X)</li> +<li>STORM-2095: remove any remaining files when deleting blobstore directory</li> +<li>STORM-2222: Repeated NPEs thrown in nimbus if rebalance fails</li> +<li>STORM-2251: Integration test refers specific version of Storm which should be project version</li> +<li>STORM-2234: heartBeatExecutorService in shellSpout don&#39;t work well with deactivate</li> +<li>STORM-2216: Favor JSONValue.parseWithException</li> +<li>STORM-2208: HDFS State Throws FileNotFoundException in Azure Data Lake Store file system (adl://)</li> +<li>STORM-2213: ShellSpout has race condition when ShellSpout is being inactive longer than heartbeat timeout</li> +<li>STORM-2210: remove array shuffle from ShuffleGrouping</li> +<li>STORM-2052: Kafka Spout - New Client API - Performance Improvements</li> +<li>storm-2205: Racecondition in getting nimbus summaries while ZK connections are reconnected</li> +<li>STORM-2198: perform RotationAction when stopping HdfsBolt</li> +<li>STORM-2196: A typo in RAS_Node::consumeCPU</li> +<li>STORM-2189: RAS_Node::freeCPU outputs incorrect info</li> +<li>STORM-2184: Don&#39;t wakeup KafkaConsumer on shutdown</li> +<li>STORM-2185: Storm Supervisor doesn&#39;t delete directories properly sometimes</li> +<li>STORM-2175: fix double close of workers</li> +<li>STORM-2018: Supervisor V2</li> +<li>STORM-2145: Leave leader nimbus&#39;s hostname to log when trying to connect leader nimbus</li> +<li>STORM-2127: Storm-eventhubs should use latest amqp and eventhubs-client versions</li> +<li>STORM-2040: Fix bug on assert-can-serialize</li> +<li>STORM-2017: ShellBolt stops reporting task ids</li> +<li>STORM-2119: bug in log message printing to stdout</li> +<li>STORM-2120: Emit to _spoutConfig.outputStreamId</li> +<li>STORM-2101: fixes npe in compute-executors in nimbus</li> +<li>STORM-2090: Add integration test for storm windowing</li> +<li>STORM-2003: Make sure config contains TOPIC before get it</li> +<li>STORM-1567: in defaults.yaml &#39;topology.disable.loadaware&#39; should be &#39;topology.disable.loadaware.messaging&#39;</li> +<li>STORM-1987: Fix TridentKafkaWordCount arg handling in distributed mode.</li> +<li>STORM-1969: Modify HiveTopology to show usage of non-partition table.</li> +<li>STORM-1849: HDFSFileTopology should use the 3rd argument as topologyName</li> +<li>STORM-2086: use DefaultTopicSelector instead of creating a new one</li> +<li>STORM-2079: Unneccessary readStormConfig operation</li> +<li>STORM-2081: create external directory for storm-sql various data sources and move storm-sql-kafka to it</li> +<li>STORM-2070: Fix sigar native binary download link</li> +<li>STORM-2056: Bugs in logviewer</li> +<li>STORM-1646: Fix ExponentialBackoffMsgRetryManager test</li> +<li>STORM-2039: Backpressure refactoring in worker and executor</li> +<li>STORM-2064: Add storm name and function, access result and function to log-thrift-access</li> +<li>STORM-2063: Add thread name in worker logs</li> +<li>STORM-2042: Nimbus client connections not closed properly causing connection leaks</li> +<li>STORM-2032: removes warning in case more than one metrics tuple is received</li> +<li>STORM-1594: org.apache.storm.tuple.Fields can throw NPE if given invalid field in selector</li> +<li>STORM-1995: downloadChunk in nimbus.clj should close the input stream</li> +</ul> +</description> + <pubDate>Tue, 14 Feb 2017 00:00:00 -0500</pubDate> + <link>http://storm.apache.org/2017/02/14/storm103-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2017/02/14/storm103-released.html</guid> + + + </item> + + <item> + <title>Storm 0.10.2 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 0.10.2 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-2042: Nimbus client connections not closed properly causing connection leaks</li> +<li>STORM-1609: Netty Client is not best effort delivery on failed Connection</li> +<li>STORM-1928: ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync</li> +<li>STORM-1989: X-Frame-Options support for Storm UI</li> +<li>STORM-1834: Documentation How to Generate Certificates For Local Testing SSL Setup</li> +<li>STORM-1754: Correct java version in 0.10.x storm-starter</li> +<li>STORM-1750: Ensure worker dies when report-error-and-die is called.</li> +<li>STORM-1739: update the minor JAVA version dependency in 0.10.0 and above</li> +<li>STORM-1733: Flush stdout and stderr before calling &quot;os.execvp&quot; to prevent log loss</li> +</ul> +</description> + <pubDate>Wed, 14 Sep 2016 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2016/09/14/storm0102-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2016/09/14/storm0102-released.html</guid> + + + </item> + + <item> + <title>Storm 0.9.7 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 0.9.7 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="multi-lang-bug-fix">Multi-Lang Bug Fix</h2> + +<p>This release fixes an issue with Storm&#39;s multi-lang feature where a malformed multi-lang message from a ShellSpout would cause the spout to hang indefinitely.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-442: multilang ShellBolt/ShellSpout die() can be hang when Exception happened</li> +<li>STORM-1928: ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync</li> +</ul> +</description> + <pubDate>Wed, 07 Sep 2016 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2016/09/07/storm097-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2016/09/07/storm097-released.html</guid> + + + </item> + + <item> + <title>Storm 1.0.2 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.0.2 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</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 TwitterSampleSpout 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&#39;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&#39;t work with primitive types</li> +<li>STORM-1661: Introduce a config to turn off blobstore acl validation in insecure mode</li> +</ul> +</description> + <pubDate>Wed, 10 Aug 2016 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2016/08/10/storm102-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2016/08/10/storm102-released.html</guid> + + + </item> + + <item> + <title>Storm 1.0.1 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.0.1 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="performance-improvements">Performance Improvements</h2> + +<p>This release includes performance improvements to Storm&#39;s internal messaging system. The maximum rate at which spouts can emit data has nearly doubled, and performance of inter-task communication has improved.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-1741: remove unconditional setting of JAVA_HOME from storm-env.sh</li> +<li>STORM-1739: update the minor JAVA version dependency in 0.10.0 and above</li> +<li>STORM-1727: document 1.0 package renaming and how to use the migration tool</li> +<li>STORM-1733: Flush stdout and stderr before calling &quot;os.execvp&quot; to prevent log loss.</li> +<li>STORM-1729: Get rid of reflections while recording stats</li> +<li>STORM-1731: Avoid looking up debug / backpressure enable flags within critical path</li> +<li>STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors.</li> +<li>STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponential Backoff method should use HashMap instead of TreeMap not to throw Exception</li> +<li>STORM-1544: Document Debug/Sampling of Topologies</li> +<li>STORM-1679: add storm Scheduler documents</li> +<li>STORM-1704: When logviewer_search.html opens daemon file, next search always show no result</li> +<li>STORM-1714: StatefulBolts ends up as normal bolts while using TopologyBuilder.setBolt without parallelism</li> +<li>STORM-1683: only check non-system streams by default</li> +<li>STORM-1680: Provide configuration to set min fetch size in KafkaSpout</li> +<li>STORM-1649: Optimize Kryo instaces creation in HBaseWindowsStore</li> +<li>STORM-1696: status not sync if zk fails in backpressure</li> +<li>STORM-1693: Move stats cleanup to executor shutdown</li> +<li>STORM-1585: Add DDL support for UDFs in storm-sql</li> +<li>STORM-1681: Bug in scheduling cyclic topologies when scheduling with RAS</li> +<li>STORM-1706: Add RELEASE and storm-env.sh to storm-diet assembly</li> +<li>STORM-1613: Upgraded HBase version to 1.1.0</li> +<li>STORM-1687: divide by zero in stats</li> +</ul> +</description> + <pubDate>Fri, 06 May 2016 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2016/05/06/storm101-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2016/05/06/storm101-released.html</guid> + + + </item> + + <item> + <title>Storm 0.10.1 Released</title> + <description><p>The Apache Storm community is pleased to announce that version 0.10.1 has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This is a maintenance release that includes a number of important bug fixes that improve Storm&#39;s performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-1731: Avoid looking up debug enable flags within critical path</li> +<li>STORM-1645: convert nimbus.thrift.port to int to avoid ClassCastException</li> +<li>STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors</li> +<li>STORM-584: Fix logging for LoggingMetricsConsumer metrics.log file</li> +<li>STORM-1603: Storm UT fails on supervisor test in Windows (0.10.x)</li> +<li>STORM-1596: Do not use single Kerberos TGT instance between multiple threads</li> +<li>STORM-1482: add missing &#39;break&#39; for RedisStoreBolt</li> +<li>STORM-1481: avoid Math.abs(Integer) get a negative value</li> +<li>STORM-1121: Deprecate test only configuraton nimbus.reassign</li> +<li>STORM-1180: FLUX logo wasn&#39;t appearing quite right</li> +</ul> +</description> + <pubDate>Thu, 05 May 2016 00:00:00 -0400</pubDate> + <link>http://storm.apache.org/2016/05/05/storm0101-released.html</link> + <guid isPermaLink="true">http://storm.apache.org/2016/05/05/storm0101-released.html</guid> + + + </item> + + <item> + <title>Storm 1.0.0 released</title> + <description><p>The Apache Storm community is pleased to announce that version 1.0.0 Stable has been released and is available from <a href="/downloads.html">the downloads page</a>.</p> + +<p>This release represents a major milestone in the evolution of Apache Storm, and includes an immense number of new features, usability and performance improvements, some of which are highlighted below.</p> + +<h2 id="improved-performance">Improved Performance</h2> + +<p>One of the main highlights in this release is a dramatice performance improvement over previous versions. Apache Storm 1.0 is *up to 16 times faster than previous versions, with latency reduced up to 60%. Obviously topology performance varies widely by use case and external service dependencies, but for most use cases users can expect a 3x performance boost over earlier versions.</p> + +<h2 id="pacemaker-heartbeat-server">Pacemaker - Heartbeat Server</h2> + +<p>Pacemaker is an optional Storm daemon designed to process heartbeats from workers. As Storm is scaled up, ZooKeeper begins to become a bottleneck due to high volumes of writes from workers doing heartbeats. Lots of writes to disk and large ammounts traffic across the network is generated as ZooKeeper tries to maintain consistency.</p> + +<p>Because heartbeats are of an ephemeral nature, they do not need to be persisted to disk or synced across nodes, and an in-memory store will do. This is the role of Pacemaker. Pacemaker functions as a simple in-memory key/value store with ZooKeeper-like, directory-style keys and byte array values.</p> + +<h2 id="distributed-cache-api">Distributed Cache API</h2> + +<p>In the past it was common for developers to bundle resources required by a topology (such as lookup data, machine learning models, etc.) within a topology jar file. One problem with this approach is that updating that data required the repackaging and redeployment of the topology. Another problem is that at times that data can be very large (gigabytes or more), which negatively impacts topology startup time. </p> + +<p>Storm version 1.0 introduces a distributed cache API that allows for the sharing of files (BLOBs) among topologies. Files in the distributed cache can be updated at any time from the command line, without the need to redeploy a topology. The distributed cache API allows for files from several KB in size to several GB, and also supports compression formats such as ZIP and GZIP.</p> + +<p>Storm 1.0 comes with two implementations of the distributed cache API: One backed by the local file system on Supervisor nodes, and one backed by Apache Hadoop HDFS. Both implementations also support fine-grained access control through ACLs.</p> + +<h2 id="ha-nimbus">HA Nimbus</h2> + +<p>Experienced Storm users will recognize that the Storm Nimbus service is not a single point of failure in the strictest sense (i.e. loss of the Nimbus node will not affect running topologies). However, the loss of the Nimbus node does degrade functionality for deploying new topologies and reassigning work across a cluster.</p> + +<p>In Storm 1.0 this âsoftâ point of failure has been eliminated by supporting an HA Nimbus. Multiple instances of the Nimbus service run in a cluster and perform leader election when a Nimbus node fails, and Nimbus hosts can join or leave the cluster at any time. HA Nimbus leverages the distributed cache API for replication to guarantee the availability of topology resources in the event of a Nimbus node failure.</p> + +<h2 id="native-streaming-window-api">Native Streaming Window API</h2> + +<p>Window based computations are common among use cases in stream processing, where the unbounded stream of data is split into finite sets based on some criteria (e.g. time) and a computation is applied on each group of events. One example would be to compute the top trending twitter topic in the last hour.</p> + +<p>Windowing is primarily used for aggregations, joins, pattern matching and more. Windows can be seen as an in-memory table where events are added and evicted based on some policies.</p> + +<p>In past releases Storm relied on developers to build their own windowing logic. There were no recommended or high level abstractions that developers could use to define a Window in a standard way in a Topology.</p> + +<p>Apache Storm 1.0 now includes a native windowing API. Windows can be specified with the following two parameters,</p> + +<ol> +<li>Window length - the length or duration of the window</li> +<li>Sliding interval - the interval at which the window slides</li> +</ol> + +<p>Storm has support for sliding and tumbling windows based on time duration and/or event count.</p> + +<h2 id="state-management-statefule-bolts-with-automatic-checkpointing">State Management - Statefule Bolts with Automatic Checkpointing</h2> + +<p>Storm 1.0 introduces a new Stateful Bolt API with automatic checkpointing. Stateful Bolts are easy to implement -- simply extend the <code>BaseStatefulBolt</code> class -- and can be combined with stateless bolts in a topology. Storm will automatically manage bolt state and recover that state in the event of a failure.</p> + +<p>Storm 1.0 comes with a state implementations backed by memory as well as Redis. Future point releases will include additional support for alternative state stores.</p> + +<h2 id="automatic-backpressure">Automatic Backpressure</h2> + +<p>In previous Storm versions, the only way to throttle the input to a topology was to enable ACKing and set <code>topology.max.spout.pending</code>. For use cases that don&#39;t require at-least-once processing guarantees, this requirement imposed a significant performance penalty.</p> + +<p>Storm 1.0 includes a new automatic backpressure mechanism based on configurable high/low watermarks expressed as a percentage of a task&#39;s buffer size. If the high water mark is reached, Storm will slow down the topology&#39;s spouts and stop throttling when the low water mark is reached.</p> + +<p>Storm&#39;s backpressure mechanism is implemented independently of the Spout API, so all existing Spouts are supported.</p> + +<h2 id="resource-aware-scheduler">Resource Aware Scheduler</h2> + +<p>Based on Storm pluggable topology scheduler API, Storm 1.0 adds a new scheduler implementation that takes into account both the memory (on-heap and off-heap) and CPU resources available in a cluster. The resources aware scheduler (AKA &quot;RAS Scheduler&quot;) allows users to specify the memory and CPU requirements for individual topology components (Spouts/Bolts), and Storm will schedule topology tasks among workers to best meet those requirements.</p> + +<p>In the future, the Storm community plans to extend the RAS implmentation to support network resources and rack awareness as well.</p> + +<h2 id="dynamic-log-levels">Dynamic Log Levels</h2> + +<p>Storm 1.0 now allows users and administrators to dynamically change the log level settings for a running topology both from the Storm UI as well as the command line. Users can also specify an optional timeout after which those changes will be automatically reverted. The resulting log files are also easily searchable from the Storm UI and logviewer service.</p> + +<h2 id="tuple-sampling-and-debugging">Tuple Sampling and Debugging</h2> + +<p>In the course of debugging a topology, many Storm users find themselves adding &quot;debug&quot; bolts or Trident functions to log information about the data flowing through the topology, only to remove or disable them for production deployment. Storm 1.0 eliminates this need through the new Topology Debug capability.</p> + +<p>Storm UI now includes a function that allow you to sample a percentage tuples flowing through a topology or individual component directly from the Storm UI. The sampled events can then be viewed directly from the Storm UI and are also saved to disk.</p> + +<h2 id="distributed-log-search">Distributed Log Search</h2> + +<p>Another improvement to Storm&#39;s UI is the addition of a distributed log search. This search capability allows users to search across all log files of a specific topology, including archived (ZIP&#39;ed) logs. The search results will include matches from all Supervisor nodes.</p> + +<h2 id="dynamic-worker-profiling">Dynamic Worker Profiling</h2> + +<p>The last, but certainly not the least, usability improvement in Storm 1.0 is dynamic worker profiling. This new feature allows users to request worker profile data directly from Storm UI, including:</p> + +<ul> +<li>Heap Dumps</li> +<li>JStack Output</li> +<li>JProfile Recordings</li> +</ul> + +<p>The generated files are then available for download for off-line analysis with various debugging tools. It is also now possible to restart workers from the Storm UI.</p> + +<h2 id="thanks">Thanks</h2> + +<p>Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.</p> + +<h2 id="full-changelog">Full Changelog</h2> + +<ul> +<li>STORM-1670: LocalState#get(String) can throw FileNotFoundException which may result supervisor.clj#sync-processes stop assigning new workers/assignments</li> +<li>STORM-1677: Test resource files are excluded from source distribution, which makes logviewer-test failing</li> +<li>STORM-676: Storm Trident support for sliding/tumbling windows</li> +<li>STORM-1671: Enable logviewer to delete a dir without yaml</li> +<li>STORM-822: Kafka Spout New Consumer API</li> +<li>STORM-1673: log4j2/worker.xml refers old package of LoggerMetricsConsumer</li> +<li>STORM-1632 Disable event logging by default</li> +<li>STORM-1667: Log the IO exception when deleting worker pid dir</li> +<li>STORM-1669: Fix SolrUpdateBolt flush bug</li> +<li>STORM-1668: Flux silently fails while setting a non-existent property.</li> +<li>STORM-1573: Add batch support for MongoInsertBolt</li> +<li>STORM-1660: remove flux gitignore file and move rules to top level gitignore</li> +<li>STORM-1622: Rename classes with older third party shaded packages</li> +<li>STORM-1537: Upgrade to kryo 3</li> +<li>STORM-1556: nimbus.clj/wait-for-desired-code-replication wrong reset for current-replication-count-jar in local mode</li> +<li>STORM-1636: Supervisor shutdown with worker id pass in being nil</li> +<li>STORM-1641: make subtree node creation consistent</li> +<li>STORM-1604: Delayed transition should handle NotALeaderException</li> +<li>STORM-1602: Blobstore UTs are failed on Windows</li> +<li>STORM-1629: Files/move doesn&#39;t work properly with non-empty directory in Windows</li> +<li>STORM-1616: Add RAS API for Trident</li> +<li>STORM-1483: add storm-mongodb connector</li> +<li>STORM-1614: backpressure init and cleanup changes</li> +<li>STORM-1549: Add support for resetting tuple timeout from bolts via the OutputCollector</li> +<li>STORM-971: Metric for messages lost due to kafka retention</li> +<li>STORM-1608: Fix stateful topology acking behavior</li> +<li>STORM-1609: Netty Client is not best effort delivery on failed Connection</li> +<li>STORM-1620: Update curator to fix CURATOR-209</li> +<li>STORM-1469: Decommission SimpleTransportPlugin and configuration</li> +<li>STORM-1469: Adding Plain Sasl Transport Plugin</li> +<li>STORM-1588: Do not add event logger details if number of event loggers is zero</li> +<li>STORM-1606: print the information of testcase which is on failure</li> +<li>STORM-1436: Set Travis Heap size to fit in memory limits in travis builds.</li> +<li>STORM-1529: Change default worker temp directory location for workers</li> +<li>STORM-1543: DRPCSpout should always try to reconnect disconnected DRPCInvocationsClient</li> +<li>STORM-1561: Supervisor should relaunch worker if assignments have changed</li> +<li>STORM-1601: Check if /backpressure/storm-id node exists before requesting children</li> +<li>STORM-1574: Better handle backpressure exception etc.</li> +<li>STORM-1587: Avoid NPE while prining Metrics</li> +<li>STORM-1570: Storm SQL support for nested fields and array</li> +<li>STORM-1576: fix ConcurrentModificationException in addCheckpointInputs</li> +<li>STORM-1521: When using Kerberos login from keytab with multiple bolts/executors ticket is not renewed</li> +<li>STORM-1488: UI Topology Page component last error timestamp is from 1970</li> +<li>STORM-1542: Remove profile action retry in case of non-zero exit code</li> +<li>STORM-1540: Fix Debug/Sampling for Trident</li> +<li>STORM-1569: Allowing users to specify the nimbus thrift server queue size.</li> +<li>STORM-1552: Fix topology event sampling log dir </li> +<li>STORM-1511: min/max operations support on a trident stream</li> +<li>STORM-1522: REST API throws invalid worker log links</li> +<li>STORM-1532: Fix readCommandLineOpts to parse JSON correctly</li> +<li>STORM-1541: Change scope of &#39;hadoop-minicluster&#39; to test</li> +<li>STORM-1539: Improve Storm ACK-ing performance</li> +<li>STORM-1519: Storm syslog logging not confirming to RFC5426 3.1</li> +<li>STORM-1533: IntegerValidator for metric consumer parallelism hint</li> +<li>STORM-1534: Pick correct version of jackson-annotations jar</li> +<li>STORM-1476: Filter -c options from args and add them as part of storm.options</li> +<li>STORM-1520: Nimbus Clojure/Zookeeper issue (&quot;stateChanged&quot; method not found)</li> +<li>STORM-1531: Junit and mockito dependencies need to have correct scope defined in storm-elasticsearch pom.xml</li> +<li>STORM-1526: Improve Storm core performance</li> +<li>STORM-1524: Add Pluggable daemon metrics Reporters</li> +<li>STORM-1517: Add peek api in trident stream</li> +<li>STORM-1455: kafka spout should not reset to the beginning of partition when offsetoutofrange exception occurs</li> +<li>STORM-1518: Backport of STORM-1504</li> +<li>STORM-1505: Add map, flatMap and filter functions in trident stream</li> +<li>STORM-1510: Fix broken nimbus log link</li> +<li>STORM-1503: Worker should not crash on failure to send heartbeats to Pacemaker/ZK</li> +<li>STORM-1176: Checkpoint window evaluated/expired state</li> +<li>STORM-1494: Add link to supervisor log in Storm UI</li> +<li>STORM-1496: Nimbus periodically throws blobstore-related exception</li> +<li>STORM-1484: ignore subproject .classpath &amp; .project file</li> +<li>STORM-1478: make bolts getComponentConfiguration method cleaner/simpler</li> +<li>STORM-1499: fix wrong package name for storm trident</li> +<li>STORM-1463: added file scehma to log4j config files for windows env</li> +<li>STORM-1485: DRPC Connectivity Issues</li> +<li>STORM-1486: Fix storm-kafa documentation</li> +<li>STORM-1214: add javadoc for Trident Streams and Operations</li> +<li>STORM-1450: Fix minor bugs and refactor code in ResourceAwareScheduler</li> +<li>STORM-1452: Fixes profiling/debugging out of the box</li> +<li>STORM-1406: Add MQTT Support</li> +<li>STORM-1473: enable log search for daemon logs</li> +<li>STORM-1472: Fix the errorTime bug and show the time to be readable</li> +<li>STORM-1466: Move the org.apache.thrift7 namespace to something correct/sensible</li> +<li>STORM-1470: Applies shading to hadoop-auth, cleaner exclusions</li> +<li>STORM-1467: Switch apache-rat plugin off by default, but enable for Travis-CI</li> +<li>STORM-1468: move documentation to asf-site branch</li> +<li>STORM-1199: HDFS Spout Implementation.</li> +<li>STORM-1453: nimbus.clj/wait-for-desired-code-replication prints wrong log message</li> +<li>STORM-1419: Solr bolt should handle tick tuples</li> +<li>STORM-1175: State store for windowing operations</li> +<li>STORM-1202: Migrate APIs to org.apache.storm, but try to provide some form of backwards compatability</li> +<li>STORM-468: java.io.NotSerializableException should be explained</li> +<li>STORM-1348: refactor API to remove Insert/Update builder in Cassandra connector</li> +<li>STORM-1206: Reduce logviewer memory usage through directory stream</li> +<li>STORM-1219: Fix HDFS and Hive bolt flush/acking</li> +<li>STORM-1150: Fix the authorization of Logviewer in method authorized-log-user?</li> +<li>STORM-1418: improve debug logs for some external modules</li> +<li>STORM-1415: Some improvements for trident map StateUpdater</li> +<li>STORM-1414: Some improvements for multilang JsonSerializer</li> +<li>STORM-1408: clean up the build directory created by tests</li> +<li>STORM-1425: Tick tuples should be acked like normal tuples</li> +<li>STORM-1432: Spurious failure in storm-kafka test </li> +<li>STORM-1449: Fix Kafka spout to maintain backward compatibility</li> +<li>STORM-1458: Add check to see if nimbus is already running.</li> +<li>STORM-1462: Upgrade HikariCP to 2.4.3</li> +<li>STORM-1457: Avoid collecting pending tuples if topology.debug is off</li> +<li>STORM-1430: ui worker checkboxes</li> +<li>STORM-1423: storm UI in a secure env shows error even when credentials are present</li> +<li>STORM-702: Exhibitor support</li> +<li>STORM-1160: Add hadoop-auth dependency needed for storm-core</li> +<li>STORM-1404: Fix Mockito test failures in storm-kafka.</li> +<li>STORM-1379: Removed Redundant Structure</li> +<li>STORM-706: Clarify examples README for IntelliJ.</li> +<li>STORM-1396: Added backward compatibility method for File Download</li> +<li>STORM-695: storm CLI tool reports zero exit code on error scenario</li> +<li>STORM-1416: Documentation for state store</li> +<li>STORM-1426: keep backtype.storm.tuple.AddressedTuple and delete duplicated backtype.storm.messaging.AddressedTuple</li> +<li>STORM-1417: fixed equals/hashCode contract in CoordType</li> +<li>STORM-1422: broken example in storm-starter tutorial</li> +<li>STORM-1429: LocalizerTest fix</li> +<li>STORM-1401: removes multilang-test</li> +<li>STORM-1424: Removed unused topology-path variable</li> +<li>STORM-1427: add TupleUtils/listHashCode method and delete tuple.clj</li> +<li>STORM-1413: remove unused variables for some tests</li> +<li>STORM-1412: null check should be done in the first place</li> +<li>STORM-1210: Set Output Stream id in KafkaSpout</li> +<li>STORM-1397: Merge conflict from Pacemaker merge</li> +<li>STORM-1373: Blobstore API sample example usage</li> +<li>STORM-1409: StormClientErrorHandler is not used</li> +<li>STORM-1411: Some fixes for storm-windowing</li> +<li>STORM-1399: Blobstore tests should write data to <code>target</code> so it gets removed when running <code>mvn clean</code></li> +<li>STORM-1398: Add back in TopologyDetails.getTopology</li> +<li>STORM-898: Add priorities and per user resource guarantees to Resource Aware Scheduler</li> +<li>STORM-1187: Support windowing based on tuple ts.</li> +<li>STORM-1400: Netty Context removeClient() called after term() causes NullPointerException.</li> +<li>STORM-1383: Supervisors should not crash if nimbus is unavailable</li> +<li>STORM-1381: Client side topology submission hook.</li> +<li>STORM-1376: Performance slowdown due excessive zk connections and log-debugging</li> +<li>STORM-1395: Move JUnit dependency to top-level pom</li> +<li>STORM-1372: Merging design and usage documents for distcache</li> +<li>STORM-1393: Update the storm.log.dir function, add doc for logs</li> +<li>STORM-1377: nimbus_auth_test: very short timeouts causing spurious failures</li> +<li>STORM-1388: Fix url and email links in README file</li> +<li>STORM-1389: Removed creation of projection tuples as they are already available</li> +<li>STORM-1179: Create Maven Profiles for Integration Tests.</li> +<li>STORM-1387: workers-artifacts directory configurable, and default to be under storm.log.dir.</li> +<li>STORM-1211: Add trident state and query support for cassandra connector</li> +<li>STORM-1359: Change kryo links from google code to github</li> +<li>STORM-1385: Divide by zero exception in stats.clj</li> +<li>STORM-1370: Bug fixes for MultitenantScheduler</li> +<li>STORM-1374: fix random failure on WindowManagerTest</li> +<li>STORM-1040: SQL support for Storm.</li> +<li>STORM-1364: Log storm version on daemon start</li> +<li>STORM-1375: Blobstore broke Pacemaker</li> +<li>STORM-876: Blobstore/DistCache Support</li> +<li>STORM-1361: Apache License missing from two Cassandra files</li> +<li>STORM-756: Handle taskids response as soon as possible</li> +<li>STORM-1218: Use markdown for JavaDoc.</li> +<li>STORM-1075: Storm Cassandra connector.</li> +<li>STORM-965: excessive logging in storm when non-kerberos client tries to connect</li> +<li>STORM-1341: Let topology have own heartbeat timeout for multilang subprocess</li> +<li>STORM-1207: Added flux support for IWindowedBolt</li> +<li>STORM-1352: Trident should support writing to multiple Kafka clusters.</li> +<li>STORM-1220: Avoid double copying in the Kafka spout.</li> +<li>STORM-1340: Use Travis-CI build matrix to improve test execution times</li> +<li>STORM-1126: Allow a configMethod that takes no arguments (Flux)</li> +<li>STORM-1203: worker metadata file creation doesn&#39;t use storm.log.dir config</li> +<li>STORM-1349: [Flux] Allow constructorArgs to take Maps as arguments</li> +<li>STORM-126: Add Lifecycle support API for worker nodes</li> +<li>STORM-1213: Remove sigar binaries from source tree</li> +<li>STORM-885: Heartbeat Server (Pacemaker)</li> +<li>STORM-1221: Create a common interface for all Trident spout.</li> +<li>STORM-1198: Web UI to show resource usages and Total Resources on all supervisors</li> +<li>STORM-1167: Add windowing support for storm core.</li> +<li>STORM-1215: Use Async Loggers to avoid locking and logging overhead</li> +<li>STORM-1204: Logviewer should graceful report page-not-found instead of 500 for bad topo-id etc</li> +<li>STORM-831: Add BugTracker and Central Logging URL to UI</li> +<li>STORM-1208: UI: NPE seen when aggregating bolt streams stats</li> +<li>STORM-1016: Generate trident bolt ids with sorted group names</li> +<li>STORM-1190: System Load too high after recent changes</li> +<li>STORM-1098: Nimbus hook for topology actions.</li> +<li>STORM-1145: Have IConnection push tuples instead of pull them</li> +<li>STORM-1191: bump timeout by 50% due to intermittent travis build failures</li> +<li>STORM-794: Modify Spout async loop to treat activate/deactivate ASAP</li> +<li>STORM-1196: Upgrade to thrift 0.9.3</li> +<li>STORM-1155: Supervisor recurring health checks</li> +<li>STORM-1189: Maintain wire compatability with 0.10.x versions of storm.</li> +<li>STORM-1185: replace nimbus.host with nimbus.seeds</li> +<li>STORM-1164: Code cleanup for typos, warnings and conciseness.</li> +<li>STORM-902: Simple Log Search.</li> +<li>STORM-1052: TridentKafkaState uses new Kafka Producer API.</li> +<li>STORM-1182: Removing and wrapping some exceptions in ConfigValidation to make code cleaner</li> +<li>STORM-1134. Windows: Fix log4j config.</li> +<li>STORM-1127: allow for boolean arguments (Flux)</li> +<li>STORM-1138: Storm-hdfs README should be updated with Avro Bolt information</li> +<li>STORM-1154: SequenceFileBolt needs unit tests</li> +<li>STORM-162: Load Aware Shuffle Grouping</li> +<li>STORM-1158: Storm metrics to profile various storm functions</li> +<li>STORM-1161: Add License headers and add rat checks to builds</li> +<li>STORM-1165: normalize the scales of CPU/Mem/Net
<TRUNCATED>
