storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
Subject svn commit: r31817 [2/3] - in /dev/storm/apache-storm-2.0.0-rc4: RELEASE_NOTES.html RELEASE_NOTES.html.asc RELEASE_NOTES.html.md5 RELEASE_NOTES.html.sha512
Date Tue, 08 Jan 2019 18:37:35 GMT

Added: dev/storm/apache-storm-2.0.0-rc4/RELEASE_NOTES.html
--- dev/storm/apache-storm-2.0.0-rc4/RELEASE_NOTES.html (added)
+++ dev/storm/apache-storm-2.0.0-rc4/RELEASE_NOTES.html Tue Jan  8 18:37:35 2019
@@ -0,0 +1,1096 @@
+<!DOCTYPE html>
+<html lang="en">
+<meta charset="utf-8">
+<title>Storm 2.0.0 Release Notes</title>
+<h1>Release Notes for Storm 2.0.0</h1>
+<p>JIRA issues addressed in the 2.0.0 release of Storm. Documentation for this
+    release is available at the <a href="">Apache Storm
+    project site</a>.</p>
+<h2>New Feature</h2>
+<li>[<a href="">STORM-171</a>] - Add "progress" method to OutputCollector</li>
+<li>[<a href="">STORM-1226</a>] - Port backtype.storm.util to java</li>
+<li>[<a href="">STORM-1227</a>] - port backtype.storm.config to java</li>
+<li>[<a href="">STORM-1228</a>] - port  backtype.storm.fields-test to java</li>
+<li>[<a href="">STORM-1229</a>] - port backtype.storm.metric.testing to java</li>
+<li>[<a href="">STORM-1230</a>] - port  backtype.storm.process-simulator to java</li>
+<li>[<a href="">STORM-1231</a>] - port backtype.storm.scheduler.EvenScheduler to java</li>
+<li>[<a href="">STORM-1232</a>] - port  backtype.storm.scheduler.DefaultScheduler to java</li>
+<li>[<a href="">STORM-1233</a>] - port to java</li>
+<li>[<a href="">STORM-1234</a>] - port to java</li>
+<li>[<a href="">STORM-1235</a>] - port to java</li>
+<li>[<a href="">STORM-1236</a>] - port to java</li>
+<li>[<a href="">STORM-1237</a>] - port to java</li>
+<li>[<a href="">STORM-1238</a>] - port to java</li>
+<li>[<a href="">STORM-1239</a>] - port  backtype.storm.scheduler.IsolationScheduler to java</li>
+<li>[<a href="">STORM-1240</a>] - port to java</li>
+<li>[<a href="">STORM-1242</a>] - migrate backtype.storm.command.config-value to java</li>
+<li>[<a href="">STORM-1243</a>] - port backtype.storm.command.healthcheck to java</li>
+<li>[<a href="">STORM-1244</a>] - port backtype.storm.command.upload-credentials to java</li>
+<li>[<a href="">STORM-1245</a>] - port backtype.storm.daemon.acker to java</li>
+<li>[<a href="">STORM-1246</a>] - port backtype.storm.local-state to java</li>
+<li>[<a href="">STORM-1247</a>] - port  backtype.storm.messaging.local to java</li>
+<li>[<a href="">STORM-1248</a>] - port  backtype.storm.messaging.loader to java</li>
+<li>[<a href="">STORM-1249</a>] - port to java</li>
+<li>[<a href="">STORM-1250</a>] - port  backtype.storm.serialization-test to java</li>
+<li>[<a href="">STORM-1251</a>] - port  backtype.storm.serialization.SerializationFactory-test to java</li>
+<li>[<a href="">STORM-1252</a>] - port backtype.storm.stats to java</li>
+<li>[<a href="">STORM-1253</a>] - port  backtype.storm.timer to java</li>
+<li>[<a href="">STORM-1254</a>] - port backtype.storm.ui.helpers to java</li>
+<li>[<a href="">STORM-1255</a>] - port backtype.storm.utils-test to java</li>
+<li>[<a href="">STORM-1256</a>] - port backtype.storm.utils.ZookeeperServerCnxnFactory-test to java</li>
+<li>[<a href="">STORM-1257</a>] - port backtype.storm.zookeeper to java</li>
+<li>[<a href="">STORM-1258</a>] - port  backtype.storm.thrift to java</li>
+<li>[<a href="">STORM-1259</a>] - Create Clojure API package + tests</li>
+<li>[<a href="">STORM-1260</a>] - port backtype.storm.command.activate to java</li>
+<li>[<a href="">STORM-1261</a>] - port backtype.storm.command.deactivate to java</li>
+<li>[<a href="">STORM-1262</a>] - port to java</li>
+<li>[<a href="">STORM-1263</a>] - port backtype.storm.command.kill-topology to java</li>
+<li>[<a href="">STORM-1264</a>] - port backtype.storm.command.list to java</li>
+<li>[<a href="">STORM-1265</a>] - port backtype.storm.command.monitor to java</li>
+<li>[<a href="">STORM-1266</a>] - port backtype.storm.command.rebalance to java</li>
+<li>[<a href="">STORM-1267</a>] - port backtype.storm.command.set-log-level to java</li>
+<li>[<a href="">STORM-1268</a>] - port backtype.storm.daemon.builtin-metrics to java</li>
+<li>[<a href="">STORM-1269</a>] - port backtype.storm.daemon.common to java</li>
+<li>[<a href="">STORM-1270</a>] - port backtype.storm.daemon.drpc to java</li>
+<li>[<a href="">STORM-1271</a>] - port backtype.storm.daemon.task to java</li>
+<li>[<a href="">STORM-1272</a>] - port backtype.storm.disruptor to java</li>
+<li>[<a href="">STORM-1273</a>] - port backtype.storm.cluster to java</li>
+<li>[<a href="">STORM-1274</a>] - port backtype.storm.LocalDRPC to java</li>
+<li>[<a href="">STORM-1276</a>] - port backtype.storm.daemon.nimbus to java</li>
+<li>[<a href="">STORM-1277</a>] - port backtype.storm.daemon.executor to java</li>
+<li>[<a href="">STORM-1278</a>] - port backtype.storm.daemon.worker to java</li>
+<li>[<a href="">STORM-1279</a>] - port backtype.storm.daemon.supervisor to java</li>
+<li>[<a href="">STORM-1280</a>] - port backtype.storm.daemon.logviewer to java</li>
+<li>[<a href="">STORM-1281</a>] - port  backtype.storm.testing to java</li>
+<li>[<a href="">STORM-1282</a>] - port backtype.storm.LocalCluster to java</li>
+<li>[<a href="">STORM-1283</a>] - port backtype.storm.MockAutoCred to java</li>
+<li>[<a href="">STORM-1285</a>] - port backtype.storm.command.get-errors to java</li>
+<li>[<a href="">STORM-1286</a>] - port backtype.storm.command.kill-workers to java</li>
+<li>[<a href="">STORM-1289</a>] - port  backtype.storm.integration-test to java</li>
+<li>[<a href="">STORM-1290</a>] - port  backtype.storm.local-state-test to java</li>
+<li>[<a href="">STORM-1291</a>] - port  backtype.storm.logviewer-test to java</li>
+<li>[<a href="">STORM-1292</a>] - port  backtype.storm.messaging-test to java</li>
+<li>[<a href="">STORM-1294</a>] - port  backtype.storm.messaging.netty-unit-test to java</li>
+<li>[<a href="">STORM-1300</a>] - port  backtype.storm.scheduler.resource-aware-scheduler-test to java</li>
+<li>[<a href="">STORM-1306</a>] - port  backtype.storm.testing4j to java</li>
+<li>[<a href="">STORM-1307</a>] - port  backtype.storm.testing4j-test to java</li>
+<li>[<a href="">STORM-1308</a>] - port  backtype.storm.tick-tuple-test to java</li>
+<li>[<a href="">STORM-1311</a>] - port backtype.storm.ui.core to java</li>
+<li>[<a href="">STORM-1312</a>] - port backtype.storm.worker-test to java</li>
+<li>[<a href="">STORM-1318</a>] - Investigate if shuld be dropped</li>
+<li>[<a href="">STORM-1336</a>] - Evalute/Port JStorm cgroup support</li>
+<li>[<a href="">STORM-1434</a>] - Support the GROUP BY clause in StormSQL</li>
+<li>[<a href="">STORM-1435</a>] - Build a single jar with dependency for StormSQL dependency</li>
+<li>[<a href="">STORM-1443</a>] - Support customizing parallelism in StormSQL</li>
+<li>[<a href="">STORM-1444</a>] - Support EXPLAIN statement in StormSQL</li>
+<li>[<a href="">STORM-1529</a>] - Change default worker temp directory location for workers</li>
+<li>[<a href="">STORM-1549</a>] - Add support for extending tuple tree timeout</li>
+<li>[<a href="">STORM-1553</a>] - port backtype.storm.event to java</li>
+<li>[<a href="">STORM-1611</a>] - port org.apache.storm.pacemaker.pacemaker to java</li>
+<li>[<a href="">STORM-1705</a>] - Cap on number of retries for a failed message in kafka spout</li>
+<li>[<a href="">STORM-1720</a>] - Support GEO in storm-redis</li>
+<li>[<a href="">STORM-1723</a>] - Introduce ClusterMetricsConsumer</li>
+<li>[<a href="">STORM-1893</a>] - Support OpenTSDB for storing timeseries data.</li>
+<li>[<a href="">STORM-1914</a>] - Storm Kafka Field Topic Selector</li>
+<li>[<a href="">STORM-1919</a>] - Introduce FilterBolt on storm-redis</li>
+<li>[<a href="">STORM-1930</a>] - Kafka New Client API - Support for Topic Wildcards</li>
+<li>[<a href="">STORM-2009</a>] - port org.apache.storm.blobstore.clj and org.apache.storm.command.blobstore.clj to Java</li>
+<li>[<a href="">STORM-2010</a>] - port org.apache.storm.command.heartbeats.clj to Java</li>
+<li>[<a href="">STORM-2018</a>] - Simplify Threading Model of the Supervisor</li>
+<li>[<a href="">STORM-2038</a>] - Provide an alternative to using symlinks</li>
+<li>[<a href="">STORM-2057</a>] - Support JOIN statement in Storm SQL</li>
+<li>[<a href="">STORM-2083</a>] - Blacklist Scheduler</li>
+<li>[<a href="">STORM-2139</a>] - Let ShellBolts and ShellSpouts run with scripts from blobs</li>
+<li>[<a href="">STORM-2170</a>] - [Storm SQL] Add built-in socket datasource to runtime</li>
+<li>[<a href="">STORM-2172</a>] - [Storm SQL] Support Avro as input / output format</li>
+<li>[<a href="">STORM-2173</a>] - [Storm SQL] Support CSV as input / output format</li>
+<li>[<a href="">STORM-2177</a>] - [Storm SQL] Support TSV as input / output format</li>
+<li>[<a href="">STORM-2204</a>] - Add caching to HBaseLookupBolt</li>
+<li>[<a href="">STORM-2236</a>] - storm kafka client should support manual partition management.</li>
+<li>[<a href="">STORM-2294</a>] - Send activate and deactivate command from ShellSpout</li>
+<li>[<a href="">STORM-2327</a>] - Abstract class ConfigurableTopology</li>
+<li>[<a href="">STORM-2344</a>] - Flux YAML File Viewer for Nimbus UI</li>
+<li>[<a href="">STORM-2383</a>] - [storm-hbase] Support HBase as state backend</li>
+<li>[<a href="">STORM-2484</a>] - Flux: support bolt+spout memory configuration</li>
+<li>[<a href="">STORM-2490</a>] - Lambda support</li>
+<li>[<a href="">STORM-2492</a>] - Support Cassandra Object Mapper</li>
+<li>[<a href="">STORM-2609</a>] - We need a drpc-client command line.</li>
+<li>[<a href="">STORM-2610</a>] - Spout throtteling metrics are unusable</li>
+<li>[<a href="">STORM-2648</a>] - Kafka spout can't show acks/fails and complete latency when auto commit is enabled</li>
+<li>[<a href="">STORM-2694</a>] - Create a listener to handle tuple state changes of the KafkaSpout</li>
+<li>[<a href="">STORM-2790</a>] - Add nimbus admin groups</li>
+<li>[<a href="">STORM-2898</a>] - Storm should support auth through delegation tokens for workers</li>
+<li>[<a href="">STORM-3026</a>] - Upgrade ZK instance for security</li>
+<li>[<a href="">STORM-3027</a>] - Make Impersonation Optional</li>
+<li>[<a href="">STORM-3130</a>] - Add Timer registration and Timed object wrapper to Storm metrics util.</li>
+<li>[<a href="">STORM-3147</a>] - Port ClusterSummary as Metrics to StormMetricsRegistry</li>
+<li>[<a href="">STORM-3175</a>] - Use custom Callback in KafkaBolt</li>
+<li>[<a href="">STORM-3232</a>] - Display other versions of storm offered on the cluster in the UI</li>
+<li>[<a href="">STORM-3234</a>] - Document Cluster Metrics</li>
+<li>[<a href="">STORM-515</a>] - Clojure documentation and examples</li>
+<li>[<a href="">STORM-621</a>] - UI should expose more version information</li>
+<li>[<a href="">STORM-676</a>] - Storm Trident support for sliding/tumbling windows</li>
+<li>[<a href="">STORM-832</a>] - Validation for configuration settings beyond those in storm.yaml</li>
+<li>[<a href="">STORM-971</a>] - Storm-Kafka: Emit metric for messages lost due to kafka retention</li>
+<li>[<a href="">STORM-1086</a>] - Make FailedMsgRetryManager configurable when setting up KafkaSpout</li>
+<li>[<a href="">STORM-1136</a>] - Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets and integrate with storm ui</li>
+<li>[<a href="">STORM-1369</a>] - Add trident MapState to Cassandra</li>
+<li>[<a href="">STORM-1446</a>] - Compile the Calcite logical plan to Storm Trident logical plan</li>
+<li>[<a href="">STORM-1450</a>] - Fix bugs and refactor code in ResourceAwareScheduler</li>
+<li>[<a href="">STORM-1459</a>] - Allow not specifying producer properties in read-only Kafka table in StormSQL</li>
+<li>[<a href="">STORM-1464</a>] - storm-hdfs should support writing to multiple files</li>
+<li>[<a href="">STORM-1479</a>] - use a simple implemention for IntSerializer</li>
+<li>[<a href="">STORM-1511</a>] - min/max operations on trident stream</li>
+<li>[<a href="">STORM-1546</a>] - Adding Read and Write Aggregations for Pacemaker to make it HA compatible</li>
+<li>[<a href="">STORM-1569</a>] - Allowing users to specify the nimbus thrift server queue size.</li>
+<li>[<a href="">STORM-1570</a>] - Support nested field lookup in Storm sql</li>
+<li>[<a href="">STORM-1571</a>] - Improvment Kafka Spout Time Metric</li>
+<li>[<a href="">STORM-1574</a>] - Better exception handling in backpressure thread, and remove backpressure dir during topology kill.</li>
+<li>[<a href="">STORM-1590</a>] - port defmeters/defgauge/defhistogram... to java for all of our code to use</li>
+<li>[<a href="">STORM-1605</a>] - storm shell script should use /bin/env python to check python version</li>
+<li>[<a href="">STORM-1607</a>] - Add MongoMapState for supporting trident's exactly once semantics</li>
+<li>[<a href="">STORM-1618</a>] - Add the option of passing config directory apart from the file</li>
+<li>[<a href="">STORM-1624</a>] - add maven central status in README</li>
+<li>[<a href="">STORM-1648</a>] - DRPCSpout should attempt reconnect if on fail it cannot reach client</li>
+<li>[<a href="">STORM-1649</a>] - Optimize Kryo instaces creation in HBaseWindowsStore</li>
+<li>[<a href="">STORM-1659</a>] - Add documents for external projects</li>
+<li>[<a href="">STORM-1660</a>] - remove flux gitignore file and move rules to top level gitignore</li>
+<li>[<a href="">STORM-1664</a>] - Allow Java users to start a local cluster with a Nimbus Thrift server</li>
+<li>[<a href="">STORM-1671</a>] - Enable logviewer to delete directory with no yaml file </li>
+<li>[<a href="">STORM-1678</a>] - abstract batch processing to common api `BatchHelper`</li>
+<li>[<a href="">STORM-1679</a>] - add storm Scheduler documents</li>
+<li>[<a href="">STORM-1695</a>] - Create trident spout that uses the new kafka consumer API</li>
+<li>[<a href="">STORM-1701</a>] - Add simple JSON mapping to storm-hbase</li>
+<li>[<a href="">STORM-1709</a>] - Add group by support in storm-sql standalone mode</li>
+<li>[<a href="">STORM-1715</a>] - Jedis Default Host</li>
+<li>[<a href="">STORM-1719</a>] - Introduce REST API: Topology metric stats for stream</li>
+<li>[<a href="">STORM-1742</a>] - More accurate 'complete latency'</li>
+<li>[<a href="">STORM-1745</a>] - Add partition to PartitionManager logs where it's missing</li>
+<li>[<a href="">STORM-1755</a>] - Revert the kafka client version upgrade in storm-kafka module</li>
+<li>[<a href="">STORM-1766</a>] - A better algorithm server rack selection for RAS</li>
+<li>[<a href="">STORM-1833</a>] - Add simple equi-join support in storm-sql standalone mode</li>
+<li>[<a href="">STORM-1835</a>] - add lock info in thread dump</li>
+<li>[<a href="">STORM-1839</a>] - Kinesis Spout</li>
+<li>[<a href="">STORM-1865</a>] - update command line client document</li>
+<li>[<a href="">STORM-1868</a>] - Modify TridentKafkaWordCount to run in distributed mode</li>
+<li>[<a href="">STORM-1870</a>] - Allow FluxShellBolt/Spout set custom "componentConfig" via yaml.</li>
+<li>[<a href="">STORM-1873</a>] - Reemit late tuples in windowed mode</li>
+<li>[<a href="">STORM-1874</a>] - Update Logger access permissions</li>
+<li>[<a href="">STORM-1876</a>] - Provide option to build storm-kafka against different kafka clients</li>
+<li>[<a href="">STORM-1886</a>] - Extend KeyValueState interface with delete method</li>
+<li>[<a href="">STORM-1888</a>] - add description for storm shell command</li>
+<li>[<a href="">STORM-1890</a>] - Employ cache-busting method to ensure newly deployed UI forces browsers to refetch scripts, templates, and CSS</li>
+<li>[<a href="">STORM-1899</a>] - Release HBase connection when topology shutdown</li>
+<li>[<a href="">STORM-1902</a>] - add a simple & flexible FileNameFormat for storm-hdfs</li>
+<li>[<a href="">STORM-1910</a>] - One topology can't use hdfs spout to read from two locations</li>
+<li>[<a href="">STORM-1913</a>] - Additions and Improvements for Trident RAS API</li>
+<li>[<a href="">STORM-1916</a>] - Add ability for worker-first classpath</li>
+<li>[<a href="">STORM-1922</a>] - Supervisor summary default order by host</li>
+<li>[<a href="">STORM-1927</a>] - Upgrade Jetty and Ring</li>
+<li>[<a href="">STORM-1950</a>] - Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition</li>
+<li>[<a href="">STORM-1966</a>] - Expand metric having Map type as value into multiple metrics based on entries</li>
+<li>[<a href="">STORM-1969</a>] - Modify HiveTopology to show usage of non-partition table</li>
+<li>[<a href="">STORM-1970</a>] - external project examples refator</li>
+<li>[<a href="">STORM-1979</a>] - Storm Druid connector implementation.</li>
+<li>[<a href="">STORM-1994</a>] - Add table with per-topology & worker resource usage and components in (new) supervisor and topology pages</li>
+<li>[<a href="">STORM-2003</a>] - Make sure config contains TOPIC before get it</li>
+<li>[<a href="">STORM-2012</a>] - Upgrade Kafka to</li>
+<li>[<a href="">STORM-2014</a>] - New Kafka spout duplicates checking if failed messages have reached max retries</li>
+<li>[<a href="">STORM-2016</a>] - Topology submission improvement: support adding local jars and maven artifacts on submission</li>
+<li>[<a href="">STORM-2058</a>] - Maven warnings about reporting.plugins.plugin.version is missing</li>
+<li>[<a href="">STORM-2063</a>] - Add thread name in worker logs</li>
+<li>[<a href="">STORM-2072</a>] - Add map, flatMap with different outputs (T->V) in Trident</li>
+<li>[<a href="">STORM-2078</a>] - Enable paging in worker data tables</li>
+<li>[<a href="">STORM-2081</a>] - create external directory for storm-sql various data sources and move storm-sql-kafka to it</li>
+<li>[<a href="">STORM-2082</a>] - add sql external module storm-sql-hdfs</li>
+<li>[<a href="">STORM-2084</a>] - after supervisor v2 merge async localizer and localizer</li>
+<li>[<a href="">STORM-2086</a>] - use DefaultTopicSelector instead of creating a new one</li>
+<li>[<a href="">STORM-2089</a>] - Replace Consumer of ISqlTridentDataSource with StateFactory and StateUpdater</li>
+<li>[<a href="">STORM-2092</a>] - optimize TridentKafkaState batch sending</li>
+<li>[<a href="">STORM-2097</a>] - Improve logging in trident core and examples</li>
+<li>[<a href="">STORM-2099</a>] - Introduce new sql external module: storm-sql-redis</li>
+<li>[<a href="">STORM-2103</a>] - Introduce new sql external module: storm-sql-mongodb</li>
+<li>[<a href="">STORM-2105</a>] - Cluster/Supervisor total and available resources displayed in the UI</li>
+<li>[<a href="">STORM-2122</a>] - Supervisor V2 can use a lot more memory</li>
+<li>[<a href="">STORM-2124</a>] - Show requested cpu/memory for each component on topology and component page</li>
+<li>[<a href="">STORM-2125</a>] - Use Calcite's implementation of Rex Compiler</li>
+<li>[<a href="">STORM-2127</a>] - Storm-eventhubs should use latest amqp and eventhubs-client versions</li>
+<li>[<a href="">STORM-2133</a>] - Page-rendered-at timestamp visible on the UI</li>
+<li>[<a href="">STORM-2134</a>] - improving the current scheduling strategy for RAS</li>
+<li>[<a href="">STORM-2145</a>] - Leave leader nimbus's hostname to log when trying to connect leader nimbus </li>
+<li>[<a href="">STORM-2148</a>] - [Storm SQL] Trident mode: back to code generate and compile Trident topology</li>
+<li>[<a href="">STORM-2182</a>] - Refactor Storm Kafka Examples Into Own Modules</li>
+<li>[<a href="">STORM-2188</a>] - It can be difficult to tell which thread is hanging when an executor fails to shut down in time in local mode</li>
+<li>[<a href="">STORM-2192</a>] - Add a new IAutoCredentials plugin to support SSL files</li>
+<li>[<a href="">STORM-2201</a>] - Dynamic scheduler configuration loader</li>
+<li>[<a href="">STORM-2203</a>] - Add a getAll method to KeyValueState interface</li>
+<li>[<a href="">STORM-2206</a>] - Topology Visualization revamp / swap underlying JS graphing library</li>
+<li>[<a href="">STORM-2212</a>] - Remove Redundant Declarations in Maven POM Files</li>
+<li>[<a href="">STORM-2214</a>] - Cache Kerberos tickets for long lived Daemons</li>
+<li>[<a href="">STORM-2215</a>] - Check that blobs are present before launching a topology</li>
+<li>[<a href="">STORM-2216</a>] - Favor JSONValue.parseWithException</li>
+<li>[<a href="">STORM-2217</a>] - Finish porting drpc to java</li>
+<li>[<a href="">STORM-2220</a>] - Adding config keys for CassandraBolts instead of taking at topology level configuration.</li>
+<li>[<a href="">STORM-2223</a>] - Storm PMML Bolt</li>
+<li>[<a href="">STORM-2224</a>] - Expose a method to override in computing the field from given tuple in FieldSelector</li>
+<li>[<a href="">STORM-2225</a>] - Kafka New API make simple things simple</li>
+<li>[<a href="">STORM-2235</a>] - Introduce new option: 'add remote repositories' for dependency resolver</li>
+<li>[<a href="">STORM-2238</a>] - Add Timestamp extractor for windowed bolt</li>
+<li>[<a href="">STORM-2243</a>] - Add ip address to supervisor id for easier debugging</li>
+<li>[<a href="">STORM-2250</a>] - Kafka Spout Refactoring to Increase Modularity and Testability</li>
+<li>[<a href="">STORM-2277</a>] - Add shaded jar for Druid connector</li>
+<li>[<a href="">STORM-2278</a>] - Allow max number of disruptor queue flusher threads to be configurable.</li>
+<li>[<a href="">STORM-2280</a>] - Upgrade Calcite version to 1.11.0</li>
+<li>[<a href="">STORM-2296</a>] - Kafka spout - no duplicates on topic leader changes</li>
+<li>[<a href="">STORM-2297</a>] - [storm-opentsdb] Support Flux for OpenTSDBBolt</li>
+<li>[<a href="">STORM-2298</a>] - Don't kill Nimbus when ClusterMetricsConsumer is failed to initialize</li>
+<li>[<a href="">STORM-2300</a>] - [Flux] support list of references</li>
+<li>[<a href="">STORM-2301</a>] - [storm-cassandra] upgrade cassandra driver to 3.1.2</li>
+<li>[<a href="">STORM-2333</a>] - CGroup Metrics</li>
+<li>[<a href="">STORM-2340</a>] - fix AutoCommitMode issue in KafkaSpout</li>
+<li>[<a href="">STORM-2363</a>] - Provide configuration to set the number of RollingWindow</li>
+<li>[<a href="">STORM-2365</a>] - Support for specifying output stream in event hubs spout</li>
+<li>[<a href="">STORM-2369</a>] - [storm-redis] Use binary type for State management</li>
+<li>[<a href="">STORM-2379</a>] - [storm-elasticsearch] switch ES client to Java REST API</li>
+<li>[<a href="">STORM-2381</a>] - Add logging of JDBC connection string in storm-jdbc integration for debugging failures</li>
+<li>[<a href="">STORM-2406</a>] - [Storm SQL] Change underlying API to Streams API (for 2.0.0)</li>
+<li>[<a href="">STORM-2416</a>] - Release Packaging Improvements</li>
+<li>[<a href="">STORM-2421</a>] - Support lists of childopts beyond just worker</li>
+<li>[<a href="">STORM-2438</a>] - on-demand resource requirement scaling</li>
+<li>[<a href="">STORM-2441</a>] - Break down 'storm-core' to extract client (worker) artifacts</li>
+<li>[<a href="">STORM-2447</a>] - Make local cluster transparent</li>
+<li>[<a href="">STORM-2448</a>] - Support running workers using older JVMs/storm versions</li>
+<li>[<a href="">STORM-2453</a>] - Move non-connectors into the top directory</li>
+<li>[<a href="">STORM-2455</a>] - Expose the window start and end timestamp in TupleWindow</li>
+<li>[<a href="">STORM-2458</a>] - Kafka Spout should allow hooking up custom logic when retries have exhanusted</li>
+<li>[<a href="">STORM-2468</a>] - Remove Clojure from storm-client</li>
+<li>[<a href="">STORM-2471</a>] - Metric for thread count in a worker</li>
+<li>[<a href="">STORM-2477</a>] - Configs should have generics</li>
+<li>[<a href="">STORM-2481</a>] - Upgrade Aether version to resolve Aether bug BUG-451566</li>
+<li>[<a href="">STORM-2482</a>] - Refactor the Storm auto credential plugins to be more usable</li>
+<li>[<a href="">STORM-2491</a>] - Missing various configuration parameters to configure the Cassandra client used by the Cassandra Bolts</li>
+<li>[<a href="">STORM-2493</a>] - update documents to reflect the changes</li>
+<li>[<a href="">STORM-2495</a>] - Integrate checkstyle check during build</li>
+<li>[<a href="">STORM-2497</a>] - Support Shared Memory Scheduling in RAS</li>
+<li>[<a href="">STORM-2501</a>] - Implement auto credential plugin for Hive</li>
+<li>[<a href="">STORM-2510</a>] - adjust checkstyle configurations to decrease violations</li>
+<li>[<a href="">STORM-2512</a>] - Change KafkaSpoutConfig in storm-kafka-client to make it work with flux</li>
+<li>[<a href="">STORM-2515</a>] - Fix most checkstyle violations for storm-kafka-client</li>
+<li>[<a href="">STORM-2519</a>] - AbstractAutoCreds should look for configKeys in both nimbus and topology configs</li>
+<li>[<a href="">STORM-2524</a>] - Set Kafka with storm-kafka</li>
+<li>[<a href="">STORM-2527</a>] - Initialize java.sql.DriverManager earlier to avoid deadlock between DriverManager static initializer and driver static initializer</li>
+<li>[<a href="">STORM-2528</a>] - Bump log4j version to 2.8.2</li>
+<li>[<a href="">STORM-2537</a>] - Resolve checkstyle violations in storm-webapp module</li>
+<li>[<a href="">STORM-2542</a>] - Deprecate storm-kafka-client KafkaConsumer.subscribe API subscriptions on 1.x and remove them as options in 2.x</li>
+<li>[<a href="">STORM-2543</a>] - Allow Topologies to query current version of downloaded blobs</li>
+<li>[<a href="">STORM-2548</a>] - Simplify KafkaSpoutConfig</li>
+<li>[<a href="">STORM-2551</a>] - Thrift client socket timeout</li>
+<li>[<a href="">STORM-2553</a>] - JedisCluster does not support password</li>
+<li>[<a href="">STORM-2556</a>] - Break down Auto* classes into Nimbus plugin and Worker / Submitter plugin</li>
+<li>[<a href="">STORM-2598</a>] - Add proxy server option for dependency resolver</li>
+<li>[<a href="">STORM-2601</a>] - the method of getting the nimbus cilent doenot accept timeout parameter</li>
+<li>[<a href="">STORM-2614</a>] - Enhance stateful windowing to persist the window state</li>
+<li>[<a href="">STORM-2615</a>] - Improvements for access to topology</li>
+<li>[<a href="">STORM-2616</a>] - Document the built in metrics (just in time to replace them???)</li>
+<li>[<a href="">STORM-2618</a>] - Add TridentKafkaStateUpdater for storm-kafka-client</li>
+<li>[<a href="">STORM-2622</a>] - Add owner resource summary</li>
+<li>[<a href="">STORM-2623</a>] - Add in a whitelist for scheduler strategies</li>
+<li>[<a href="">STORM-2626</a>] - Provided a template for drpc-auth-acl.yaml</li>
+<li>[<a href="">STORM-2630</a>] - Apply new code style to storm-sql-hdfs</li>
+<li>[<a href="">STORM-2631</a>] - Apply new code style to storm-sql-mongodb</li>
+<li>[<a href="">STORM-2632</a>] - Apply new code style to storm-sql-kafka</li>
+<li>[<a href="">STORM-2633</a>] - Apply new code style to storm-sql-redis</li>
+<li>[<a href="">STORM-2634</a>] - Apply new code style to storm-sql-runtime</li>
+<li>[<a href="">STORM-2643</a>] - Add a confirmation dialog for profiling and debugging actions on Storm UI</li>
+<li>[<a href="">STORM-2644</a>] - Show message when result not found on deep search page</li>
+<li>[<a href="">STORM-2649</a>] - Update config validation check to give better information</li>
+<li>[<a href="">STORM-2650</a>] - Add test for non-string property substitution in Flux tests</li>
+<li>[<a href="">STORM-2653</a>] - PaceMaker code improvement</li>
+<li>[<a href="">STORM-2654</a>] - Error column in Storm UI loses original formatting</li>
+<li>[<a href="">STORM-2657</a>] - Update SECURITY.MD </li>
+<li>[<a href="">STORM-2658</a>] - Provide storm-kafka-client spout examples</li>
+<li>[<a href="">STORM-2664</a>] - Fix for the distribution packaged on Windows OS can't run on Linux</li>
+<li>[<a href="">STORM-2671</a>] - For the love of all that is good remove storm-rename-hack</li>
+<li>[<a href="">STORM-2672</a>] - Expose a metric for calls to reportError()</li>
+<li>[<a href="">STORM-2673</a>] - For debugging allow users to tell the scheduler which nodes they would prefer</li>
+<li>[<a href="">STORM-2679</a>] - Need to close resources and streams after use</li>
+<li>[<a href="">STORM-2689</a>] - storm-kafka-examples and storm-kafka-client-examples are difficult for new users to run</li>
+<li>[<a href="">STORM-2693</a>] - Topology submission or kill takes too much time when topologies grow to a few hundred</li>
+<li>[<a href="">STORM-2698</a>] - Upgrade to newest Mockito and Hamcrest versions</li>
+<li>[<a href="">STORM-2699</a>] - Put all the version information of third party components into the main pom </li>
+<li>[<a href="">STORM-2702</a>] - Better load generation testing tools</li>
+<li>[<a href="">STORM-2712</a>] - accept arbitrary number of rows per tuple in storm-cassandra</li>
+<li>[<a href="">STORM-2717</a>] - Output topology Id from storm list command</li>
+<li>[<a href="">STORM-2718</a>] - Show some descriptions on LogViewer index page</li>
+<li>[<a href="">STORM-2730</a>] -  Add in config options for acker cpu and memory</li>
+<li>[<a href="">STORM-2731</a>] - Simple checks in Storm Windowing</li>
+<li>[<a href="">STORM-2740</a>] - Add caching of some blobs in nimbus to improve performance</li>
+<li>[<a href="">STORM-2741</a>] - Add in config options for metrics consumer cpu and memory</li>
+<li>[<a href="">STORM-2743</a>] - Add logging to monitor how long scheduling is taking</li>
+<li>[<a href="">STORM-2744</a>] - Add in "restart timeout" for backpressure</li>
+<li>[<a href="">STORM-2759</a>] - Let users indicate if a worker should restart on blob download</li>
+<li>[<a href="">STORM-2760</a>] - Add Blobstore Migration Scripts</li>
+<li>[<a href="">STORM-2767</a>] - Surefire now truncates too much of the stack trace</li>
+<li>[<a href="">STORM-2770</a>] - Add fragmentation metrics for CPU and Memory</li>
+<li>[<a href="">STORM-2775</a>] - Improve KafkaPartition Metric Names</li>
+<li>[<a href="">STORM-2781</a>] - Refactor storm-kafka-client KafkaSpout  Processing Guarantees</li>
+<li>[<a href="">STORM-2782</a>] - Refactor partial key grouping for greater flexibility</li>
+<li>[<a href="">STORM-2791</a>] - Add support for multiple output fields to FixedTupleSpout</li>
+<li>[<a href="">STORM-2792</a>] - Clean up RAS and remove possible loops</li>
+<li>[<a href="">STORM-2793</a>] - Add transferred byte count metrics</li>
+<li>[<a href="">STORM-2796</a>] - Flux: Provide means for invoking static factory methods and improve non-primitive number handling</li>
+<li>[<a href="">STORM-2805</a>] - Clean up configs in topology builders</li>
+<li>[<a href="">STORM-2806</a>] - Give users the option to disable the login cache</li>
+<li>[<a href="">STORM-2807</a>] - Integration test should shut down topologies immediately after the test</li>
+<li>[<a href="">STORM-2813</a>] - Clean up RAS resource Map.</li>
+<li>[<a href="">STORM-2832</a>] - misuse of Utils.readStormConfig() and ConfigUtils.readStormConfig()</li>
+<li>[<a href="">STORM-2837</a>] - RAS Constraint Solver Strategy</li>
+<li>[<a href="">STORM-2842</a>] - Fixed links for YARN&Kubernetes Integration</li>
+<li>[<a href="">STORM-2854</a>] - Expose IEventLogger to make event logging pluggable</li>
+<li>[<a href="">STORM-2857</a>] - Loosen some constraints on validation to support running topologies of older version</li>
+<li>[<a href="">STORM-2860</a>] - Add Kerberos support to Solr bolt</li>
+<li>[<a href="">STORM-2862</a>] - More flexible logging in multilang (Python, Ruby, JS)</li>
+<li>[<a href="">STORM-2864</a>] - Minor optimisation about trident kafka state</li>
+<li>[<a href="">STORM-2867</a>] - Add Consumer lag metrics to Kafka Spout</li>
+<li>[<a href="">STORM-2877</a>] - Introduce an option to configure pagination in Storm UI </li>
+<li>[<a href="">STORM-2891</a>] - Upgrade Checkstyle plugin to version 3.0.0</li>
+<li>[<a href="">STORM-2896</a>] - Support automatic migration of offsets from storm-kafka to storm-kafka-client KafkaSpout</li>
+<li>[<a href="">STORM-2897</a>] - Optimize defaults.yaml by removing the zeromq configurations and adding some annotations</li>
+<li>[<a href="">STORM-2899</a>] - Remove/replace the contributors lists in the README and on</li>
+<li>[<a href="">STORM-2901</a>] - Reuse ZK connection for getKeySequenceNumber</li>
+<li>[<a href="">STORM-2902</a>] - Some improvements for storm-rocketmq module</li>
+<li>[<a href="">STORM-2909</a>] - New Metrics Reporting API - for 2.0.0</li>
+<li>[<a href="">STORM-2914</a>] - Remove support from storm-kafka-client</li>
+<li>[<a href="">STORM-2916</a>] - Separate hdfs-blobstore from storm-hdfs</li>
+<li>[<a href="">STORM-2917</a>] - Check the config( before using it to connect</li>
+<li>[<a href="">STORM-2933</a>] - Add a storm-perf topology that uses storm-kafka-client, so we can benchmark that module</li>
+<li>[<a href="">STORM-2939</a>] - Create interface for processing worker metrics</li>
+<li>[<a href="">STORM-2948</a>] - Add -XX:+HeapDumpOnOutOfMemoryError for maven-surefire-plugin in pom.xml </li>
+<li>[<a href="">STORM-2958</a>] - Use new wait strategies for Spout as well</li>
+<li>[<a href="">STORM-2961</a>] - Refactoring duplicate code in Topology Builder classes</li>
+<li>[<a href="">STORM-2977</a>] - Update the BlowfishTupleSerializer to make it simpler to use</li>
+<li>[<a href="">STORM-2990</a>] - Make the storm-kafka-client Trident spout FirstPollOffsetStrategy behavior consistent with the regular spout</li>
+<li>[<a href="">STORM-2997</a>] - Add logviewer ssl module in </li>
+<li>[<a href="">STORM-2998</a>] - Wrong className in LoggerFactory.getLogger method</li>
+<li>[<a href="">STORM-3006</a>] - Distributed RPC documentation needs an update</li>
+<li>[<a href="">STORM-3011</a>] - Use default bin path in flight.bash if $JAVA_HOME is undefined</li>
+<li>[<a href="">STORM-3017</a>] - Refactor pacemaker code</li>
+<li>[<a href="">STORM-3022</a>] - Decouple storm-hive UTs with Hive</li>
+<li>[<a href="">STORM-3025</a>] - Optimize Scheduler Loopy loops with Caching in Cluster State</li>
+<li>[<a href="">STORM-3029</a>] - Don't use keytab if AutoTGT is used</li>
+<li>[<a href="">STORM-3036</a>] - Add isRemoteBlobExists RPC interface for deciding if remote blob exists</li>
+<li>[<a href="">STORM-3037</a>] - Improve CheckStyle code compatibility</li>
+<li>[<a href="">STORM-3039</a>] - Ports of killed topologies remain in TIME_WAIT state preventing to start new topology</li>
+<li>[<a href="">STORM-3040</a>] - RAS scheduling performance improvements</li>
+<li>[<a href="">STORM-3041</a>] - worker-launcher setup is confusing</li>
+<li>[<a href="">STORM-3044</a>] - AutoTGT should ideally check if a TGT is specific to IP addresses and reject</li>
+<li>[<a href="">STORM-3061</a>] - Upgrade Dependencies before 2.x release</li>
+<li>[<a href="">STORM-3064</a>] - PartitionedTridentSpoutExecutor should use getPartitionsForTask</li>
+<li>[<a href="">STORM-3069</a>] - Allow users to specify maven local repository directory for storm submit tool</li>
+<li>[<a href="">STORM-3083</a>] - Upgrade HikariCP version to 2.4.7</li>
+<li>[<a href="">STORM-3093</a>] - Cache the storm id to executors mapping on master to avoid repeat computation</li>
+<li>[<a href="">STORM-3094</a>] - Topology name needs to be validated at storm-client</li>
+<li>[<a href="">STORM-3099</a>] - Extend metrics on supervisor, workers, and DRPC</li>
+<li>[<a href="">STORM-3115</a>] - Add admin command to get a zookeeper shell</li>
+<li>[<a href="">STORM-3125</a>] - Refactoring methods in components for Supervisor and DRPC</li>
+<li>[<a href="">STORM-3131</a>] - Support hostname-substitution for blobstore.hdfs.principal</li>
+<li>[<a href="">STORM-3133</a>] - Extend metrics on Nimbus and LogViewer</li>
+<li>[<a href="">STORM-3134</a>] - upload-credentials imporvements</li>
+<li>[<a href="">STORM-3138</a>] - dev-zookeeper logging to stdout is annoying</li>
+<li>[<a href="">STORM-3142</a>] - Add support for JUnit 5 tests</li>
+<li>[<a href="">STORM-3150</a>] - Improve Gauge Registration in StormMetricsRegistry</li>
+<li>[<a href="">STORM-3157</a>] - General improvement to StormMetricsRegistry</li>
+<li>[<a href="">STORM-3196</a>] - 'storm list' should include topology owner in output</li>
+<li>[<a href="">STORM-3198</a>] - Topology submitters should be able to supply log4j2 configurations</li>
+<li>[<a href="">STORM-3205</a>] - Optimization in TuplImpl</li>
+<li>[<a href="">STORM-3222</a>] - Fix KafkaSpout internals to use LinkedList instead of ArrayList</li>
+<li>[<a href="">STORM-3226</a>] - Improve Supervisor authorization handler error message</li>
+<li>[<a href="">STORM-3227</a>] - Improve security of credentials push</li>
+<li>[<a href="">STORM-3229</a>] - Better error reporting in WorkerTokenAuthorizer</li>
+<li>[<a href="">STORM-3242</a>] - Example and External maven modules in their own profiles</li>
+<li>[<a href="">STORM-3243</a>] - Clean up Maven POM dependency on clojure</li>
+<li>[<a href="">STORM-3258</a>] - prevent flooding supervisor log with blobstore location</li>
+<li>[<a href="">STORM-3260</a>] - Add in more admin commands to debug cluster state</li>
+<li>[<a href="">STORM-3263</a>] - Memory and CPU guarantee columns do not sort correctly in Owner Summary</li>
+<li>[<a href="">STORM-3292</a>] - Trident HiveState must flush writers when the batch commits</li>
+<li>[<a href="">STORM-203</a>] - Add /usr/lib64 in default java library path</li>
+<li>[<a href="">STORM-584</a>] - LoggingMetricsConsumer metrics.log file is shared by multiple topologies.</li>
+<li>[<a href="">STORM-1114</a>] - Racing condition in trident zookeeper zk-node create/delete</li>
+<li>[<a href="">STORM-1344</a>] - storm-jdbc build error "object name already exists: USER_DETAILS in statement"</li>
+<li>[<a href="">STORM-1363</a>] - TridentKafkaState should handle null values from TridentTupleToKafkaMapper.getMessageFromTuple()</li>
+<li>[<a href="">STORM-1476</a>] - Filter -c options from args and add them as part of storm.options</li>
+<li>[<a href="">STORM-1481</a>] - avoid Math.abs(Integer) get a negative value</li>
+<li>[<a href="">STORM-1492</a>] - With nimbus.seeds set to default, a nimbus for localhost may appear "Offline"</li>
+<li>[<a href="">STORM-1516</a>] - Topology workers are not getting killed when a topology is killed.</li>
+<li>[<a href="">STORM-1521</a>] - When using Kerberos login from keytab with multiple bolts/executors ticket is not renewed</li>
+<li>[<a href="">STORM-1522</a>] - REST API throws invalid worker log links.</li>
+<li>[<a href="">STORM-1528</a>] - Fix CsvPreparableReporter log directory</li>
+<li>[<a href="">STORM-1530</a>] - Add API doc for minBy/min/max/maxBy operations on stream</li>
+<li>[<a href="">STORM-1532</a>] - Fix readCommandLineOpts to parse JSON correctly</li>
+<li>[<a href="">STORM-1535</a>] - Storm-HDFS - When using keytab Kerberos ticket is not renewed with multiple bolts/executors</li>
+<li>[<a href="">STORM-1538</a>] - Exception being thrown after Utils conversion to java</li>
+<li>[<a href="">STORM-1541</a>] - Change scope of 'hadoop-minicluster' to test</li>
+<li>[<a href="">STORM-1543</a>] - DRPCSpout should always try to reconnect disconnected DRPCInvocationsClient</li>
+<li>[<a href="">STORM-1544</a>] - Document Debug/Sampling of Topologies</li>
+<li>[<a href="">STORM-1545</a>] - Topology Debug Event Log in Wrong Location</li>
+<li>[<a href="">STORM-1556</a>] - nimbus.clj/wait-for-desired-code-replication wrong reset for current-replication-count-jar in local mode</li>
+<li>[<a href="">STORM-1558</a>] - Utils in java breaks component page due to illegal type cast</li>
+<li>[<a href="">STORM-1561</a>] - Supervisor should relaunch worker if assignments have changed</li>
+<li>[<a href="">STORM-1564</a>] - fix wrong package-info in org.apache.storm.utils.staticmocking</li>
+<li>[<a href="">STORM-1566</a>] - Worker exits with error o.a.s.d.worker [ERROR] Error on initialization of server mk-worker java.lang.ClassCastException: java.lang.String cannot be cast to</li>
+<li>[<a href="">STORM-1567</a>] - in defaults.yaml  'topology.disable.loadaware' should be 'topology.disable.loadaware.messaging'</li>
+<li>[<a href="">STORM-1572</a>] - throw NPE when parsing the command line arguments by CLI</li>
+<li>[<a href="">STORM-1575</a>] - TwitterSampleSpout throws NPE on close</li>
+<li>[<a href="">STORM-1578</a>] - ClassCastException from Integer to Long for "port" in cluster.clj translation</li>
+<li>[<a href="">STORM-1579</a>] - Got NoSuchFileException when running tests in storm-core</li>
+<li>[<a href="">STORM-1588</a>] - component page gets divide by 0 if no event loggers configured</li>
+<li>[<a href="">STORM-1592</a>] - clojure code calling into Utils.exitProcess throws ClassCastException</li>
+<li>[<a href="">STORM-1594</a>] - org.apache.storm.tuple.Fields can throw NPE if given invalid field in selector</li>
+<li>[<a href="">STORM-1596</a>] - Multiple Subject sharing Kerberos TGT - causes services to fail</li>
+<li>[<a href="">STORM-1608</a>] - Fix stateful topology acking behavior</li>
+<li>[<a href="">STORM-1609</a>] - Netty Client is not best effort delivery on failed Connection</li>
+<li>[<a href="">STORM-1614</a>] - Clean backpressure zk node in do-cleanup</li>
+<li>[<a href="">STORM-1615</a>] - Update state checkpointing doc with bolt's acking contract</li>
+<li>[<a href="">STORM-1623</a>] - nimbus.clj's minor bug</li>
+<li>[<a href="">STORM-1625</a>] - Move storm-sql dependencies out of lib folder</li>
+<li>[<a href="">STORM-1631</a>] - storm CGroup bugs 1) when launching workers as the user that submitted the topology 2) when initial cleanup of cgroup fails</li>
+<li>[<a href="">STORM-1636</a>] -  Supervisor shutdown with worker id pass in being nil </li>
+<li>[<a href="">STORM-1642</a>] - NullPointerException when deserialize</li>
+<li>[<a href="">STORM-1646</a>] - Intermittent test failures in storm-kafka unit tests</li>
+<li>[<a href="">STORM-1658</a>] - documents improvements and links fixes</li>
+<li>[<a href="">STORM-1663</a>] - Clicking on an active topology from storm ui home page and then refreshing the page throws exception</li>
+<li>[<a href="">STORM-1665</a>] - Worker cannot instantiate kryo</li>
+<li>[<a href="">STORM-1666</a>] - Kill from the UI fails silently.</li>
+<li>[<a href="">STORM-1669</a>] - Fix SolrUpdateBolt flush bug</li>
+<li>[<a href="">STORM-1670</a>] - LocalState#get(String) can throw FileNotFoundException which results in not removing worker heartbeats and supervisor is kind of stuck and goes down after some time.</li>
+<li>[<a href="">STORM-1672</a>] - Stats not get class cast exception</li>
+<li>[<a href="">STORM-1673</a>] - log4j2/worker.xml refers old package of LoggerMetricsConsumer</li>
+<li>[<a href="">STORM-1674</a>] - Idle KafkaSpout consumes more bandwidth than needed</li>
+<li>[<a href="">STORM-1676</a>] - NullPointerException while serializing ClusterWorkerHearbeat</li>
+<li>[<a href="">STORM-1677</a>] - Test resource files (.log) are excluded from source distribution, which makes logviewer-test failing</li>
+<li>[<a href="">STORM-1681</a>] - Bug in scheduling cyclic topologies when scheduling with RAS</li>
+<li>[<a href="">STORM-1687</a>] - Divide by zero exception in stats</li>
+<li>[<a href="">STORM-1694</a>] - Kafka Spout Trident Implementation Using New Kafka Consumer API</li>
+<li>[<a href="">STORM-1696</a>] - Backpressure flag not sync if zookeeper connection errors</li>
+<li>[<a href="">STORM-1713</a>] - Don't use proprietary NotImplementedException in storm-kafka</li>
+<li>[<a href="">STORM-1728</a>] - TransactionalTridentKafkaSpout error</li>
+<li>[<a href="">STORM-1730</a>] - LocalCluster#shutdown() does not terminate all storm threads/thread pools.</li>
+<li>[<a href="">STORM-1733</a>] - Logs from bin/storm are lost because stdout and stderr are not flushed</li>
+<li>[<a href="">STORM-1735</a>] - Nimbus logs that replication was not reached when min-replication-count was reached exactly</li>
+<li>[<a href="">STORM-1737</a>] - storm-kafka-client has compilation errors with Apache Kafka 0.10</li>
+<li>[<a href="">STORM-1749</a>] - Fix storm-starter links in the github code</li>
+<li>[<a href="">STORM-1750</a>] - Report-error-and-die may not kill the worker</li>
+<li>[<a href="">STORM-1756</a>] - Storm-kafka tests leak resources due to retained references to KafkaServer</li>
+<li>[<a href="">STORM-1761</a>] - Storm-Solr Example Throws ArrayIndexOutOfBoundsException in Remote Cluster Mode</li>
+<li>[<a href="">STORM-1764</a>] - Pacemaker is throwing some stack traces</li>
+<li>[<a href="">STORM-1771</a>] - HiveState should flushAndClose before closing old or idle Hive connections</li>
+<li>[<a href="">STORM-1772</a>] - Create topologies for measuring performance</li>
+<li>[<a href="">STORM-1773</a>] - Utils.javaDeserialize() doesn't work with primitive types</li>
+<li>[<a href="">STORM-1832</a>] - Consistently slow metrics consumer triggers backpressure which will be never back to normal</li>
+<li>[<a href="">STORM-1834</a>] - Documentation How to Generate Certificates For Local Testing SSL Setup</li>
+<li>[<a href="">STORM-1837</a>] - Running local clusters without simulating time breaks Testing.completeTopology, and may cause message loss</li>
+<li>[<a href="">STORM-1841</a>] - Address a few minor issues in windowing and doc</li>
+<li>[<a href="">STORM-1842</a>] - Forward references in storm.thrift cause tooling issues</li>
+<li>[<a href="">STORM-1844</a>] - Some tests are flaky due to low timeout</li>
+<li>[<a href="">STORM-1848</a>] - NotSerializableException when using storm-kafka spout with event logging</li>
+<li>[<a href="">STORM-1849</a>] - HDFSFileTopology should take 3rd argument as topology name</li>
+<li>[<a href="">STORM-1851</a>] - Nimbus impersonation authorizer in defaults.yaml causes issues in secure mode</li>
+<li>[<a href="">STORM-1853</a>] - Deserialization issues in Utils.javaDeserialize()</li>
+<li>[<a href="">STORM-1859</a>] - Late tuples are not acked in windowed mode</li>
+<li>[<a href="">STORM-1861</a>] - Storm submit command returns exit code of 0 even when it fails</li>
+<li>[<a href="">STORM-1862</a>] - Flux ShellSpout and ShellBolt can't emit to named streams</li>
+<li>[<a href="">STORM-1864</a>] - StormSubmitter should show proper error messages for submitter hook invocation.</li>
+<li>[<a href="">STORM-1872</a>] - Storm Redis connection release </li>
+<li>[<a href="">STORM-1878</a>] - Flux does not handle stateful bolts</li>
+<li>[<a href="">STORM-1879</a>] - Supervisor may not shut down workers cleanly</li>
+<li>[<a href="">STORM-1881</a>] - storm-redis is missing dependant libraries in distribution</li>
+<li>[<a href="">STORM-1882</a>] - Expose TextFileReader public</li>
+<li>[<a href="">STORM-1884</a>] - In RedisKeyValueState.prepareCommit keys in pendingPrepare should have priority over pendingCommit</li>
+<li>[<a href="">STORM-1887</a>] - Help message for the set_log_level command does not have the topology name parameter</li>
+<li>[<a href="">STORM-1906</a>] - Window count/length of zero should be disallowed</li>
+<li>[<a href="">STORM-1907</a>] - PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException</li>
+<li>[<a href="">STORM-1911</a>] - Inconsistency of timestamp between IMetricsConsumer and IClusterMetricsConsumer</li>
+<li>[<a href="">STORM-1915</a>] - Supervisor keeps restarting forever</li>
+<li>[<a href="">STORM-1920</a>] - version of parent pom for storm-kafka-monitor is set 1.0.2-SNAPSHOT in master branch</li>
+<li>[<a href="">STORM-1924</a>] - Add a config file parameter to HDFS test topologies </li>
+<li>[<a href="">STORM-1925</a>] - Nimbus fails to start in secure mode </li>
+<li>[<a href="">STORM-1928</a>] - ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync</li>
+<li>[<a href="">STORM-1934</a>] - Race condition between sync-supervisor and sync-processes raises several strange issues</li>
+<li>[<a href="">STORM-1937</a>] - trident topologies WindowTridentProcessor cause NullPointerException when using windowing</li>
+<li>[<a href="">STORM-1939</a>] - Frequent InterruptedException raised by ShellBoltMessageQueue.poll</li>
+<li>[<a href="">STORM-1941</a>] - Nimbus discovery can fail when zookeeper reconnect happens.</li>
+<li>[<a href="">STORM-1942</a>] - Extra closing div tag in topology.html</li>
+<li>[<a href="">STORM-1945</a>] - Internal Server Error shown on topology page for topology using KafkaSpout</li>
+<li>[<a href="">STORM-1946</a>] - - On busy system BoltHeartbeatTimerTask fires before setHeartbeat() is executed</li>
+<li>[<a href="">STORM-1954</a>] - Large Trident topologies can cause memory issues due to DefaultResourceDeclarer object reading config</li>
+<li>[<a href="">STORM-1956</a>] - Disable Backpressure by default</li>
+<li>[<a href="">STORM-1959</a>] - does not have license</li>
+<li>[<a href="">STORM-1962</a>] - python storm integration does not run on python 3</li>
+<li>[<a href="">STORM-1964</a>] - Unexpected behavior when using count window together with timestamp extraction</li>
+<li>[<a href="">STORM-1976</a>] - Storm Nimbus H/A has issue on cleaning corrupted topologies</li>
+<li>[<a href="">STORM-1977</a>] - Leader Nimbus crashes with getClusterInfo when it doesn't have one or more replicated topology codes</li>
+<li>[<a href="">STORM-1985</a>] - Provide a tool for showing and killing corrupted topology</li>
+<li>[<a href="">STORM-1987</a>] - Fix TridentKafkaWordCount arg handling </li>
+<li>[<a href="">STORM-1988</a>] - Kafka Offset not showing due to bad classpath</li>
+<li>[<a href="">STORM-1995</a>] - downloadChunk in nimbus.clj should close the input stream</li>
+<li>[<a href="">STORM-1999</a>] - Update docs with OutputCollector's threadsafety</li>
+<li>[<a href="">STORM-2000</a>] - Add opentsdb libs to external dir in installation.</li>
+<li>[<a href="">STORM-2017</a>] - ShellBolt stops reporting task ids</li>
+<li>[<a href="">STORM-2020</a>] - Stop using sun internal classes</li>
+<li>[<a href="">STORM-2021</a>] - storm-kinesis missing licenses</li>
+<li>[<a href="">STORM-2022</a>] - FieldsTest.selectingUnknownFieldThrowsTest is failing</li>
+<li>[<a href="">STORM-2023</a>] - Add calcite-core to dependency of storm-sql-runtime</li>
+<li>[<a href="">STORM-2026</a>] - Inconsistency between (SpoutExecutor, BoltExecutor) and (spout-transfer-fn, bolt-transfer-fn)</li>
+<li>[<a href="">STORM-2028</a>] - Exceptions in JDBCClient are hidden by subsequent SQL-Exception in close()</li>
+<li>[<a href="">STORM-2032</a>] - "not fast enough" metrics WARN message in netty client can be misinterpreted</li>
+<li>[<a href="">STORM-2036</a>] - Fix minor bug in RAS Tests</li>
+<li>[<a href="">STORM-2037</a>] - debug operation should be whitelisted in SimpleAclAuthorizer</li>
+<li>[<a href="">STORM-2040</a>] - Config.TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE=true causes j.l.UnsupportedOperationException: nth not supported on this type: AddressedTuple</li>
+<li>[<a href="">STORM-2042</a>] - Nimbus client connections not closed properly causing connection leaks</li>
+<li>[<a href="">STORM-2045</a>] - NPE in SpoutExecutor in 2.0 branch</li>
+<li>[<a href="">STORM-2047</a>] - In secure setup the log page can't be viewed</li>
+<li>[<a href="">STORM-2052</a>] - Kafka Spout New Client API - Log Improvements and Parameter Tuning for Better Performance</li>
+<li>[<a href="">STORM-2054</a>] - DependencyResolver should be aware of relative path and absolute path</li>
+<li>[<a href="">STORM-2056</a>] - Bugs in logviewer</li>
+<li>[<a href="">STORM-2059</a>] - storm-submit-tools is getting rat failures.</li>
+<li>[<a href="">STORM-2064</a>] - Add storm name and function, access result and function to log-thrift-access</li>
+<li>[<a href="">STORM-2066</a>] - Fix scheduler status when in isolation and running with less slots than requested</li>
+<li>[<a href="">STORM-2067</a>] - "array element type mismatch" from compute-executors in nimbus.clj</li>
+<li>[<a href="">STORM-2070</a>] - Sigar native binary download link went 404</li>
+<li>[<a href="">STORM-2071</a>] - nimbus-test test-leadership failing with Exception</li>
+<li>[<a href="">STORM-2074</a>] - NPE bug in storm-kafka-monitor</li>
+<li>[<a href="">STORM-2079</a>] - Unneccessary readStormConfig operation</li>
+<li>[<a href="">STORM-2087</a>] - Storm-kafka-client: Failed tuples are not always replayed </li>
+<li>[<a href="">STORM-2088</a>] - Typos in documentation "Guaranteeing Message Processing"</li>
+<li>[<a href="">STORM-2093</a>] - Cannot download OOM heap dumps on MT storm systems through UI</li>
+<li>[<a href="">STORM-2095</a>] - Nimbus dies and never recovers due to java.nio.file.DirectoryNotEmptyException</li>
+<li>[<a href="">STORM-2098</a>] - DruidBeamBolt:  Pass DruidConfig.Builder as constructor argument</li>
+<li>[<a href="">STORM-2100</a>] - Few tests are getting failed in external/sql module with JDK 7 </li>
+<li>[<a href="">STORM-2101</a>] - NPE in compute-executors in nimbus</li>
+<li>[<a href="">STORM-2104</a>] - New Kafka spout crashes if partitions are reassigned while tuples are in-flight</li>
+<li>[<a href="">STORM-2109</a>] - Under supervisor V2 SUPERVISOR_MEMORY_CAPACITY_MB and SUPERVISOR_CPU_CAPACITY must be Doubles</li>
+<li>[<a href="">STORM-2110</a>] - in supervisor v2 filter out empty command line args</li>
+<li>[<a href="">STORM-2115</a>] - [Storm SQL] 'IN' with subquery making implicit aggregate calls which is having 'null' as name</li>
+<li>[<a href="">STORM-2117</a>] - Supervisor V2 with local mode extracts resources directory to topology root directory instead of temporary directory</li>
+<li>[<a href="">STORM-2118</a>] - A few fixes for storm-sql standalone mode</li>
+<li>[<a href="">STORM-2119</a>] - bug in log message printing to stdout</li>
+<li>[<a href="">STORM-2120</a>] - Emit to outputStreamId configured in SpoutConfig for KafkaSpout</li>
+<li>[<a href="">STORM-2126</a>] - Fix NPE due to race condition in nimbus.clj when attempting to get resources from SupervisorDetail</li>
+<li>[<a href="">STORM-2128</a>] - SimpleSqlTridentConsumer missing license headder</li>
+<li>[<a href="">STORM-2131</a>] - Add blob command to worker-launcher, make stormdist directory not writeable by topo owner</li>
+<li>[<a href="">STORM-2142</a>] - ReportErrorAndDie runs suicide function only when InterruptedException or InterruptedIOException is thrown</li>
+<li>[<a href="">STORM-2144</a>] - Fix Storm-sql group-by behavior in standalone mode</li>
+<li>[<a href="">STORM-2158</a>] - OutOfMemoryError in Nimbus' SimpleTransportPlugin</li>
+<li>[<a href="">STORM-2171</a>] - blob recovery on a single host results in deadlock</li>
+<li>[<a href="">STORM-2175</a>] - Supervisor V2 can possibly shut down workers twice in local mode</li>
+<li>[<a href="">STORM-2176</a>] - Workers do not shutdown cleanly and worker hooks don't run when a topology is killed</li>
+<li>[<a href="">STORM-2184</a>] - New Kafka spout will fail to commit offsets on shutdown if there are offsets to commit</li>
+<li>[<a href="">STORM-2185</a>] - Storm Supervisor doesn't delete directories properly sometimes</li>
+<li>[<a href="">STORM-2189</a>] - RAS_Node::freeCPU outputs incorrect info</li>
+<li>[<a href="">STORM-2190</a>] - Topology submission blocked behind scheduling</li>
+<li>[<a href="">STORM-2193</a>] - Storm UI/Logviewer passing in params in wrong order to FilterConfiguration</li>
+<li>[<a href="">STORM-2194</a>] - ReportErrorAndDie doesn't always die</li>
+<li>[<a href="">STORM-2195</a>] - Clean up some of worker-launcher code</li>
+<li>[<a href="">STORM-2196</a>] - A typo in RAS_Node::consumeCPU</li>
+<li>[<a href="">STORM-2197</a>] - NimbusClient connectins leak due to leakage in ThriftClient.</li>
+<li>[<a href="">STORM-2198</a>] - perform RotationAction when stopping HdfsBolt</li>
+<li>[<a href="">STORM-2205</a>] - Racecondition in getting nimbus summaries while ZK connections are reconnected.</li>
+<li>[<a href="">STORM-2208</a>] - HDFS State Throws FileNotFoundException in Azure Data Lake Store file system (adl://)</li>
+<li>[<a href="">STORM-2210</a>] - ShuffleGrouping does not produce even distribution</li>
+<li>[<a href="">STORM-2213</a>] - ShellSpout has race condition when ShellSpout is being inactive longer than heartbeat timeout  </li>
+<li>[<a href="">STORM-2226</a>] - New kafka spout offset lag tool does not work for secured kafka setup</li>
+<li>[<a href="">STORM-2228</a>] - KafkaSpout does not replay properly when a topic maps to multiple streams</li>
+<li>[<a href="">STORM-2231</a>] - NULL in DisruptorQueue while multi-threaded ack</li>
+<li>[<a href="">STORM-2234</a>] - heartBeatExecutorService in shellSpout don't work well with deactivate </li>
+<li>[<a href="">STORM-2239</a>] - New Kafka spout does not properly handle interrupts</li>
+<li>[<a href="">STORM-2240</a>] - STORM PMML Bolt - Add Support to Load Models from Blob Store</li>
+<li>[<a href="">STORM-2245</a>] - integration-test constant compilation failure</li>
+<li>[<a href="">STORM-2246</a>] - Logviewer download link has urlencoding on part of the URL</li>
+<li>[<a href="">STORM-2251</a>] - Integration test refers specific version of Storm which should be project version</li>
+<li>[<a href="">STORM-2257</a>] - Add built in support for sum function with different types in storm-sql standalone mode</li>
+<li>[<a href="">STORM-2264</a>] - OpaqueTridentKafkaSpout failing after STORM-2216</li>
+<li>[<a href="">STORM-2266</a>] - NimbusClient is not closed properly from some of the usages.</li>
+<li>[<a href="">STORM-2267</a>] - [storm-submit-tools] Use user's local maven repo. directory to local repo.</li>
+<li>[<a href="">STORM-2268</a>] - Fix integration test for Travis CI build</li>
+<li>[<a href="">STORM-2271</a>] - ClosedByInterruptException should be handled in few cases and removing a confusing debug statement</li>
+<li>[<a href="">STORM-2272</a>] - LocalCluster can leak simulated time</li>
+<li>[<a href="">STORM-2274</a>] - Support named output streams in Hdfs Spout</li>
+<li>[<a href="">STORM-2275</a>] - Nimbus crashed during state transition of topology</li>
+<li>[<a href="">STORM-2276</a>] - Remove twitter4j usages due to license issue ( is catalog X)</li>
+<li>[<a href="">STORM-2279</a>] - Unable to open bolt page of storm ui</li>
+<li>[<a href="">STORM-2281</a>] - Running Multiple Kafka Spouts (Trident) Throws Illegal State Exception</li>
+<li>[<a href="">STORM-2283</a>] - Fix DefaultStateHandler kryo multithreading issues</li>
+<li>[<a href="">STORM-2293</a>] - hostname should only refer node's 'storm.local.hostname'</li>
+<li>[<a href="">STORM-2295</a>] - KafkaSpoutStreamsNamedTopics changing the sequence of fields name while emitting data</li>
+<li>[<a href="">STORM-2303</a>] - [storm-opentsdb] Fix list invariant issue for JDK 7</li>
+<li>[<a href="">STORM-2305</a>] - STORM-2279 calculates task index different from grouper code</li>
+<li>[<a href="">STORM-2315</a>] - New kafka spout can't commit offset when ack is disabled. </li>
+<li>[<a href="">STORM-2320</a>] - DRPC client printer class reusable for local and remote DRPC</li>
+<li>[<a href="">STORM-2321</a>] - Nimbus did not come up after restart</li>
+<li>[<a href="">STORM-2323</a>] - Precondition for Leader Nimbus should check all topology blobs</li>
+<li>[<a href="">STORM-2324</a>] - Topology should not fail if topology jar is missing resources directory</li>

[... 456 lines stripped ...]

View raw message