Repository: flink-web Updated Branches: refs/heads/asf-site aaf1263c9 -> a283d1701
Add 1.1.3 release blog post Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/d416d721 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/d416d721 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/d416d721 Branch: refs/heads/asf-site Commit: d416d721dc35efad9bb9ebabfbbb90d9dc840199 Parents: aaf1263 Author: Ufuk Celebi <u...@apache.org> Authored: Thu Oct 13 12:20:44 2016 +0200 Committer: Ufuk Celebi <u...@apache.org> Committed: Thu Oct 13 12:20:44 2016 +0200 ---------------------------------------------------------------------- _posts/2016-10-12-release-1.1.3.md | 107 ++++++++++++++++++++++++++++++++ 1 file changed, 107 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink-web/blob/d416d721/_posts/2016-10-12-release-1.1.3.md ---------------------------------------------------------------------- diff --git a/_posts/2016-10-12-release-1.1.3.md b/_posts/2016-10-12-release-1.1.3.md new file mode 100644 index 0000000..c2a2497 --- /dev/null +++ b/_posts/2016-10-12-release-1.1.3.md @@ -0,0 +1,107 @@ +--- +layout: post +title: "Apache Flink 1.1.3 Released" +date: 2016-10-12 9:00:00 +categories: news +--- + +The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series. + +We recommend all users to upgrade to Flink 1.1.3. + +```xml +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>1.1.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java_2.10</artifactId> + <version>1.1.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients_2.10</artifactId> + <version>1.1.3</version> +</dependency> +``` + +You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html). + +## Note for RocksDB Backend Users + +It is highly recommended to use the "fully async" mode for the RocksDB state backend. The "fully async" mode will most likely allow you to easily upgrade to Flink 1.2 (via [savepoints](https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/savepoints.html)) when it is released. The "semi async" mode will no longer be supported by Flink 1.2. + +```java +RocksDBStateBackend backend = new RocksDBStateBackend("..."); +backend.enableFullyAsyncSnapshots(); +``` + +## Release Notes - Flink - Version 1.1.3 + +<h2> Bug +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-2662'>FLINK-2662</a>] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4311'>FLINK-4311</a>] - TableInputFormat fails when reused on next split +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4329'>FLINK-4329</a>] - Fix Streaming File Source Timestamps/Watermarks Handling +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4485'>FLINK-4485</a>] - Finished jobs in yarn session fill /tmp filesystem +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4513'>FLINK-4513</a>] - Kafka connector documentation refers to Flink 1.1-SNAPSHOT +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4514'>FLINK-4514</a>] - ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4540'>FLINK-4540</a>] - Detached job execution may prevent cluster shutdown +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4544'>FLINK-4544</a>] - TaskManager metrics are vulnerable to custom JMX bean installation +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4566'>FLINK-4566</a>] - ProducerFailedException does not properly preserve Exception causes +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4588'>FLINK-4588</a>] - Fix Merging of Covering Window in MergingWindowSet +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4589'>FLINK-4589</a>] - Fix Merging of Covering Window in MergingWindowSet +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4616'>FLINK-4616</a>] - Kafka consumer doesn't store last emmited watermarks per partition in state +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4618'>FLINK-4618</a>] - FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4619'>FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4636'>FLINK-4636</a>] - AbstractCEPPatternOperator fails to restore state +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4640'>FLINK-4640</a>] - Serialization of the initialValue of a Fold on WindowedStream fails +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4651'>FLINK-4651</a>] - Re-register processing time timers at the WindowOperator upon recovery. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4663'>FLINK-4663</a>] - Flink JDBCOutputFormat logs wrong WARN message +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4672'>FLINK-4672</a>] - TaskManager accidentally decorates Kill messages +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4677'>FLINK-4677</a>] - Jars with no job executions produces NullPointerException in ClusterClient +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4702'>FLINK-4702</a>] - Kafka consumer must commit offsets asynchronously +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4727'>FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4732'>FLINK-4732</a>] - Maven junction plugin security threat +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4777'>FLINK-4777</a>] - ContinuousFileMonitoringFunction may throw IOException when files are moved +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4788'>FLINK-4788</a>] - State backend class cannot be loaded, because fully qualified name converted to lower-case +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4396'>FLINK-4396</a>] - GraphiteReporter class not found at startup of jobmanager +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4574'>FLINK-4574</a>] - Strengthen fetch interval implementation in Kinesis consumer +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4723'>FLINK-4723</a>] - Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer +</li> +</ul>