Version 2.1.0

Version 2.1.0 is based on a subset of Apache Beam 2.1.0. See the Apache Beam
2.1.0 release notes for additional change information.

Issues

Known issue: When running in batch mode, Gauge metrics are not reported.

Updates and improvements

• Added Metrics support forDataflowRunner in streaming mode.
• Added OnTimeBehavior to WindowinStrategy to control emitting of ON_TIME panes.
• Added default file name policy for windowed file FileBasedSinks which consume windowed input.
• Fixed an issue in which processing time timers for expired windows were ignored.
• Fixed an issue in which DatastoreIO failed to make progress when Datastore was slow to respond.
• Fixed an issue in which bzip2 files were being partially read; added support for concatenated bzip2 files.
• Improved several stability, performance, and documentation issues.