Download

Apache Storm 2.1.0 Released

The Apache Storm community is pleased to announce that version 2.1.0 has been released and is available from the downloads page.

This release includes a number of code improvements and important bug fixes that improve Apache Storm's performance, stability and fault tolerance. We encourage users of previous versions to upgrade to this latest release.

Thanks

Special thanks are due to all those who have contributed to Apache Storm -- whether through direct code contributions, documentation, bug reports, or helping other users on the mailing lists. Your efforts are much appreciated.

Changes in this Release

Improvement

  • [STORM-2720] - Add timestamp based FirstPollOffsetStrategy in KafkaTridentSpoutOpaque
  • [STORM-3370] - Make StormMetricRegistry non-static
  • [STORM-3392] - Topology page should show components even if workers haven't started
  • [STORM-3394] - Fix placeholder system bolt filtering for Topology page
  • [STORM-3395] - Modifiy Topology page placeholder components to show task counts
  • [STORM-3396] - uploading dependency jars too slow when StormSubmitter and Nimbus located in different IDC
  • [STORM-3402] - Scan code quality at build time
  • [STORM-3409] - Wipe Storm artifacts from local Maven repo before building, and fix build order for storm-shaded-deps
  • [STORM-3411] - Worker Log Download Only Create Generic Name Worker.log
  • [STORM-3412] - Jira and Central Log Links Disappear In Topo Page
  • [STORM-3413] - Deduplicate Storm site layout documents from main Storm repository
  • [STORM-3414] - Remove JavadocMethod checkstyle rule
  • [STORM-3415] - storm-jms-examples: fix all checkstyle warnings
  • [STORM-3416] - storm-jdbc-examples: fix all checkstyle warnings
  • [STORM-3417] - storm-sql-core: fix all checkstyle warnings
  • [STORM-3418] - storm-hdfs-blobstore: fix all checkstyle warnings
  • [STORM-3419] - storm-opentsdb: fix all checkstyle warnings
  • [STORM-3420] - storm-mqtt: fix all checkstyle warnings
  • [STORM-3421] - storm-kinesis: fix all checkstyle warnings
  • [STORM-3423] - Logviewer Log Is Ambiguous
  • [STORM-3424] - storm-submit-tools: fix all checkstyle warnings
  • [STORM-3427] - integration-test: fix all checkstyle warnings
  • [STORM-3428] - kafka-monitor: fix all checkstyle warnings
  • [STORM-3429] - closure: fix all checkstyle warnings
  • [STORM-3430] - flux-wrappers: fix all checkstyle warnings
  • [STORM-3431] - rocketmq-examples: fix all checkstyle warnings
  • [STORM-3432] - solr-examples: fix all checkstyle warnings
  • [STORM-3433] - pmml: fix all checkstyle warnings
  • [STORM-3435] - Use the Jetty BOM
  • [STORM-3437] - More license check automation
  • [STORM-3438] - webapp: fix all checkstyle warnings
  • [STORM-3440] - client: fix all checkstyle warnings
  • [STORM-3441] - hbase: fix all checkstyle warnings
  • [STORM-3442] - Add owner to supervisor summary
  • [STORM-3443] - hive: fix all checkstyle warnings
  • [STORM-3444] - redis: fix all checkstyle warnings
  • [STORM-3445] - metrics: fix all checkstyle warnings
  • [STORM-3446] - storm-maven-plugins: fix all checkstyle warnings
  • [STORM-3447] - jms: fix all checkstyle warnings
  • [STORM-3448] - core: fix all checkstyle warnings
  • [STORM-3449] - autocreds: fix all checkstyle warnings
  • [STORM-3450] - perf: fix all checkstyle warnings
  • [STORM-3451] - jdbc: fix all checkstyle warnings
  • [STORM-3452] - blobstore-migration: fix all checkstyle warnings
  • [STORM-3453] - eventhubs: fix all checkstyle warnings
  • [STORM-3454] - hbase-examples: fix all checkstyle warnings
  • [STORM-3455] - solr: fix all checkstyle warnings
  • [STORM-3456] - cassandra: fix all checkstyle warnings
  • [STORM-3457] - hdfs: fix all checkstyle warnings
  • [STORM-3458] - starter: fix all checkstyle warnings
  • [STORM-3460] - examples-opentsdb: fix all checkstyle warnings
  • [STORM-3461] - examples-hdfs: fix all checkstyle warnings
  • [STORM-3462] - examples-hive: fix all checkstyle warnings
  • [STORM-3463] - examples-pmml: fix all checkstyle warnings
  • [STORM-3464] - examples-mongodb: fix all checkstyle warnings
  • [STORM-3465] - examples-redis: fix all checkstyle warnings
  • [STORM-3472] - STORM-3411 should have tests, and we shouldn't catch NPE for control flow
  • [STORM-3477] - HDFS blobstore isRemoteBlobExists performs unnecessary file opens
  • [STORM-3506] - prevent topology from overriding STORM_CGROUP_HIERARCHY_DIR and WORKER_METRICS

Bug

  • [STORM-1515] - LocalState corruption after hard reboot on Windows
  • [STORM-3371] - Metrics v2 is inaccessible in Trident StateFactory.
  • [STORM-3372] - HDFS bolt can throw NPE on shutdown if not using a TimedRotationPolicy
  • [STORM-3376] - Storm drops messages in the interval between server bind and callback registration
  • [STORM-3379] - Intermittent NPE during worker boot in local mode
  • [STORM-3385] - ClientSupervisorUtils.processLauncherAndWait might have two threads reading the process' inputStream concurrently
  • [STORM-3390] - Lock python test dependencies so we don't get accidentally upgraded
  • [STORM-3408] - Rocks version shipped with Storm2 doesn't work on Windows 10
  • [STORM-3422] - TupleCaptureBolt is not thread-safe
  • [STORM-3436] - TupleInfo.id is not set, making debugging more difficult than it should be
  • [STORM-3466] - storm-kafka-monitor not found jar
  • [STORM-3470] - Possible Null Dereference in SimpleSaslServer authentication function
  • [STORM-3481] - IllegalArgumentException in ConstraintSolverStrategy
  • [STORM-3485] - VersionInfoMojo fails to run when the sources are built outside the Git repo
  • [STORM-3488] - Scheduling can cause RAS_Node resources to become negative
  • [STORM-3491] - BoltReaderRunnable shouldn't throw IllegalArgumentException for sync command
  • [STORM-3500] - Spelling issue in storm.blobstore.dependency.jar.upload.chuck.size.bytes
  • [STORM-3501] - Local Cluster worker restarts
  • [STORM-3515] - Storm CLI config options are passed directly to underlying JAVA cli
  • [STORM-3516] - Delayed Kill or Rebalance Topology not processed on Nimbus restart
  • [STORM-3520] - Storm CLI drpc-client incorrectly validating function args
  • [STORM-3521] - Storm CLI jar command doesn't handle topology arguments correctly
  • [STORM-3524] - worker fails to launch due to missing parent directory for localized resource

Dependency upgrade

  • [STORM-3373] - Use Log4j BOM, ensure SLF4J dependencies use the same version, upgrade SLF4J to latest
  • [STORM-3478] - Upgrade to JUnit 5.5.1

Task

  • [STORM-3000] - Add missing @Override annotations
  • [STORM-3386] - Set minimum Maven version for build to 3.5.0