Flink 1.0.2 Released

April 22, 2016 -

Today, the Flink community released Flink version 1.0.2, the second bugfix release of the 1.0 series.

We recommend all users updating to this release by bumping the version of your Flink dependencies to 1.0.2 and updating the binaries on the server. You can find the binaries on the updated Downloads page.

Fixed Issues #

Bug #

  • [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to ‘public’
  • [FLINK-3762] [core] Enable Kryo reference tracking
  • [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()
  • [FLINK-3760] Fix StateDescriptor.readObject
  • [FLINK-3730] Fix RocksDB Local Directory Initialization
  • [FLINK-3712] Make all dynamic properties available to the CLI frontend
  • [FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore
  • [FLINK-3697] Properly access type information for nested POJO key selection

Improvement #

  • [FLINK-3654] Disable Write-Ahead-Log in RocksDB State

Docs #

  • [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs
  • [FLINK-3469] [docs] Improve documentation for grouping keys
  • [FLINK-3634] [docs] Fix documentation for DataSetUtils.zipWithUniqueId()
  • [FLINK-3711][docs] Documentation of Scala fold()() uses correct syntax

Tests #

  • [FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker() will pass before JUnit timeout