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