Repository: flink-web Updated Branches: refs/heads/asf-site 035337bd3 -> e2d729cb2
Add Flink 1.4.1 release Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/913dc520 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/913dc520 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/913dc520 Branch: refs/heads/asf-site Commit: 913dc520573de770aa7ca6a46821b3c0a665e1da Parents: 035337b Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Sat Feb 10 14:40:49 2018 +0100 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Feb 16 01:36:31 2018 +0800 ---------------------------------------------------------------------- _config.yml | 40 ++++---- _posts/2018-02-10-release-1.4.1.md | 176 ++++++++++++++++++++++++++++++++ downloads.md | 1 + 3 files changed, 197 insertions(+), 20 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink-web/blob/913dc520/_config.yml ---------------------------------------------------------------------- diff --git a/_config.yml b/_config.yml index 05af7f7..cefdafb 100644 --- a/_config.yml +++ b/_config.yml @@ -9,8 +9,8 @@ url: http://flink.apache.org DOCS_BASE_URL: http://ci.apache.org/projects/flink/ -FLINK_VERSION_STABLE: 1.4.0 -FLINK_VERSION_HADOOP_2_STABLE: 1.4.0 +FLINK_VERSION_STABLE: 1.4.1 +FLINK_VERSION_HADOOP_2_STABLE: 1.4.1 FLINK_VERSION_STABLE_SHORT: 1.4 FLINK_VERSION_LATEST: 1.5-SNAPSHOT @@ -21,41 +21,41 @@ FLINK_GITHUB_URL: https://github.com/apache/flink FLINK_CONTRIBUTORS_URL: https://cwiki.apache.org/confluence/display/FLINK/List+of+contributors FLINK_GITHUB_REPO_NAME: flink -FLINK_DOWNLOAD_URL_SOURCE: http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-src.tgz -FLINK_DOWNLOAD_URL_SOURCE_ASC: https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-src.tgz.asc -FLINK_DOWNLOAD_URL_SOURCE_MD5: https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-src.tgz.md5 +FLINK_DOWNLOAD_URL_SOURCE: http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-src.tgz +FLINK_DOWNLOAD_URL_SOURCE_ASC: https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-src.tgz.asc +FLINK_DOWNLOAD_URL_SOURCE_MD5: https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-src.tgz.md5 stable_releases: - name: "Without bundled Hadoop®" id: "download-hadoopfree_211" - url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-scala_2.11.tgz"; - asc_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-scala_2.11.tgz.asc"; - md5_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-scala_2.11.tgz.md5"; + url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-bin-scala_2.11.tgz"; + asc_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-scala_2.11.tgz.asc"; + md5_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-scala_2.11.tgz.md5"; - name: "Hadoop® 2.8" id: "download-hadoop28_211" - url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop28-scala_2.11.tgz"; - asc_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop28-scala_2.11.tgz.asc"; - md5_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop28-scala_2.11.tgz.md5"; + url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-bin-hadoop28-scala_2.11.tgz"; + asc_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop28-scala_2.11.tgz.asc"; + md5_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop28-scala_2.11.tgz.md5"; - name: "Hadoop® 2.7" id: "download-hadoop27_211" - url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop27-scala_2.11.tgz"; - asc_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop27-scala_2.11.tgz.asc"; - md5_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop27-scala_2.11.tgz.md5"; + url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-bin-hadoop27-scala_2.11.tgz"; + asc_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop27-scala_2.11.tgz.asc"; + md5_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop27-scala_2.11.tgz.md5"; - name: "Hadoop® 2.6" id: "download-hadoop26_211" - url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop26-scala_2.11.tgz"; - asc_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop26-scala_2.11.tgz.asc"; - md5_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop26-scala_2.11.tgz.md5"; + url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-bin-hadoop26-scala_2.11.tgz"; + asc_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop26-scala_2.11.tgz.asc"; + md5_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop26-scala_2.11.tgz.md5"; - name: "Hadoop® 2.4" id: "download-hadoop24_211" - url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop24-scala_2.11.tgz"; - asc_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop24-scala_2.11.tgz.asc"; - md5_url: "https://www.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop24-scala_2.11.tgz.md5"; + url: "http://www.apache.org/dyn/closer.lua/flink/flink-1.4.1/flink-1.4.1-bin-hadoop24-scala_2.11.tgz"; + asc_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop24-scala_2.11.tgz.asc"; + md5_url: "https://www.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-bin-hadoop24-scala_2.11.tgz.md5"; FLINK_DOWNLOAD_URL_HADOOP_2_LATEST: https://s3.amazonaws.com/flink-nightly/flink-1.5-SNAPSHOT-bin-hadoop2.tgz http://git-wip-us.apache.org/repos/asf/flink-web/blob/913dc520/_posts/2018-02-10-release-1.4.1.md ---------------------------------------------------------------------- diff --git a/_posts/2018-02-10-release-1.4.1.md b/_posts/2018-02-10-release-1.4.1.md new file mode 100644 index 0000000..5e9d385 --- /dev/null +++ b/_posts/2018-02-10-release-1.4.1.md @@ -0,0 +1,176 @@ +--- +layout: post +title: "Apache Flink 1.4.1 Released" +date: 2018-02-15 9:00:00 +categories: news +--- + +The Apache Flink community released the first bugfix version of the Apache Flink 1.4 series. + +This release includes more than 60 fixes and minor improvements for Flink 1.4.0. The list below includes a detailed list of all fixes. + +We highly recommend all users to upgrade to Flink 1.4.1. + +Updated Maven dependencies: + +```xml +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>1.4.1</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java_2.11</artifactId> + <version>1.4.1</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients_2.11</artifactId> + <version>1.4.1</version> +</dependency> +``` + +You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html). + +List of resolved issues: + +<h2> Sub-task +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6321'>FLINK-6321</a>] - RocksDB state backend Checkpointing is not working with KeyedCEP. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7499'>FLINK-7499</a>] - double buffer release in SpillableSubpartitionView +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7756'>FLINK-7756</a>] - RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7760'>FLINK-7760</a>] - Restore failing from external checkpointing metadata. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8323'>FLINK-8323</a>] - Fix Mod scala function bug +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5506'>FLINK-5506</a>] - Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6951'>FLINK-6951</a>] - Incompatible versions of httpcomponents jars for Flink kinesis connector +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7949'>FLINK-7949</a>] - AsyncWaitOperator is not restarting when queue is full +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8145'>FLINK-8145</a>] - IOManagerAsync not properly shut down in various tests +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8200'>FLINK-8200</a>] - RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8226'>FLINK-8226</a>] - Dangling reference generated after NFA clean up timed out SharedBufferEntry +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8230'>FLINK-8230</a>] - NPE in OrcRowInputFormat on nested structs +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8235'>FLINK-8235</a>] - Cannot run spotbugs for single module +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8242'>FLINK-8242</a>] - ClassCastException in OrcTableSource.toOrcPredicate +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8248'>FLINK-8248</a>] - RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8249'>FLINK-8249</a>] - Kinesis Producer didnt configure region +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8261'>FLINK-8261</a>] - Typos in the shading exclusion for jsr305 in the quickstarts +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8263'>FLINK-8263</a>] - Wrong packaging of flink-core in scala quickstarty +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8265'>FLINK-8265</a>] - Missing jackson dependency for flink-mesos +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8270'>FLINK-8270</a>] - TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8275'>FLINK-8275</a>] - Flink YARN deployment with Kerberos enabled not working +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8278'>FLINK-8278</a>] - Scala examples in Metric documentation do not compile +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8283'>FLINK-8283</a>] - FlinkKafkaConsumerBase failing on Travis with no output in 10min +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8295'>FLINK-8295</a>] - Netty shading does not work properly +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8306'>FLINK-8306</a>] - FlinkKafkaConsumerBaseTest has invalid mocks on final methods +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8318'>FLINK-8318</a>] - Conflict jackson library with ElasticSearch connector +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8325'>FLINK-8325</a>] - Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1) +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8352'>FLINK-8352</a>] - Flink UI Reports No Error on Job Submission Failures +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8355'>FLINK-8355</a>] - DataSet Should not union a NULL row for AGG without GROUP BY clause. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8371'>FLINK-8371</a>] - Buffers are not recycled in a non-spilled SpillableSubpartition upon release +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8398'>FLINK-8398</a>] - Stabilize flaky KinesisDataFetcherTests +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8406'>FLINK-8406</a>] - BucketingSink does not detect hadoop file systems +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8409'>FLINK-8409</a>] - Race condition in KafkaConsumerThread leads to potential NPE +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8419'>FLINK-8419</a>] - Kafka consumer's offset metrics are not registered for dynamically discovered partitions +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8421'>FLINK-8421</a>] - HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8433'>FLINK-8433</a>] - Update code example for "Managed Operator State" documentation +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8461'>FLINK-8461</a>] - Wrong logger configurations for shaded Netty +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8466'>FLINK-8466</a>] - ErrorInfo needs to hold Exception as SerializedThrowable +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8484'>FLINK-8484</a>] - Kinesis consumer re-reads closed shards on job restart +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8485'>FLINK-8485</a>] - Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8489'>FLINK-8489</a>] - Data is not emitted by second ElasticSearch connector +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8496'>FLINK-8496</a>] - WebUI does not display TM MemorySegment metrics +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8499'>FLINK-8499</a>] - Kryo must not be child-first loaded +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8522'>FLINK-8522</a>] - DefaultOperatorStateBackend writes data in checkpoint that is never read. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8559'>FLINK-8559</a>] - Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot cause job to get stuck +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8561'>FLINK-8561</a>] - SharedBuffer line 573 uses == to compare BufferEntries instead of .equals. +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8079'>FLINK-8079</a>] - Skip remaining E2E tests if one failed +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8202'>FLINK-8202</a>] - Update queryable section on configuration page +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8243'>FLINK-8243</a>] - OrcTableSource should recursively read all files in nested directories of the input path. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8260'>FLINK-8260</a>] - Document API of Kafka 0.11 Producer +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8264'>FLINK-8264</a>] - Add Scala to the parent-first loading patterns +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8271'>FLINK-8271</a>] - upgrade from deprecated classes to AmazonKinesis +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8287'>FLINK-8287</a>] - Flink Kafka Producer docs should clearly state what partitioner is used by default +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8296'>FLINK-8296</a>] - Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8346'>FLINK-8346</a>] - add S3 signature v4 workaround to docs +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8362'>FLINK-8362</a>] - Shade Elasticsearch dependencies away +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8455'>FLINK-8455</a>] - Add Hadoop to the parent-first loading patterns +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8473'>FLINK-8473</a>] - JarListHandler may fail with NPE if directory is deleted +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8571'>FLINK-8571</a>] - Provide an enhanced KeyedStream implementation to use ForwardPartitioner +</li> +</ul> + +<h2> Test +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-8472'>FLINK-8472</a>] - Extend migration tests for Flink 1.4 +</li> +</ul> http://git-wip-us.apache.org/repos/asf/flink-web/blob/913dc520/downloads.md ---------------------------------------------------------------------- diff --git a/downloads.md b/downloads.md index 74a34be..ab78c71 100644 --- a/downloads.md +++ b/downloads.md @@ -98,6 +98,7 @@ Note that the community is always open for discussing bugfix releases for even o All Flink releases are available via [https://archive.apache.org/dist/flink/](https://archive.apache.org/dist/flink/) including checksums and cryptographic signatures. At the time of writing, this includes the following versions: +- Flink 1.4.1 - 2018-02-15 ([Source](https://archive.apache.org/dist/flink/flink-1.4.1/flink-1.4.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.4.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/api/scala/index.html)) - Flink 1.4.0 - 2017-11-29 ([Source](https://archive.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.4.0/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.4/api/scala/index.html)) - Flink 1.3.2 - 2017-08-05 ([Source](https://archive.apache.org/dist/flink/flink-1.3.2/flink-1.3.2-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.3.2/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/scala/index.html)) - Flink 1.3.1 - 2017-06-23 ([Source](https://archive.apache.org/dist/flink/flink-1.3.1/flink-1.3.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.3.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/scala/index.html))
