<commit_before>## 2.0.0
 * STORM-2305: STORM-2279 calculates task index different from grouper code
 * STORM-1292: port backtype.storm.messaging-test to java
 * STORM-2271: ClosedByInterruptException should be handled in few cases and removing a confusing debug statement
 * STORM-2272: don't leak simulated time
 * STORM-2275: Nimbus crashed during state transition of topology
 * STORM-2243: adds ip address to supervisor id
 * STORM-2214: add in cacheing of the Kerberos Login
 * STORM-2203: Add a getAll method to KeyValueState interface
 * STORM-1239: port backtype.storm.scheduler.IsolationScheduler to java
 * STORM-2217: Finish porting drpc to java
 * STORM-1308: port backtype.storm.tick-tuple-test to java
 * STORM-2245: integration-test constant compilation failure
 * STORM-1607: Add MongoMapState for supporting trident's exactly once semantics
 * STORM-2104: More graceful handling of acked/failed tuples after partition reassignment
 * STORM-1281: LocalCluster, testing4j and testing.clj to java
 * STORM-2226: Fix kafka spout offset lag ui for kerberized kafka
 * STORM-1276: line for line translation of nimbus to java
 * STORM-2224: Exposed a method to override in computing the field from given tuple in FieldSelector
 * STORM-2220: Added config support for each bolt in Cassandra bolts, fixed the bolts to be used also as sinks.
 * STORM-1886: Extend KeyValueState iface with delete
 * STORM-2193: Fix FilterConfiguration parameter order
 * STORM-2209: Update documents adding new integration for some external systems
 * STORM-2212: Remove Redundant Declarations in Maven POM Files
 * STORM-2195: Clean up some of worker-launcher code
 * storm-2205: Racecondition in getting nimbus summaries while ZK connections are reconnected
 * STORM-1278: Port org.apache.storm.daemon.worker to java
 * STORM-2192: Add a new IAutoCredentials plugin to support SSL files
 * STORM-2197: NimbusClient connectins leak due to leakage in ThriftClient
 * STORM-2185: Storm Supervisor doesn't delete directories properly sometimes
 * STORM-2188: Interrupt all executor threads before joining in executor shutdown
 * STORM-203: Adding paths to default java library path
 * STORM-2175: fix double close of workers
 * STORM-1985: Provide a tool for showing and killing corrupted topology
 * STORM-2012: Upgrade Kafka to 0.8.2.2
 * STORM-2142: ReportErrorAndDie runs suicide function only when InterruptedException or InterruptedIOException is thrown
 * STORM-2134: improving the current scheduling strategy for RAS
 * STORM-2131: Add blob command to worker-launcher, make stormdist directory not writeable by topo owner
 * STORM-2144: Fix Storm-sql group-by behavior in standalone mode
 * STORM-1546: Adding Read and Write Aggregations for Pacemaker to make it HA compatible
 * STORM-2124: show requested cpu mem for each component
 * STORM-2109: Treat Supervisor CPU/MEMORY Configs as Numbers
 * STORM-2122: Cache dependency data, and serialize reading of the data
 * STORM-2117: Supervisor V2 with local mode extracts resources directory to the wrong directory
 * STORM-2110: strip out empty String in worker opts
 * STORM-2100: Fix Trident SQL join tests to not rely on ordering
 * STORM-2018: Supervisor V2
 * STORM-2098: DruidBeamBolt: Pass DruidConfig.Builder as constructor argument
 * STORM-2067: Fix "array element type mismatch" from compute-executors in nimbus.clj
 * STORM-2054: DependencyResolver should be aware of relative path and absolute path
 * STORM-2052: Kafka Spout New Client API - Log Improvements and Parameter Tuning for Better Performance
 * STORM-2045: fixed SpoutExecutor NPE
 * STORM-2041: Make Java 8 as minimum requirement for 2.0 release
 * STORM-1256: port backtype.storm.utils.ZookeeperServerCnxnFactory-test to java
 * STORM-1251: port backtype.storm.serialization.SerializationFactory-test to java
 * STORM-1240: port backtype.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer-test to java
 * STORM-1234: port backtype.storm.security.auth.DefaultHttpCredentialsPlugin-test to java
 * STORM-2037: debug operation should be whitelisted in SimpleAclAuthorizer.
 * STORM-2036: Fix minor bug in RAS Tests
 * STORM-2026: Inconsistency between (SpoutExecutor, BoltExecutor) and (spout-transfer-fn, bolt-transfer-fn)
 * STORM-1277: port backtype.storm.daemon.executor to java
 * STORM-2020: Stop using sun internal classes.
 * STORM-2021: Fix license.
 * STORM-2022: fix FieldsTest
 * STORM-1285: port backtype.storm.command.get-errors to java
 * STORM-2010: port org.apache.storm.command.heartbeats.clj to Java
 * STORM-2009: port org.apache.storm.blobstore.clj and org.apache.storm.command.blobstore.clj to Java
 * STORM-1876: Option to build storm-kafka and storm-kafka-client with different kafka client version
 * STORM-2000: Package storm-opentsdb as part of external dir in installation
 * STORM-1962: support python 3 and 2 in multilang
 * STORM-1964: Unexpected behavior when using count window together with timestamp extraction
 * STORM-1890: ensure we refetch static resources after package build
 * STORM-1966: Expand metric having Map type as value into multiple metrics based on entries
 * STORM-1737: storm-kafka-client has compilation errors with Apache Kafka 0.10
 * STORM-1910: One topology cannot use hdfs spout to read from two locations
 * STORM-1916: Add ability for worker-first classpath
 * STORM-1954: Large Trident topologies can cause memory issues due to DefaultResourceDeclarer object reading config
 * STORM-1913: Additions and Improvements for Trident RAS API
 * STORM-1959: Add missing license header to KafkaPartitionOffsetLag
 * STORM-1249: port backtype.storm.security.serialization.BlowfishTupleSerializer-test to java
 * STORM-1238: port backtype.storm.security.auth.ThriftServer-test to java
 * STORM-1237: port backtype.storm.security.auth.ThriftClient-test to java
 * STORM-1236: port backtype.storm.security.auth.SaslTransportPlugin-test to java
 * STORM-1235: port backtype.storm.security.auth.ReqContext-test to java
 * STORM-1229: port backtype.storm.metric.testing to java
 * STORM-1228: port backtype.storm.fields-test to java
 * STORM-1233: Port AuthUtilsTest to java
 * STORM-1920: version of parent pom for storm-kafka-monitor is set 1.0.2-SNAPSHOT in master branch
 * STORM-1896: Remove duplicate code from HDFS spout
 * STORM-1909: Update HDFS spout documentation
 * STORM-1705: Cap number of retries for a failed message
 * STORM-1884: Prioritize pendingPrepare over pendingCommit
 * STORM-1575: fix TwitterSampleSpout NPE on close
 * STORM-1874: Update logger private permissions
 * STORM-1865: update command line client document
 * STORM-1771. HiveState should flushAndClose before closing old or idle Hive connections
 * STORM-1882: Expose TextFileReader public
 * STORM-1873: Implement alternative behaviour for late tuples
 * STORM-1878: Flux can now handle IStatefulBolts
 * STORM-1864: StormSubmitter should throw respective exceptions and log respective errors forregistered submitter hook invocation
 * STORM-1766: A better algorithm server rack selection for RAS
 * STORM-1859: Ack late tuples in windowed mode
 * STORM-1851: Fix default nimbus impersonation authorizer config
 * STORM-1848: Make KafkaMessageId and Partition serializable to support event logging
 * STORM-1862: Flux ShellSpout and ShellBolt can't emit to named streams
 * Storm-1728: TransactionalTridentKafkaSpout error
 * STORM-1850: State Checkpointing Documentation update
 * STORM-1674: Idle KafkaSpout consumes more bandwidth than needed
 * STORM-1842: Forward references in storm.thrift cause tooling issues
 * STORM-1676: Filter null executor stats from worker heartbeat map
 * STORM-1672: Stats not get class cast exception
 * STORM-1739: update the minor JAVA version dependency in 0.10.0 and above
 * STORM-1733: Flush stdout before calling "os.execvp" to prevent log loss
 * STORM-1535: Make sure hdfs key tab login happens only once for multiple components
 * STORM-1544: Document Debug/Sampling of Topologies
 * STORM-1681: Bug in scheduling cyclic topologies when scheduling with RAS
 * STORM-1679: add storm Scheduler documents
 * STORM-1687: divide by zero in StatsUtil
 * STORM-1464: storm-hdfs support for multiple file outputs
 * STORM-515: Clojure documentation and examples
 * STORM-1279: port backtype.storm.daemon.supervisor to java
 * STORM-1668: Flux silently fails while setting a non-existent property.
 * STORM-1271: Port backtype.storm.daemon.task to java
 * STORM-822: Kafka Spout New Consumer API
 * STORM-1663: Stats couldn't handle null worker HB.
 * STORM-1665: Worker cannot instantiate kryo
 * STORM-1666: Kill from the UI fails silently
 * STORM-1610: port pacemaker_state_factory_test.clj to java
 * STORM-1611: port org.apache.storm.pacemaker.pacemaker to java
 * STORM-1268: port builtin-metrics to java
 * STORM-1648: drpc spout reconnect on failure
 * STORM-1631: Storm CGroup bugs
 * STORM-1616: Add RAS API for Trident
 * STORM-1623: nimbus.clj's minor bug
 * STORM-1624: Add maven central status in README
 * STORM-1232: port backtype.storm.scheduler.DefaultScheduler to java
 * STORM-1231: port backtype.storm.scheduler.EvenScheduler to java
 * STORM-1523: util.clj available-port conversion to java
 * STORM-1252: port backtype.storm.stats to java
 * STORM-1250: port backtype.storm.serialization-test to java
 * STORM-1605: use '/usr/bin/env python' to check python version
 * STORM-1618: Add the option of passing config directory
 * STORM-1269: port backtype.storm.daemon.common to java
 * STORM-1270: port drpc to java
 * STORM-1274: port LocalDRPC to java
 * STORM-1590: port defmeters/defgauge/defhistogram... to java for all of our code to use
 * STORM-1529: Change default worker temp directory location for workers
 * STORM-1543: DRPCSpout should always try to reconnect disconnected DRPCInvocationsClient
 * STORM-1528: Fix CsvPreparableReporter log directory
 * STORM-1561: Supervisor should relaunch worker if assignments have changed
 * STORM-1283: port backtype.storm.MockAutoCred to java
 * STORM-1592: clojure code calling into Utils.exitProcess throws ClassCastException
 * STORM-1579: Fix NoSuchFileException when running tests in storm-core
 * STORM-1244: port backtype.storm.command.upload-credentials to java
 * STORM-1245: port backtype.storm.daemon.acker to java
 * STORM-1545: Topology Debug Event Log in Wrong Location
 * STORM-1254: port ui.helper to java
 * STORM-1571: Improvment Kafka Spout Time Metric
 * STORM-1569: Allowing users to specify the nimbus thrift server queue size.
 * STORM-1564: fix wrong package-info in org.apache.storm.utils.staticmocking
 * STORM-1267: Port set_log_level
 * STORM-1266: Port rebalance
 * STORM-1265: Port monitor
 * STORM-1572: throw NPE when parsing the command line arguments by CLI
 * STORM-1273: port backtype.storm.cluster to java
 * STORM-1479: use a simple implemention for IntSerializer
 * STORM-1255: port storm_utils.clj to java and split Time tests into its
 * STORM-1566: Worker exits with error o.a.s.d.worker [ERROR] Error on initialization of server mk-worker
 * STORM-1558: Utils in java breaks component page due to illegal type cast
 * STORM-1553: port event.clj to java
 * STORM-1262: port backtype.storm.command.dev-zookeeper to java.
 * STORM-1243: port backtype.storm.command.healthcheck to java.
 * STORM-1246: port backtype.storm.local-state to java.
 * STORM-1516: Fixed issue in writing pids with distributed cluster mode.
 * STORM-1253: port backtype.storm.timer to java
 * STORM-1258: port thrift.clj to Thrift.java
 * STORM-1336: Evalute/Port JStorm cgroup support and implement cgroup support for RAS
 * STORM-1511: min/max operators implementation in Trident streams API.
 * STROM-1263: port backtype.storm.command.kill-topology to java
 * STORM-1260: port backtype.storm.command.activate to java
 * STORM-1261: port backtype.storm.command.deactivate to java
 * STORM-1264: port backtype.storm.command.list to java
 * STORM-1272: port backtype.storm.disruptor to java
 * STORM-1248: port backtype.storm.messaging.loader to java
 * STORM-1538: Exception being thrown after Utils conversion to java
 * STORM-1242: migrate backtype.storm.command.config-value to java
 * STORM-1226: Port backtype.storm.util to java
 * STORM-1436: Random test failure on BlobStoreTest / HdfsBlobStoreImplTest (occasionally killed)
 * STORM-1476: Filter -c options from args and add them as part of storm.options
 * STORM-1257: port backtype.storm.zookeeper to java
 * STORM-1504: Add Serializer and instruction for AvroGenericRecordBolt
 * STORM-1524: Add Pluggable daemon metrics Reporters
 * STORM-1521: When using Kerberos login from keytab with multiple bolts/executors ticket is not renewed in hbase bolt.
 * STORM-1769: Added a test to check local nimbus with notifier plugin

## 1.1.0
 * STORM-2298: Don't kill Nimbus when ClusterMetricsConsumer is failed to initialize
 * STORM-2301: [storm-cassandra] upgrade cassandra driver to 3.1.2
 * STORM-1446: Compile the Calcite logical plan to Storm Trident logical plan
 * STORM-2303: [storm-opentsdb] Fix list invariant issue for JDK 7
 * STORM-2295: KafkaSpoutStreamsNamedTopics should return output fields with predictable ordering
 * STORM-2300: [Flux] support list of references
 * STORM-2297: [storm-opentsdb] Support Flux for OpenTSDBBolt
 * STORM-2294: Send activate and deactivate command to ShellSpout
 * STORM-2236: Kafka Spout with manual partition management.
 * STORM-2280: Upgrade Calcite version to 1.11.0
 * STORM-2278: Allow max number of disruptor queue flusher threads to be configurable
 * STORM-2277: Add shaded jar for Druid connector
 * STORM-2274: Support named output streams in Hdfs Spout
 * STORM-2204: Adding caching capabilities in HBaseLookupBolt
 * STORM-2267: Use user's local maven repo. directory to local repo.
 * STORM-2254: Provide Socket time out for nimbus thrift client
 * STORM-2200: [Storm SQL] Drop Aggregate & Join support on Trident mode
 * STORM-2244: Some shaded jars doesn't exclude dependency signature files
 * STORM-2266: Close NimbusClient instances appropriately
 * STORM-2257: Add built in support for sum function with different types
 * STORM-2082: add sql external module storm-sql-hdfs
 * STORM-2190: reduce contention between submission and scheduling
 * STORM-2239: Handle InterruptException in new Kafka spout
 * STORM-2238: Add Timestamp extractor for windowed bolt
 * STORM-2235: Introduce new option: 'add remote repositories' for dependency resolver
 * STORM-2215: validate blobs are present before submitting
 * STORM-2170: [Storm SQL] Add built-in socket datasource to runtime
 * STORM-2087: storm-kafka-client - tuples not always being replayed.
 * STORM-2182: Refactor Storm Kafka Examples Into Own Modules.
 * STORM-1694: Kafka Spout Trident Implementation Using New Kafka Consumer API.
 * STORM-2173: [SQL] Support CSV as input / output format
 * STORM-2177: [SQL] Support TSV as input / output format
 * STORM-2172: [SQL] Support Avro as input / output format
 * STORM-2103: [SQL] Introduce new sql external module: storm-sql-mongodb
 * STORM-2109: Under supervisor V2 SUPERVISOR_MEMORY_CAPACITY_MB and SUPERVISOR_CPU_CAPACITY must be Doubles
 * STORM-2110: in supervisor v2 filter out empty command line args
 * STORM-2117: Supervisor V2 with local mode extracts resources directory to topology root directory instead of temporary directory
 * STORM-2131: Add blob command to worker-launcher, make stormdist directory not writeable by topo owner
 * STORM-2018: Supervisor V2
 * STORM-2139: Let ShellBolts and ShellSpouts run with scripts from blobs
 * STORM-2072: Add map, flatMap with different outputs (T->V) in Trident
 * STORM-2125: Use Calcite's implementation of Rex Compiler
 * STORM-1444: Support EXPLAIN statement in StormSQL
 * STORM-2099: Introduce new sql external module: storm-sql-redis
 * STORM-2097: Improve logging in trident core and examples
 * STORM-2066: make error message in IsolatedPool.java more descriptive
 * STORM-1870: Allow FluxShellBolt/Spout set custom "componentConfig" via yaml
 * STORM-2126: fix NPE due to race condition in compute-new-sched-assign…
 * STORM-2089: Replace Consumer of ISqlTridentDataSource with SqlTridentConsumer
 * STORM-2118: A few fixes for storm-sql standalone mode
 * STORM-2105: Cluster/Supervisor total and available resources displayed in the UI
 * STORM-2078: enable paging in worker datatable
 * STORM-1664: Allow Java users to start a local cluster with a Nimbus Thrift server.
 * STORM-1872: Release Jedis connection when topology shutdown
 * STORM-1837: Fix complete-topology and prevent message loss
 * STORM-2092: optimize TridentKafkaState batch sending
 * STORM-1979: Storm Druid Connector implementation.
 * STORM-2057: Support JOIN statement in Storm SQL
 * STORM-1970: external project examples refator
 * STORM-2074: fix storm-kafka-monitor NPE bug
 * STORM-1459: Allow not specifying producer properties in read-only Kafka table in StormSQL
 * STORM-2050: [storm-sql] Support User Defined Aggregate Function for Trident mode
 * STORM-1434: Support the GROUP BY clause in StormSQL
 * STORM-2016: Topology submission improvement: support adding local jars and maven artifacts on submission
 * STORM-1994: Add table with per-topology & worker resource usage and components in (new) supervisor and topology pages
 * STORM-2023: Add calcite-core to dependency of storm-sql-runtime
 * STORM-1839: Storm spout implementation for Amazon Kinesis Streams.
 * STORM-1988: Kafka Offset not showing due to bad classpath.
 * STORM-1950: Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition.
 * STORM-1833: Simple equi-join in storm-sql standalone mode
 * STORM-1866: Update Resource Aware Scheduler Documentation
 * STORM-1930: Kafka New Client API - Support for Topic Wildcards
 * STORM-1924: Adding conf options for Persistent Word Count Topology
 * STORM-1956: Disabling Backpressure by default 
 * STORM-1934: Fix race condition between sync-supervisor and sync-processes
 * STORM-1919: Introduce FilterBolt on storm-redis
 * STORM-1945: Fix NPE bugs on topology spout lag for storm-kafka-monitor
 * STORM-1719: Introduce REST API: Topology metric stats for stream
 * STORM-1941: Nimbus discovery can fail when zookeeper reconnect happens
 * STORM-1888: add description for shell command
 * STORM-1902: add a simple & flexible FileNameFormat for storm-hdfs
 * STORM-1914: Storm Kafka Field Topic Selector
 * STORM-1925: Remove Nimbus thrift call from Nimbus itself
 * STORM-1907: PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException
 * STORM-1136: Command line module to return kafka spout offsets lag and display in storm ui.
 * STORM-1911: IClusterMetricsConsumer should use seconds to timestamp unit
 * STORM-1893: Support OpenTSDB for storing timeseries data.
 * STORM-1723: Introduce ClusterMetricsConsumer
 * STORM-1700: Introduce 'whitelist' / 'blacklist' option to MetricsConsumer
 * STORM-1698: Asynchronous MetricsConsumerBolt
 * STORM-1887: Fixed help message for set_log_level command
 * STORM-1709: Added group by support in storm sql standalone mode
 * STORM-1720: Support GEO in storm-redis
 * STORM-1868: Modify TridentKafkaWordCount to run in distributed mode

## 1.0.3
 * STORM-1742: More accurate 'complete latency'
 * STORM-2176: Workers do not shutdown cleanly and worker hooks don't run when a topology is killed
 * STORM-2293: hostname should only refer node's 'storm.local.hostname'
 * STORM-2246: Logviewer download link has urlencoding on part of the URL
 * STORM-1906: Window count/length of zero should be disallowed
 * STORM-1841: Address a few minor issues in windowing and doc
 * STORM-2268: Fix integration test for Travis CI build
 * STORM-2283: Fix DefaultStateHandler kryo multithreading issues
 * STORM-2279: Unable to open bolt page of storm ui
 * STORM-2264: OpaqueTridentKafkaSpout failing after STORM-2216<commit_msg>STORM-2325: CHANGELOG<commit_after>## 2.0.0
 * STORM-2305: STORM-2279 calculates task index different from grouper code
 * STORM-1292: port backtype.storm.messaging-test to java
 * STORM-2271: ClosedByInterruptException should be handled in few cases and removing a confusing debug statement
 * STORM-2272: don't leak simulated time
 * STORM-2275: Nimbus crashed during state transition of topology
 * STORM-2243: adds ip address to supervisor id
 * STORM-2214: add in cacheing of the Kerberos Login
 * STORM-2203: Add a getAll method to KeyValueState interface
 * STORM-1239: port backtype.storm.scheduler.IsolationScheduler to java
 * STORM-2217: Finish porting drpc to java
 * STORM-1308: port backtype.storm.tick-tuple-test to java
 * STORM-2245: integration-test constant compilation failure
 * STORM-1607: Add MongoMapState for supporting trident's exactly once semantics
 * STORM-2104: More graceful handling of acked/failed tuples after partition reassignment
 * STORM-1281: LocalCluster, testing4j and testing.clj to java
 * STORM-2226: Fix kafka spout offset lag ui for kerberized kafka
 * STORM-1276: line for line translation of nimbus to java
 * STORM-2224: Exposed a method to override in computing the field from given tuple in FieldSelector
 * STORM-2220: Added config support for each bolt in Cassandra bolts, fixed the bolts to be used also as sinks.
 * STORM-1886: Extend KeyValueState iface with delete
 * STORM-2193: Fix FilterConfiguration parameter order
 * STORM-2209: Update documents adding new integration for some external systems
 * STORM-2212: Remove Redundant Declarations in Maven POM Files
 * STORM-2195: Clean up some of worker-launcher code
 * storm-2205: Racecondition in getting nimbus summaries while ZK connections are reconnected
 * STORM-1278: Port org.apache.storm.daemon.worker to java
 * STORM-2192: Add a new IAutoCredentials plugin to support SSL files
 * STORM-2197: NimbusClient connectins leak due to leakage in ThriftClient
 * STORM-2185: Storm Supervisor doesn't delete directories properly sometimes
 * STORM-2188: Interrupt all executor threads before joining in executor shutdown
 * STORM-203: Adding paths to default java library path
 * STORM-2175: fix double close of workers
 * STORM-1985: Provide a tool for showing and killing corrupted topology
 * STORM-2012: Upgrade Kafka to 0.8.2.2
 * STORM-2142: ReportErrorAndDie runs suicide function only when InterruptedException or InterruptedIOException is thrown
 * STORM-2134: improving the current scheduling strategy for RAS
 * STORM-2131: Add blob command to worker-launcher, make stormdist directory not writeable by topo owner
 * STORM-2144: Fix Storm-sql group-by behavior in standalone mode
 * STORM-1546: Adding Read and Write Aggregations for Pacemaker to make it HA compatible
 * STORM-2124: show requested cpu mem for each component
 * STORM-2109: Treat Supervisor CPU/MEMORY Configs as Numbers
 * STORM-2122: Cache dependency data, and serialize reading of the data
 * STORM-2117: Supervisor V2 with local mode extracts resources directory to the wrong directory
 * STORM-2110: strip out empty String in worker opts
 * STORM-2100: Fix Trident SQL join tests to not rely on ordering
 * STORM-2018: Supervisor V2
 * STORM-2098: DruidBeamBolt: Pass DruidConfig.Builder as constructor argument
 * STORM-2067: Fix "array element type mismatch" from compute-executors in nimbus.clj
 * STORM-2054: DependencyResolver should be aware of relative path and absolute path
 * STORM-2052: Kafka Spout New Client API - Log Improvements and Parameter Tuning for Better Performance
 * STORM-2045: fixed SpoutExecutor NPE
 * STORM-2041: Make Java 8 as minimum requirement for 2.0 release
 * STORM-1256: port backtype.storm.utils.ZookeeperServerCnxnFactory-test to java
 * STORM-1251: port backtype.storm.serialization.SerializationFactory-test to java
 * STORM-1240: port backtype.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer-test to java
 * STORM-1234: port backtype.storm.security.auth.DefaultHttpCredentialsPlugin-test to java
 * STORM-2037: debug operation should be whitelisted in SimpleAclAuthorizer.
 * STORM-2036: Fix minor bug in RAS Tests
 * STORM-2026: Inconsistency between (SpoutExecutor, BoltExecutor) and (spout-transfer-fn, bolt-transfer-fn)
 * STORM-1277: port backtype.storm.daemon.executor to java
 * STORM-2020: Stop using sun internal classes.
 * STORM-2021: Fix license.
 * STORM-2022: fix FieldsTest
 * STORM-1285: port backtype.storm.command.get-errors to java
 * STORM-2010: port org.apache.storm.command.heartbeats.clj to Java
 * STORM-2009: port org.apache.storm.blobstore.clj and org.apache.storm.command.blobstore.clj to Java
 * STORM-1876: Option to build storm-kafka and storm-kafka-client with different kafka client version
 * STORM-2000: Package storm-opentsdb as part of external dir in installation
 * STORM-1962: support python 3 and 2 in multilang
 * STORM-1964: Unexpected behavior when using count window together with timestamp extraction
 * STORM-1890: ensure we refetch static resources after package build
 * STORM-1966: Expand metric having Map type as value into multiple metrics based on entries
 * STORM-1737: storm-kafka-client has compilation errors with Apache Kafka 0.10
 * STORM-1910: One topology cannot use hdfs spout to read from two locations
 * STORM-1916: Add ability for worker-first classpath
 * STORM-1954: Large Trident topologies can cause memory issues due to DefaultResourceDeclarer object reading config
 * STORM-1913: Additions and Improvements for Trident RAS API
 * STORM-1959: Add missing license header to KafkaPartitionOffsetLag
 * STORM-1249: port backtype.storm.security.serialization.BlowfishTupleSerializer-test to java
 * STORM-1238: port backtype.storm.security.auth.ThriftServer-test to java
 * STORM-1237: port backtype.storm.security.auth.ThriftClient-test to java
 * STORM-1236: port backtype.storm.security.auth.SaslTransportPlugin-test to java
 * STORM-1235: port backtype.storm.security.auth.ReqContext-test to java
 * STORM-1229: port backtype.storm.metric.testing to java
 * STORM-1228: port backtype.storm.fields-test to java
 * STORM-1233: Port AuthUtilsTest to java
 * STORM-1920: version of parent pom for storm-kafka-monitor is set 1.0.2-SNAPSHOT in master branch
 * STORM-1896: Remove duplicate code from HDFS spout
 * STORM-1909: Update HDFS spout documentation
 * STORM-1705: Cap number of retries for a failed message
 * STORM-1884: Prioritize pendingPrepare over pendingCommit
 * STORM-1575: fix TwitterSampleSpout NPE on close
 * STORM-1874: Update logger private permissions
 * STORM-1865: update command line client document
 * STORM-1771. HiveState should flushAndClose before closing old or idle Hive connections
 * STORM-1882: Expose TextFileReader public
 * STORM-1873: Implement alternative behaviour for late tuples
 * STORM-1878: Flux can now handle IStatefulBolts
 * STORM-1864: StormSubmitter should throw respective exceptions and log respective errors forregistered submitter hook invocation
 * STORM-1766: A better algorithm server rack selection for RAS
 * STORM-1859: Ack late tuples in windowed mode
 * STORM-1851: Fix default nimbus impersonation authorizer config
 * STORM-1848: Make KafkaMessageId and Partition serializable to support event logging
 * STORM-1862: Flux ShellSpout and ShellBolt can't emit to named streams
 * Storm-1728: TransactionalTridentKafkaSpout error
 * STORM-1850: State Checkpointing Documentation update
 * STORM-1674: Idle KafkaSpout consumes more bandwidth than needed
 * STORM-1842: Forward references in storm.thrift cause tooling issues
 * STORM-1676: Filter null executor stats from worker heartbeat map
 * STORM-1672: Stats not get class cast exception
 * STORM-1739: update the minor JAVA version dependency in 0.10.0 and above
 * STORM-1733: Flush stdout before calling "os.execvp" to prevent log loss
 * STORM-1535: Make sure hdfs key tab login happens only once for multiple components
 * STORM-1544: Document Debug/Sampling of Topologies
 * STORM-1681: Bug in scheduling cyclic topologies when scheduling with RAS
 * STORM-1679: add storm Scheduler documents
 * STORM-1687: divide by zero in StatsUtil
 * STORM-1464: storm-hdfs support for multiple file outputs
 * STORM-515: Clojure documentation and examples
 * STORM-1279: port backtype.storm.daemon.supervisor to java
 * STORM-1668: Flux silently fails while setting a non-existent property.
 * STORM-1271: Port backtype.storm.daemon.task to java
 * STORM-822: Kafka Spout New Consumer API
 * STORM-1663: Stats couldn't handle null worker HB.
 * STORM-1665: Worker cannot instantiate kryo
 * STORM-1666: Kill from the UI fails silently
 * STORM-1610: port pacemaker_state_factory_test.clj to java
 * STORM-1611: port org.apache.storm.pacemaker.pacemaker to java
 * STORM-1268: port builtin-metrics to java
 * STORM-1648: drpc spout reconnect on failure
 * STORM-1631: Storm CGroup bugs
 * STORM-1616: Add RAS API for Trident
 * STORM-1623: nimbus.clj's minor bug
 * STORM-1624: Add maven central status in README
 * STORM-1232: port backtype.storm.scheduler.DefaultScheduler to java
 * STORM-1231: port backtype.storm.scheduler.EvenScheduler to java
 * STORM-1523: util.clj available-port conversion to java
 * STORM-1252: port backtype.storm.stats to java
 * STORM-1250: port backtype.storm.serialization-test to java
 * STORM-1605: use '/usr/bin/env python' to check python version
 * STORM-1618: Add the option of passing config directory
 * STORM-1269: port backtype.storm.daemon.common to java
 * STORM-1270: port drpc to java
 * STORM-1274: port LocalDRPC to java
 * STORM-1590: port defmeters/defgauge/defhistogram... to java for all of our code to use
 * STORM-1529: Change default worker temp directory location for workers
 * STORM-1543: DRPCSpout should always try to reconnect disconnected DRPCInvocationsClient
 * STORM-1528: Fix CsvPreparableReporter log directory
 * STORM-1561: Supervisor should relaunch worker if assignments have changed
 * STORM-1283: port backtype.storm.MockAutoCred to java
 * STORM-1592: clojure code calling into Utils.exitProcess throws ClassCastException
 * STORM-1579: Fix NoSuchFileException when running tests in storm-core
 * STORM-1244: port backtype.storm.command.upload-credentials to java
 * STORM-1245: port backtype.storm.daemon.acker to java
 * STORM-1545: Topology Debug Event Log in Wrong Location
 * STORM-1254: port ui.helper to java
 * STORM-1571: Improvment Kafka Spout Time Metric
 * STORM-1569: Allowing users to specify the nimbus thrift server queue size.
 * STORM-1564: fix wrong package-info in org.apache.storm.utils.staticmocking
 * STORM-1267: Port set_log_level
 * STORM-1266: Port rebalance
 * STORM-1265: Port monitor
 * STORM-1572: throw NPE when parsing the command line arguments by CLI
 * STORM-1273: port backtype.storm.cluster to java
 * STORM-1479: use a simple implemention for IntSerializer
 * STORM-1255: port storm_utils.clj to java and split Time tests into its
 * STORM-1566: Worker exits with error o.a.s.d.worker [ERROR] Error on initialization of server mk-worker
 * STORM-1558: Utils in java breaks component page due to illegal type cast
 * STORM-1553: port event.clj to java
 * STORM-1262: port backtype.storm.command.dev-zookeeper to java.
 * STORM-1243: port backtype.storm.command.healthcheck to java.
 * STORM-1246: port backtype.storm.local-state to java.
 * STORM-1516: Fixed issue in writing pids with distributed cluster mode.
 * STORM-1253: port backtype.storm.timer to java
 * STORM-1258: port thrift.clj to Thrift.java
 * STORM-1336: Evalute/Port JStorm cgroup support and implement cgroup support for RAS
 * STORM-1511: min/max operators implementation in Trident streams API.
 * STROM-1263: port backtype.storm.command.kill-topology to java
 * STORM-1260: port backtype.storm.command.activate to java
 * STORM-1261: port backtype.storm.command.deactivate to java
 * STORM-1264: port backtype.storm.command.list to java
 * STORM-1272: port backtype.storm.disruptor to java
 * STORM-1248: port backtype.storm.messaging.loader to java
 * STORM-1538: Exception being thrown after Utils conversion to java
 * STORM-1242: migrate backtype.storm.command.config-value to java
 * STORM-1226: Port backtype.storm.util to java
 * STORM-1436: Random test failure on BlobStoreTest / HdfsBlobStoreImplTest (occasionally killed)
 * STORM-1476: Filter -c options from args and add them as part of storm.options
 * STORM-1257: port backtype.storm.zookeeper to java
 * STORM-1504: Add Serializer and instruction for AvroGenericRecordBolt
 * STORM-1524: Add Pluggable daemon metrics Reporters
 * STORM-1521: When using Kerberos login from keytab with multiple bolts/executors ticket is not renewed in hbase bolt.
 * STORM-1769: Added a test to check local nimbus with notifier plugin

## 1.1.0
 * STORM-2298: Don't kill Nimbus when ClusterMetricsConsumer is failed to initialize
 * STORM-2301: [storm-cassandra] upgrade cassandra driver to 3.1.2
 * STORM-1446: Compile the Calcite logical plan to Storm Trident logical plan
 * STORM-2303: [storm-opentsdb] Fix list invariant issue for JDK 7
 * STORM-2295: KafkaSpoutStreamsNamedTopics should return output fields with predictable ordering
 * STORM-2300: [Flux] support list of references
 * STORM-2297: [storm-opentsdb] Support Flux for OpenTSDBBolt
 * STORM-2294: Send activate and deactivate command to ShellSpout
 * STORM-2236: Kafka Spout with manual partition management.
 * STORM-2280: Upgrade Calcite version to 1.11.0
 * STORM-2278: Allow max number of disruptor queue flusher threads to be configurable
 * STORM-2277: Add shaded jar for Druid connector
 * STORM-2274: Support named output streams in Hdfs Spout
 * STORM-2204: Adding caching capabilities in HBaseLookupBolt
 * STORM-2267: Use user's local maven repo. directory to local repo.
 * STORM-2254: Provide Socket time out for nimbus thrift client
 * STORM-2200: [Storm SQL] Drop Aggregate & Join support on Trident mode
 * STORM-2244: Some shaded jars doesn't exclude dependency signature files
 * STORM-2266: Close NimbusClient instances appropriately
 * STORM-2257: Add built in support for sum function with different types
 * STORM-2082: add sql external module storm-sql-hdfs
 * STORM-2190: reduce contention between submission and scheduling
 * STORM-2239: Handle InterruptException in new Kafka spout
 * STORM-2238: Add Timestamp extractor for windowed bolt
 * STORM-2235: Introduce new option: 'add remote repositories' for dependency resolver
 * STORM-2215: validate blobs are present before submitting
 * STORM-2170: [Storm SQL] Add built-in socket datasource to runtime
 * STORM-2087: storm-kafka-client - tuples not always being replayed.
 * STORM-2182: Refactor Storm Kafka Examples Into Own Modules.
 * STORM-1694: Kafka Spout Trident Implementation Using New Kafka Consumer API.
 * STORM-2173: [SQL] Support CSV as input / output format
 * STORM-2177: [SQL] Support TSV as input / output format
 * STORM-2172: [SQL] Support Avro as input / output format
 * STORM-2103: [SQL] Introduce new sql external module: storm-sql-mongodb
 * STORM-2109: Under supervisor V2 SUPERVISOR_MEMORY_CAPACITY_MB and SUPERVISOR_CPU_CAPACITY must be Doubles
 * STORM-2110: in supervisor v2 filter out empty command line args
 * STORM-2117: Supervisor V2 with local mode extracts resources directory to topology root directory instead of temporary directory
 * STORM-2131: Add blob command to worker-launcher, make stormdist directory not writeable by topo owner
 * STORM-2018: Supervisor V2
 * STORM-2139: Let ShellBolts and ShellSpouts run with scripts from blobs
 * STORM-2072: Add map, flatMap with different outputs (T->V) in Trident
 * STORM-2125: Use Calcite's implementation of Rex Compiler
 * STORM-1444: Support EXPLAIN statement in StormSQL
 * STORM-2099: Introduce new sql external module: storm-sql-redis
 * STORM-2097: Improve logging in trident core and examples
 * STORM-2066: make error message in IsolatedPool.java more descriptive
 * STORM-1870: Allow FluxShellBolt/Spout set custom "componentConfig" via yaml
 * STORM-2126: fix NPE due to race condition in compute-new-sched-assign…
 * STORM-2089: Replace Consumer of ISqlTridentDataSource with SqlTridentConsumer
 * STORM-2118: A few fixes for storm-sql standalone mode
 * STORM-2105: Cluster/Supervisor total and available resources displayed in the UI
 * STORM-2078: enable paging in worker datatable
 * STORM-1664: Allow Java users to start a local cluster with a Nimbus Thrift server.
 * STORM-1872: Release Jedis connection when topology shutdown
 * STORM-1837: Fix complete-topology and prevent message loss
 * STORM-2092: optimize TridentKafkaState batch sending
 * STORM-1979: Storm Druid Connector implementation.
 * STORM-2057: Support JOIN statement in Storm SQL
 * STORM-1970: external project examples refator
 * STORM-2074: fix storm-kafka-monitor NPE bug
 * STORM-1459: Allow not specifying producer properties in read-only Kafka table in StormSQL
 * STORM-2050: [storm-sql] Support User Defined Aggregate Function for Trident mode
 * STORM-1434: Support the GROUP BY clause in StormSQL
 * STORM-2016: Topology submission improvement: support adding local jars and maven artifacts on submission
 * STORM-1994: Add table with per-topology & worker resource usage and components in (new) supervisor and topology pages
 * STORM-2023: Add calcite-core to dependency of storm-sql-runtime
 * STORM-1839: Storm spout implementation for Amazon Kinesis Streams.
 * STORM-1988: Kafka Offset not showing due to bad classpath.
 * STORM-1950: Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition.
 * STORM-1833: Simple equi-join in storm-sql standalone mode
 * STORM-1866: Update Resource Aware Scheduler Documentation
 * STORM-1930: Kafka New Client API - Support for Topic Wildcards
 * STORM-1924: Adding conf options for Persistent Word Count Topology
 * STORM-1956: Disabling Backpressure by default 
 * STORM-1934: Fix race condition between sync-supervisor and sync-processes
 * STORM-1919: Introduce FilterBolt on storm-redis
 * STORM-1945: Fix NPE bugs on topology spout lag for storm-kafka-monitor
 * STORM-1719: Introduce REST API: Topology metric stats for stream
 * STORM-1941: Nimbus discovery can fail when zookeeper reconnect happens
 * STORM-1888: add description for shell command
 * STORM-1902: add a simple & flexible FileNameFormat for storm-hdfs
 * STORM-1914: Storm Kafka Field Topic Selector
 * STORM-1925: Remove Nimbus thrift call from Nimbus itself
 * STORM-1907: PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException
 * STORM-1136: Command line module to return kafka spout offsets lag and display in storm ui.
 * STORM-1911: IClusterMetricsConsumer should use seconds to timestamp unit
 * STORM-1893: Support OpenTSDB for storing timeseries data.
 * STORM-1723: Introduce ClusterMetricsConsumer
 * STORM-1700: Introduce 'whitelist' / 'blacklist' option to MetricsConsumer
 * STORM-1698: Asynchronous MetricsConsumerBolt
 * STORM-1887: Fixed help message for set_log_level command
 * STORM-1709: Added group by support in storm sql standalone mode
 * STORM-1720: Support GEO in storm-redis
 * STORM-1868: Modify TridentKafkaWordCount to run in distributed mode

## 1.0.3
 * STORM-2325: Logviewer doesn't consider 'storm.local.hostname'
 * STORM-1742: More accurate 'complete latency'
 * STORM-2176: Workers do not shutdown cleanly and worker hooks don't run when a topology is killed
 * STORM-2293: hostname should only refer node's 'storm.local.hostname'
 * STORM-2246: Logviewer download link has urlencoding on part of the URL
 * STORM-1906: Window count/length of zero should be disallowed
 * STORM-1841: Address a few minor issues in windowing and doc
 * STORM-2268: Fix integration test for Travis CI build
 * STORM-2283: Fix DefaultStateHandler kryo multithreading issues
 * STORM-2279: Unable to open bolt page of storm ui
 * STORM-2264: OpaqueTridentKafkaSpout failing after STORM-2216
{'fraction_non_alphanumeric': 0.06579904210235964, 'fraction_numerical': 0.06218811906015698, 'mean_word_length': 4.638342994486074, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 2, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 2, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6832204', 'n_tokens_mistral': 13330, 'n_tokens_neox': 11705, 'n_words': 4615}