Download Latest Version Version 2.1.0 source code.zip (174.8 kB)
Email in envelope

Get an email when there's a new version of Dataflow Java SDK

Home / v2.1.0
Name Modified Size InfoDownloads / Week
Parent folder
README.md 2017-09-01 1.1 kB
0
Version 2.1.0 source code.tar.gz 2017-09-01 74.4 kB
0
Version 2.1.0 source code.zip 2017-09-01 174.8 kB
0
Totals: 3 Items   250.2 kB 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.
Source: README.md, updated 2017-09-01