[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #113. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/e195978f Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/e195978f Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/e195978f Branch: refs/heads/asf-site Commit: e195978f01616f9a48684d95aa456cb5c9b91c59 Parents: dd236bd Author: Fabian Hueske Authored: Mon Jul 23 16:45:11 2018 +0200 Committer: Fabian Hueske Committed: Mon Jul 23 16:45:31 2018 +0200 -- content/img/poweredby/ebay-logo.png | Bin 0 -> 23050 bytes content/img/poweredby/huawei-logo.png | Bin 0 -> 22468 bytes content/img/poweredby/lyft-logo.png | Bin 0 -> 17387 bytes content/index.html| 74 +++-- content/poweredby.html| 17 ++- 5 files changed, 75 insertions(+), 16 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/e195978f/content/img/poweredby/ebay-logo.png -- diff --git a/content/img/poweredby/ebay-logo.png b/content/img/poweredby/ebay-logo.png new file mode 100644 index 000..ff4a0de Binary files /dev/null and b/content/img/poweredby/ebay-logo.png differ http://git-wip-us.apache.org/repos/asf/flink-web/blob/e195978f/content/img/poweredby/huawei-logo.png -- diff --git a/content/img/poweredby/huawei-logo.png b/content/img/poweredby/huawei-logo.png new file mode 100644 index 000..3fd5480 Binary files /dev/null and b/content/img/poweredby/huawei-logo.png differ http://git-wip-us.apache.org/repos/asf/flink-web/blob/e195978f/content/img/poweredby/lyft-logo.png -- diff --git a/content/img/poweredby/lyft-logo.png b/content/img/poweredby/lyft-logo.png new file mode 100644 index 000..f263283 Binary files /dev/null and b/content/img/poweredby/lyft-logo.png differ http://git-wip-us.apache.org/repos/asf/flink-web/blob/e195978f/content/index.html -- diff --git a/content/index.html b/content/index.html index fe8c8e4..30de7ea 100644 --- a/content/index.html +++ b/content/index.html @@ -271,59 +271,103 @@ - + + + - + + + - + + + - + + + - + + + - + + + - - + + + + + + + + + + + + + + + + + + + + - + + + - + + + - + + + - + + + - + + + - + + + - + + + http://git-wip-us.apache.org/repos/asf/flink-web/blob/e195978f/content/poweredby.html -- diff --git a/content/poweredby.html b/content/poweredby.html index 491b74a..0dfd38c 100644 --- a/content/poweredby.html +++ b/content/poweredby.html @@ -173,17 +173,32 @@ Drivetribe, a digital community founded by the former hosts of âTop Gearâ, uses Flink for metrics and content recommendations. https://data-artisans.com/drivetribe-cqrs-apache-flink/"; target="_blank"> Read about Flink in the Drivetribe stack - + + + Ebay's monitoring platform is powered by Flink and evaluates thousands of customizable alert rules on metrics and log streams. + https://vimeo.com/265025956/c7d5576622"; target="_blank"> Learn more about Flink at Ebay + Ericsson used Flink to build a real-time anomaly detector with machine learning over large infrastructures. https://www.oreilly.com/ideas/applying-the-kappa-architecture-in-the-telco-industry"; target="_blank"> Read a detailed overview on O'Reilly Ideas + +
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/2b0c472a Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/2b0c472a Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/2b0c472a Branch: refs/heads/asf-site Commit: 2b0c472a16f34b1aa52df71bf287b550e0f89a5c Parents: 98cf557 Author: Fabian Hueske Authored: Tue Jun 5 14:46:34 2018 +0200 Committer: Fabian Hueske Committed: Tue Jun 5 14:46:34 2018 +0200 -- content/contribute-code.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/2b0c472a/content/contribute-code.html -- diff --git a/content/contribute-code.html b/content/contribute-code.html index b098395..3de551a 100644 --- a/content/contribute-code.html +++ b/content/contribute-code.html @@ -183,7 +183,7 @@ â¦please make sure there is a Jira issue that corresponds to your contribution. This is a general rule that the Flink community follows for all code contributions, including bug fixes, improvements, or new features, with an exception for trivial hot fixes. If you would like to fix a bug that you found or if you would like to add a new feature or improvement to Flink, please follow the File a bug report or Propose an improvement or a new feature guidelines to open an issue in http://issues.apache.org/jira/browse/FLINK";>Flinkâs Jira before starting with the implementation. -If the description of a Jira issue indicates that its resolution will touch sensible parts of the code base, be sufficiently complex, or add significant amounts of new code, the Flink community might request a design document. (Most contributions should not require a design document.) The purpose of this document is to ensure that the overall approach to address the issue is sensible and agreed upon by the community. Jira issues that require a design document are tagged with the requires-design-doc label. The label can be attached by any community member who feels that a design document is necessary. A good description helps to decide whether a Jira issue requires a design document or not. The design document must be added or attached to or linked from the Jira issue and cover the following aspects: +If the description of a Jira issue indicates that its resolution will touch sensitive parts of the code base, be sufficiently complex, or add significant amounts of new code, the Flink community might request a design document. (Most contributions should not require a design document.) The purpose of this document is to ensure that the overall approach to address the issue is sensible and agreed upon by the community. Jira issues that require a design document are tagged with the requires-design-doc label. The label can be attached by any community member who feels that a design document is necessary. A good description helps to decide whether a Jira issue requires a design document or not. The design document must be added or attached to or linked from the Jira issue and cover the following aspects: Overview of the general approach.
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/1bf1430b Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/1bf1430b Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/1bf1430b Branch: refs/heads/asf-site Commit: 1bf1430b28873c9498471808c436e9997892dd74 Parents: 9837b29 Author: Aljoscha Krettek Authored: Tue Apr 17 11:06:18 2018 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 17 11:06:18 2018 +0200 -- content/community.html | 70 ++--- content/css/flink.css | 4 +++ 2 files changed, 39 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/1bf1430b/content/community.html -- diff --git a/content/community.html b/content/community.html index 2993f57..f66e747 100644 --- a/content/community.html +++ b/content/community.html @@ -349,200 +349,200 @@ Apache ID -https://avatars2.githubusercontent.com/u/5990983?s=50"; /> +https://avatars2.githubusercontent.com/u/5990983?s=50"; class="committer-avatar" /> Márton Balassi PMC, Committer mbalassi -https://avatars2.githubusercontent.com/u/858078?v=3&s=50"; /> +https://avatars2.githubusercontent.com/u/858078?v=3&s=50"; class="committer-avatar" /> Paris Carbone Committer senorcarbone -https://avatars3.githubusercontent.com/u/1756620?s=50"; /> +https://avatars3.githubusercontent.com/u/1756620?s=50"; class="committer-avatar" /> Ufuk Celebi PMC, Committer uce -https://avatars2.githubusercontent.com/u/1727146?s=50"; /> +https://avatars2.githubusercontent.com/u/1727146?s=50"; class="committer-avatar" /> Stephan Ewen PMC, Committer, VP sewen -https://avatars1.githubusercontent.com/u/5880972?s=50"; /> +https://avatars1.githubusercontent.com/u/5880972?s=50"; class="committer-avatar" /> Gyula Fóra PMC, Committer gyfora -https://avatars3.githubusercontent.com/u/332352?s=50"; /> +https://avatars3.githubusercontent.com/u/332352?s=50"; class="committer-avatar" /> Alan Gates PMC, Committer gates -https://avatars1.githubusercontent.com/u/569655?s=50"; /> +https://avatars1.githubusercontent.com/u/569655?s=50"; class="committer-avatar" /> Greg Hogan PMC, Committer greg -https://avatars0.githubusercontent.com/u/2388347?s=50"; /> +https://avatars0.githubusercontent.com/u/2388347?s=50"; class="committer-avatar" /> Fabian Hueske PMC, Committer fhueske -https://avatars3.githubusercontent.com/u/498957?v=3&s=50"; /> +https://avatars3.githubusercontent.com/u/498957?v=3&s=50"; class="committer-avatar" /> Vasia Kalavri PMC, Committer vasia -https://avatars1.githubusercontent.com/u/2405800?v=3&s=50"; /> +https://avatars1.githubusercontent.com/u/2405800?v=3&s=50"; class="committer-avatar" /> Kostas Kloudas Committer kkloudas -https://avatars0.githubusercontent.com/u/68551?s=50"; /> +https://avatars0.githubusercontent.com/u/68551?s=50"; class="committer-avatar" /> Aljoscha Krettek PMC, Committer aljoscha -https://avatars1.githubusercontent.com/u/4425616?s=50"; /> +https://avatars1.githubusercontent.com/u/4425616?s=50"; class="committer-avatar" /> ChengXiang Li Committer chengxiang -https://avatars2.githubusercontent.com/u/2550549?s=50"; /> +https://avatars2.githubusercontent.com/u/2550549?s=50"; class="committer-avatar" /> Andra Lungu Committer andra -https://avatars0.githubusercontent.com/u/89049?s=50"; /> +https://avatars0.githubusercontent.com/u/89049?s=50"; class="committer-avatar" /> Robert Metzger PMC, Committer rmetzger -https://avatars2.githubusercontent.com/u/837221?s=50"; /> +https://avatars2.githubusercontent.com/u/837221?s=50"; class="committer-avatar" /> Maximilian Michels PMC, Committer mxm -https://avatars2.githubusercontent.com/u/1941681?s=50"; /> +https://avatars2.githubusercontent.com/u/1941681?s=50"; class="committer-avatar" /> Chiwan Park Committer chiwanpark -https://avatars1.githubusercontent.com/u/2128543?s=50"; /> +https://avatars1.githubusercontent.com/u/2128543?s=50"; class="committer-avatar" /> Stefan Richter Committer srichter -https://avatars1.githubusercontent.com/u/5756858?s=50"; /> +https://avatars1.githubusercontent.com/u/5756858?s=50"; class="committer-avatar" /> Till Rohrmann PMC, Committer
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/ae3a7e4c Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/ae3a7e4c Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/ae3a7e4c Branch: refs/heads/asf-site Commit: ae3a7e4c2541c3a14b19797b252bf81a93456550 Parents: 04b4862 Author: Tzu-Li (Gordon) Tai Authored: Fri Mar 16 03:56:58 2018 +0800 Committer: Tzu-Li (Gordon) Tai Committed: Fri Mar 16 03:56:58 2018 +0800 -- content/blog/feed.xml | 60 ++ content/blog/index.html| 40 ++-- content/blog/page2/index.html | 40 ++-- content/blog/page3/index.html | 40 ++-- content/blog/page4/index.html | 40 ++-- content/blog/page5/index.html | 40 ++-- content/blog/page6/index.html | 25 +++ content/downloads.html | 1 + content/index.html | 8 +- content/news/2018/03/15/release-1.3.3.html | 247 content/q/quickstart-scala.sh | 2 +- content/q/quickstart.sh| 2 +- content/q/sbt-quickstart.sh| 2 +- 13 files changed, 466 insertions(+), 81 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/ae3a7e4c/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 2fcf465..067a5a0 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,66 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +Apache Flink 1.3.3 Released +The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series.
+ +This release includes 4 critical fixes related to checkpointing and recovery. The list below includes a detailed list of all fixes.
+ +We highly recommend all Flink 1.3 series users to upgrade to Flink 1.3.3.
+ +Updated Maven dependencies:
+ ++ +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>1.3.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java_2.10</artifactId> + <version>1.3.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients_2.10</artifactId> + <version>1.3.3</version> +</dependency>You can find the binaries on the updated Downloads page.
+ +List of resolved issues:
+ +Sub-task +
++
+ +- [FLINK-7783;] - Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() +
+Bug +
++
+ +- [FLINK-7283;] - PythonPlanBinderTest issues with python paths +
+- [FLINK-8487;] - State loss after multiple restart attempts +
+- [FLINK-8807;] - ZookeeperCompleted checkpoint store can get stuck in infinite loop +
+Improvement +
++
+ +Thu, 15 Mar 2018 12:00:00 + +http://flink.apache.org/news/2018/03/15/release-1.3.3.html +/news/2018/03/15/release-1.3.3.html + + + Apache Flink 1.4.2 Released- [FLINK-8890;] - Compare checkpoints with order in CompletedCheckpoint.checkpointsMatch() +
+The Apache Flink community released the second bugfix version of the Apache Flink 1.4 series.
http://git-wip-us.apache.org/repos/asf/flink-web/blob/ae3a7e4c/content/blog/index.html ---
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/1a4e6233 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/1a4e6233 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/1a4e6233 Branch: refs/heads/asf-site Commit: 1a4e62339e1e8c8f871035f4425785aad634e9d7 Parents: 24f6a33 Author: Tzu-Li (Gordon) Tai Authored: Thu Mar 8 12:42:01 2018 +0800 Committer: Tzu-Li (Gordon) Tai Committed: Thu Mar 8 12:42:01 2018 +0800 -- content/blog/feed.xml | 201 - content/blog/index.html| 40 ++-- content/blog/page2/index.html | 40 ++-- content/blog/page3/index.html | 40 ++-- content/blog/page4/index.html | 43 ++-- content/blog/page5/index.html | 43 ++-- content/blog/page6/index.html | 25 +++ content/downloads.html | 29 +-- content/index.html | 12 +- content/news/2018/03/08/release-1.4.2.html | 278 10 files changed, 597 insertions(+), 154 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/1a4e6233/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index bea4e4c..2fcf465 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,97 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +Apache Flink 1.4.2 Released +The Apache Flink community released the second bugfix version of the Apache Flink 1.4 series.
+ +This release includes more than 10 fixes and minor improvements for Flink 1.4.1. The list below includes a detailed list of all fixes.
+ +We highly recommend all users to upgrade to Flink 1.4.2.
+ +Updated Maven dependencies:
+ ++ +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>1.4.2</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java_2.11</artifactId> + <version>1.4.2</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients_2.11</artifactId> + <version>1.4.2</version> +</dependency>You can find the binaries on the updated Downloads page.
+ +List of resolved issues:
+ +Sub-task +
++
+ +- [FLINK-6321;] - RocksDB state backend Checkpointing is not working with KeyedCEP. +
+- [FLINK-7756;] - RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. +
+Bug +
++
- [FLINK-8423;] - OperatorChain#pushToOperator catch block may fail with NPE +
+- [FLINK-8451;] - CaseClassSerializer is not backwards compatible in 1.4 +
+- [FLINK-8520;] - CassandraConnectorITCase.testCassandraTableSink unstable on Travis +
+- [FLINK-8621;] - PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis +
+- [FLINK-8692;] - Mistake in MyMapFunction code snippet +
+- [FLINK-8735;] - Add savepoint migration ITCase that covers operator state +
+- [FLINK-8741;] - KafkaFe
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/bc3766c7 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/bc3766c7 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/bc3766c7 Branch: refs/heads/asf-site Commit: bc3766c71d23e22832026b0c8d2c993be0bf1a50 Parents: 00ef1c4 Author: Fabian Hueske Authored: Thu Mar 1 18:41:28 2018 +0100 Committer: Fabian Hueske Committed: Thu Mar 1 18:42:07 2018 +0100 -- content/blog/feed.xml | 155 + content/blog/index.html | 38 ++- content/blog/page2/index.html | 40 ++- content/blog/page3/index.html | 40 ++- content/blog/page4/index.html | 40 ++- content/blog/page5/index.html | 40 ++- content/blog/page6/index.html | 25 ++ .../end-to-end-exactly-once-apache-flink.html | 342 +++ content/img/blog/eo-post-graphic-1.png | Bin 0 -> 106477 bytes content/img/blog/eo-post-graphic-2.png | Bin 0 -> 124079 bytes content/img/blog/eo-post-graphic-3.png | Bin 0 -> 160968 bytes content/img/blog/eo-post-graphic-4.png | Bin 0 -> 225687 bytes content/img/blog/eo-post-graphic-5.png | Bin 0 -> 184375 bytes content/index.html | 11 +- 14 files changed, 648 insertions(+), 83 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/bc3766c7/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index b25b084..bea4e4c 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,161 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +An Overview of End-to-End Exactly-Once Processing in Apache Flink (with Apache Kafka, too!) +This post is an adaptation of Piotr Nowojskiâs presentation from Flink Forward Berlin 2017. You can find the slides and a recording of the presentation on the Flink Forward Berlin website.
+ +Apache Flink 1.4.0, released in December 2017, introduced a significant milestone for stream processing with Flink: a new feature called
+ +TwoPhaseCommitSinkFunction(relevant Jira here) that extracts the common logic of the two-phase commit protocol and makes it possible to build end-to-end exactly-once applications with Flink and a selection of data sources and sinks, including Apache Kafka versions 0.11 and beyond. It provides a layer of abstraction and requires a user to implement only a handful of methods to achieve end-to-end exactly-once semantics.If thatâs all you need to hear, let us point you to the relevant place in the Flink documentation, where you can read about how to put
+ +TwoPhaseCommitSinkFunctionto use.But if youâd like to learn more, in this post, weâll share an in-depth overview of the new feature and what is happening behind the scenes in Flink.
+ +Throughout the rest of this post, weâll:
+ ++
+ +- Describe the role of Flinkâs checkpoints for guaranteeing exactly-once results within a Flink application.
+- Show how Flink interacts with data sources and data sinks via the two-phase commit protocol to deliver end-to-end exactly-once guarantees.
+- Walk through a simple example on how to use
+TwoPhaseCommitSinkFunctionto implement an exactly-once file sink.Exactly-once Semantics Within an Apache Flink Application
+ +When we say âexactly-once semanticsâ, what we mean is that each incoming event affects the final results exactly once. Even in case of a machine or software failure, thereâs no duplicate data and no data that goes unprocessed.
+ +Flink has long provided exactly-once semantics within a Flink application. Over the past few years, weâve written in depth about Flinkâs checkpointing, which is at the core of Flinkâs ability to provide exactly-once semantics. The Flink documentation also [2/2] flink-web git commit: Rebuild website
Rebuild website This closes #100. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/035337bd Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/035337bd Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/035337bd Branch: refs/heads/asf-site Commit: 035337bd381b913ad2ec69aaa13f92061a1faff8 Parents: 8f98e45 Author: Fabian Hueske Authored: Wed Feb 7 18:58:14 2018 +0100 Committer: Fabian Hueske Committed: Wed Feb 7 18:58:30 2018 +0100 -- content/blog/feed.xml | 90 ++ content/blog/index.html | 44 ++- content/blog/page2/index.html | 46 +-- content/blog/page3/index.html | 45 ++- content/blog/page4/index.html | 44 ++- content/blog/page5/index.html | 46 +-- content/blog/page6/index.html | 32 ++- .../2018/01/30/incremental-checkpointing.html | 277 +++ .../img/blog/incremental_cp_impl_example.svg| 3 + content/index.html | 6 +- 10 files changed, 553 insertions(+), 80 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/035337bd/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 2006044..0c44c61 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,96 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +Managing Large State in Apache Flink: An Intro to Incremental Checkpointing +Apache Flink was purpose-built for stateful stream processing. However, what is state in a stream processing application? I defined state and stateful stream processing in a previous blog post, and in case you need a refresher, state is defined as memory in an applicationâs operators that stores information about previously-seen events that you can use to influence the processing of future events.
+ +State is a fundamental, enabling concept in stream processing required for a majority of complex use cases. Some examples highlighted in the Flink documentation:
+ ++
+ +- When an application searches for certain event patterns, the state stores the sequence of events encountered so far.
+- When aggregating events per minute, the state holds the pending aggregates.
+- When training a machine learning model over a stream of data points, the state holds the current version of the model parameters.
+However, stateful stream processing is only useful in production environments if the state is fault tolerant. âFault toleranceâ means that even if thereâs a software or machine failure, the computed end-result is accurate, with no data loss or double-counting of events.
+ +Flinkâs fault tolerance has always been a powerful and popular feature, minimizing the impact of software or machine failure on your business and making it possible to guarantee exactly-once results from a Flink application.
+ +Core to this is checkpointing;, which is the mechanism Flink uses to make application state fault tolerant. A checkpoint in Flink is a global, asynchronous snapshot of application state thatâs taken on a regular interval and sent to durable storage (usually, a distributed file system). In the event of a failure, Flink restarts an application using the most recently completed checkpoint as a starting point. Some Apache Flink users run applications with gigabytes or even terabytes of application state. These users reported that with such large state, creating a checkpoint was often a slow and resource intensive operation, which is why in Flink 1.3 we introduced âincremental checkpointing.â
+ +Before incremental checkpointing, every single Flink checkpoint consisted of the full state of an application. We created the incremental checkpointing feature after we noticed that writing the full state for every checkpoint was often unnecessary, as the state changes from one checkpoint to the next were rarely that large. Incremental checkpointing instead maintains the differences (or âdeltaâ) between each checkpoint and stores only the differences between the last checkpoint and the current state.
+ +Incremental checkpoints can provide a significant performance improvement for jobs with a very large state. Early
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/3219e324 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/3219e324 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/3219e324 Branch: refs/heads/asf-site Commit: 3219e3245d6d73903cf58f1f548a02306b084f71 Parents: 63bd21d Author: Fabian Hueske Authored: Thu Dec 21 17:59:55 2017 +0100 Committer: Fabian Hueske Committed: Thu Dec 21 17:59:55 2017 +0100 -- content/blog/feed.xml | 141 content/blog/index.html | 36 +- content/blog/page2/index.html | 37 ++- content/blog/page3/index.html | 38 ++- content/blog/page4/index.html | 44 +-- content/blog/page5/index.html | 45 ++- content/blog/page6/index.html | 25 ++ content/img/blog/flink-dow-2017.png | Bin 0 -> 3356 bytes content/img/blog/flink-hod-2017.png | Bin 0 -> 3225 bytes content/img/blog/flink-lines-of-code-2017.png | Bin 0 -> 3931 bytes content/img/blog/flink-meetups-dec2017.png | Bin 0 -> 158700 bytes content/img/blog/flink-releases-2017.png| Bin 0 -> 74945 bytes content/img/blog/github-stats-2017.png | Bin 0 -> 260619 bytes content/img/blog/speaker-logos-ff2017.png | Bin 0 -> 87833 bytes content/index.html | 8 +- .../news/2017/12/21/2017-year-in-review.html| 328 +++ 16 files changed, 621 insertions(+), 81 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/3219e324/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 9f8d02d..2006044 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,147 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +Apache Flink in 2017: Year in Review +2017 was another exciting year for the Apache Flink® community, with 3 major version releases (Flink 1.2.0 in February, Flink 1.3.0 in June, and Flink 1.4.0 in December) and the first-ever Flink Forward in San Francisco, giving Flink community members in another corner of the globe an opportunity to connect. Users shared details about their innovative production deployments, redefining what is possible with a modern stream processing framework like Flink.
+ +In this post, weâll look back on the projectâs progress over the course of 2017, and weâll also preview what 2018 has in store.
+ ++ + ++ +Community Growth
+ +Github
+ +First, hereâs a summary of community statistics from GitHub;. At the time of writing:
+ ++
+ +- Contributors have increased from 258 in December 2016 to 352 in December 2017 (up 36%)
+- Stars have increased from 1830 in December 2016 to 3036 in December 2017 (up 65%)
+- Forks have increased from 1255 in December 2016 to 2070 in December 2017 (up 65%)
+The community also welcomed 10 new committers in 2017: Kostas Kloudas, Jark Wu, Stefan Richter, Kurt Young, Theodore Vasiloudis, Xiaogang Shi, Dawid Wysakowicz, Shaoxuan Wang, Jincheng Sun and Haohui Mai.
+ +We also welcomed 3 new members to the [2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/b311c4f9 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/b311c4f9 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/b311c4f9 Branch: refs/heads/asf-site Commit: b311c4f9a151948c0f60b6110ae465d725af0208 Parents: 9133e71 Author: Aljoscha Krettek Authored: Wed Dec 13 14:17:50 2017 +0100 Committer: Aljoscha Krettek Committed: Wed Dec 13 14:17:50 2017 +0100 -- content/blog/feed.xml | 9 + content/news/2017/12/12/release-1.4.0.html | 9 + 2 files changed, 18 insertions(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/b311c4f9/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 0e1113c..9f8d02d 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -50,6 +50,7 @@ releases for APIs annotated with the @Public annotation.Changes to dynamic class loading of user code No more Avro dependency included by default Hadoop-free Flink +Bundled S3 FileSystems List of Contributors @@ -222,6 +223,14 @@ supported version of YARN, and Flink would dynamically use the Hadoop dependenci dependencies or make sure to include Hadoop dependencies when building a jar file for your application. +Bundled S3 FileSystems
+ +Flink 1.4 comes bundled with two different S3 FileSystems based on the Presto S3 FileSystem and +the Hadoop S3A FileSystem. They donât have dependencies (because all dependencies are +shaded/relocated) and you can use them by dropping the respective file from the
; +optdirectory +into thelibdirectory of your Flink installation. For more information about this, please refer +to the documentation.List of Contributors
According to git shortlog, the following 106 people contributed to the 1.4.0 release. Thank you to http://git-wip-us.apache.org/repos/asf/flink-web/blob/b311c4f9/content/news/2017/12/12/release-1.4.0.html -- diff --git a/content/news/2017/12/12/release-1.4.0.html b/content/news/2017/12/12/release-1.4.0.html index fcec280..4213521 100644 --- a/content/news/2017/12/12/release-1.4.0.html +++ b/content/news/2017/12/12/release-1.4.0.html @@ -183,6 +183,7 @@ releases for APIs annotated with the @Public annotation. Changes to dynamic class loading of user code No more Avro dependency included by default Hadoop-free Flink + Bundled S3 FileSystems List of Contributors @@ -355,6 +356,14 @@ supported version of YARN, and Flink would dynamically use the Hadoop dependenci dependencies or make sure to include Hadoop dependencies when building a jar file for your application. +Bundled S3 FileSystems + +Flink 1.4 comes bundled with two different S3 FileSystems based on the Presto S3 FileSystem and +the Hadoop S3A FileSystem. They donât have dependencies (because all dependencies are +shaded/relocated) and you can use them by dropping the respective file from the opt directory +into the lib directory of your Flink installation. For more information about this, please refer +to the https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/filesystems.html#built-in-file-systems";>documentation. + List of Contributors According to git shortlog, the following 106 people contributed to the 1.4.0 release. Thank you to
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/de20a67d Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/de20a67d Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/de20a67d Branch: refs/heads/asf-site Commit: de20a67df4107c5275a4813142d833d874298c63 Parents: 2d42077 Author: Aljoscha Krettek Authored: Tue Dec 12 17:24:02 2017 +0100 Committer: Aljoscha Krettek Committed: Tue Dec 12 17:24:02 2017 +0100 -- content/blog/feed.xml | 25 - content/news/2017/12/12/release-1.4.0.html | 25 - 2 files changed, 48 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/de20a67d/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 07bb0c3..0e1113c 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -33,6 +33,30 @@ releases for APIs annotated with the @Public annotation.For more background on the Flink 1.4.0 release and the work planned for the Flink 1.5.0 release, please refer to this blog post on the Apache Flink blog.
++++
+ +- New Features and Improvements
++
+- End-to-end Exactly Once Applications with Apache Flink and Apache Kafka and TwoPhaseCommitSinkFunction
+- Table API and Streaming SQL Enhancements
+- A Significantly-Improved Dependency Structure and Reversed Class Loading
+- Hadoop-free Flink
+- Improvements to Flink Internals
+- Improvements to the Queryable State Client
+- Metrics and Monitoring
+- Connector improvements and fixes
+- Release Notes - Please Read +
+- List of Contributors
+New Features and Improvements
End-to-end Exactly Once Applications with Apache Flink and Apache Kafka and TwoPhaseCommitSinkFunction
@@ -217,7 +241,6 @@ fengyelei, godfreyhe, gosubpl, gyao, hongyuhong, huafengw, kkloudas, kl0u, linco lingjinjiang, mengji.fy, minwenjun, mtunique, p1tz, paul, rtudoran, shaoxuan-wang, sirko bretschneider, sunjincheng121, tedyu, twalthr, uybhatti, wangmiao1981, yew1eb, z00376786, zentol, zhangminglei, zhe li, zhouhai02, zjureel, ä»å ¸, åé¿, å®ç, æ·æ±, é竹 - Tue, 12 Dec 2017 11:00:00 +0100 http://flink.apache.org/news/2017/12/12/release-1.4.0.html http://git-wip-us.apache.org/repos/asf/flink-web/blob/de20a67d/content/news/2017/12/12/release-1.4.0.html -- diff --git a/content/news/2017/12/12/release
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/389b00e6 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/389b00e6 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/389b00e6 Branch: refs/heads/asf-site Commit: 389b00e6779a24404f88707a7c4048546087039d Parents: 3df7f59 Author: Aljoscha Krettek Authored: Thu Nov 23 12:08:13 2017 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 23 12:08:13 2017 +0100 -- content/blog/feed.xml | 9 + content/news/2017/11/22/release-1.4-and-1.5-timeline.html | 9 + 2 files changed, 10 insertions(+), 8 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/389b00e6/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index f39fda1..b60a59d 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -20,7 +20,7 @@ in the hands of users.This post will describe how the community plans to get there and the rationale behind the approach.
-Coming soon: Major Changes to the Flinkâs Runtime
+Coming soon: Major Changes to Flinkâs Runtime
There are 3 significant improvements to the Apache Flink engine that the community has nearly completed and that will have a meaningful impact on Flinkâs operability and performance.
@@ -33,9 +33,10 @@ completed and that will have a meaningful impact on Flinkâs operability and peNext, weâll go through each of these improvements in more detail.
-Reworking Flinkâs Deployment Model and Distributed Process
+Reworking Flinkâs Deployment Model and Distributed Processing
-FLIP-6; is an initiative +
FLIP-6; (FLIP is short for +FLink Improvement Proposal and FLIPs are proposals for bigger changes to Flink) is an initiative thatâs been in the works for more than a year and represents a major refactor of Flinkâs deployment model and distributed process. The underlying motivation for FLIP-6 was the fact that Flink is being adopted by a wider range of developer communitiesâboth developers coming from the big data and @@ -71,7 +72,7 @@ driven network I/O and application-level flow control, ensuring that Flink will network capacity, as well as credit-based flow control which offers more fine-grained backpressuring for improved checkpoint alignments.
-In our testing (see slide 26 here), +
In our testing (see slide 26 here), weâve seen a substantial improvement in latency using event-driven network I/O, and the community is also doing work to make sure weâre able to provide this increase in speed without a measurable throughput tradeoff.
http://git-wip-us.apache.org/repos/asf/flink-web/blob/389b00e6/content/news/2017/11/22/release-1.4-and-1.5-timeline.html -- diff --git a/content/news/2017/11/22/release-1.4-and-1.5-timeline.html b/content/news/2017/11/22/release-1.4-and-1.5-timeline.html index 8079574..8c2eda9 100644 --- a/content/news/2017/11/22/release-1.4-and-1.5-timeline.html +++ b/content/news/2017/11/22/release-1.4-and-1.5-timeline.html @@ -153,7 +153,7 @@ in the hands of users. This post will describe how the community plans to get there and the rationale behind the approach. -Coming soon: Major Changes to the Flinkâs Runtime +Coming soon: Major Changes to Flinkâs Runtime There are 3 significant improvements to the Apache Flink engine that the community has nearly completed and that will have a meaningful impact on Flinkâs operability and performance. @@ -166,9 +166,10 @@ completed and that will have a meaningful impact on Flinkâs operability and pe Next, weâll go through each of these improvements in more detail. -Reworking Flinkâs Deployment Model and Distributed Process +Reworking Flinkâs Deployment Model and Distributed Processing -https://cwiki.apache.o
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/4fc16962 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/4fc16962 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/4fc16962 Branch: refs/heads/asf-site Commit: 4fc16962417467742b5727f8eb4a6e1d33155ea3 Parents: 1452aac Author: Greg Hogan Authored: Fri May 5 09:17:22 2017 -0400 Committer: Greg Hogan Committed: Fri May 5 09:17:22 2017 -0400 -- content/downloads.html | 35 --- 1 file changed, 16 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/4fc16962/content/downloads.html -- diff --git a/content/downloads.html b/content/downloads.html index e0f6271..93e0735 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -166,11 +166,10 @@ $( document ).ready(function() { Apache Flink® 1.2.1 is our latest stable release. -You -donât have to install Hadoop -to use Flink, but if you plan to use Flink with data stored in Hadoop, pick the -version matching your installed Hadoop version. If you donât want to do this, -pick the Hadoop 2 version. +An Apache Hadoop installation is +not required +to use Flink. If you plan to run Flink in YARN or process data stored in HDFS then +select the version matching your installed Hadoop version. Binaries @@ -182,30 +181,28 @@ pick the Hadoop 2 version. -Hadoop® 2.3.0 -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop2-scala_2.10.tgz"; class="ga-track" id="download-hadoop2">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop2-scala_2.11.tgz"; class="ga-track" id="download-hadoop2_211">Download - - - -Hadoop® 2.4.1 -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop24-scala_2.10.tgz"; class="ga-track" id="download-hadoop24">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop24-scala_2.11.tgz"; class="ga-track" id="download-hadoop24_211">Download +Hadoop® 2.7 +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop27-scala_2.10.tgz"; class="ga-track" id="download-hadoop27">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download -Hadoop® 2.6.0 +Hadoop® 2.6 http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop26-scala_2.10.tgz"; class="ga-track" id="download-hadoop26">Download http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop26-scala_2.11.tgz"; class="ga-track" id="download-hadoop26_211">Download -Hadoop® 2.7.0 -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop27-scala_2.10.tgz"; class="ga-track" id="download-hadoop27">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download +Hadoop® 2.4 +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop24-scala_2.10.tgz"; class="ga-track" id="download-hadoop24">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop24-scala_2.11.tgz"; class="ga-track" id="download-hadoop24_211">Download - + +Hadoop® 2.3 +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop2-scala_2.10.tgz"; class="ga-track" id="download-hadoop2">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-bin-hadoop2-scala_2.11.tgz"; class="ga-track" id="download-hadoop2_211">Download +
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/b1878e33 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/b1878e33 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/b1878e33 Branch: refs/heads/asf-site Commit: b1878e3330687f6c0f98ea8d36cbb5d0af188dcc Parents: afcedbb Author: Kurt Young Authored: Tue Apr 25 17:48:54 2017 +0800 Committer: Kurt Young Committed: Tue Apr 25 17:48:54 2017 +0800 -- content/community.html | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/b1878e33/content/community.html -- diff --git a/content/community.html b/content/community.html index bdfc388..9602c8e 100644 --- a/content/community.html +++ b/content/community.html @@ -491,6 +491,12 @@ Committer jark + +https://avatars0.githubusercontent.com/u/955396?s=50"; /> +Kurt Young +Committer +kurt + You can reach committers directly at@apache.org. A list of all contributors can be found https://cwiki.apache.org/confluence/display/FLINK/List+of+contributors";>here.
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/c2a77b5c Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/c2a77b5c Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/c2a77b5c Branch: refs/heads/asf-site Commit: c2a77b5c4dd3618eb513eaae0a9be70c84feb1ed Parents: 1d4cd1f Author: Greg Hogan Authored: Sat Apr 8 07:08:14 2017 -0400 Committer: Greg Hogan Committed: Sat Apr 8 07:08:14 2017 -0400 -- content/community.html | 66 ++--- 1 file changed, 33 insertions(+), 33 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/c2a77b5c/content/community.html -- diff --git a/content/community.html b/content/community.html index 84cdf6a..bdfc388 100644 --- a/content/community.html +++ b/content/community.html @@ -340,14 +340,14 @@ PMC, Committer mbalassi - -https://avatars2.githubusercontent.com/u/858078?v=3&s=50"; /> -Paris Carbone -Committer -senorcarbone - -https://avatars3.githubusercontent.com/u/1756620?s=50"; /> +https://avatars2.githubusercontent.com/u/858078?v=3&s=50"; /> +Paris Carbone +Committer +senorcarbone + + +https://avatars3.githubusercontent.com/u/1756620?s=50"; /> Ufuk Celebi PMC, Committer uce @@ -365,12 +365,18 @@ gyfora - +https://avatars3.githubusercontent.com/u/332352?s=50"; /> Alan Gates PMC, Committer gates +https://avatars1.githubusercontent.com/u/569655?s=50"; /> +Greg Hogan +PMC, Committer +greg + + https://avatars0.githubusercontent.com/u/2388347?s=50"; /> Fabian Hueske PMC, Committer @@ -384,18 +390,24 @@ - https://avatars1.githubusercontent.com/u/2405800?v=3&s=50"; /> - Kostas Kloudas - Committer - kkloudas - - +https://avatars1.githubusercontent.com/u/2405800?v=3&s=50"; /> +Kostas Kloudas +Committer +kkloudas + + https://avatars0.githubusercontent.com/u/68551?s=50"; /> Aljoscha Krettek PMC, Committer aljoscha +https://avatars1.githubusercontent.com/u/4425616?s=50"; /> +ChengXiang Li +Committer +chengxiang + + https://avatars2.githubusercontent.com/u/2550549?s=50"; /> Andra Lungu Committer @@ -450,13 +462,19 @@ ssc +https://avatars1.githubusercontent.com/u/5284370?s=50"; /> +Tzu-Li (Gordon) Tai +Committer +tzulitai + + https://avatars2.githubusercontent.com/u/1925554?s=50"; /> Kostas Tzoumas PMC, Committer ktzoumas - +https://avatars3.githubusercontent.com/u/5746567?s=50"; /> Timo Walther PMC, Committer twalthr @@ -468,24 +486,6 @@ warneke -https://avatars1.githubusercontent.com/u/4425616?s=50"; /> -ChengXiang Li -Committer -chengxiang - - -https://avatars1.githubusercontent.com/u/569655?s=50"; /> -Greg Hogan -Committer -greg - - -https://avatars1.githubusercontent.com/u/5284370?s=50"; /> -Tzu-Li (Gordon) Tai -Committer -tzulitai - - https://avatars1.githubusercontent.com/u/5378924?s=50"; /> Jark Wu Committer
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/efb3b513 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/efb3b513 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/efb3b513 Branch: refs/heads/asf-site Commit: efb3b513c1f95dde3ff391d7a426ef2cb673c983 Parents: cb74df5 Author: Stefan Richter Authored: Fri Mar 3 14:33:46 2017 +0100 Committer: Stefan Richter Committed: Fri Mar 3 14:33:46 2017 +0100 -- content/community.html | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/efb3b513/content/community.html -- diff --git a/content/community.html b/content/community.html index 5a72235..fcfc428 100644 --- a/content/community.html +++ b/content/community.html @@ -414,6 +414,12 @@ chiwanpark +https://avatars1.githubusercontent.com/u/2128543?s=50"; /> +Stefan Richter +Committer +srichter + + https://avatars1.githubusercontent.com/u/5756858?s=50"; /> Till Rohrmann PMC, Committer
[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #17. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/dafb7f81 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/dafb7f81 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/dafb7f81 Branch: refs/heads/asf-site Commit: dafb7f8195cd7b76d30fa882c5752f8f3a6e2848 Parents: 2235799 Author: Ufuk Celebi Authored: Mon Feb 20 16:00:01 2017 +0100 Committer: Ufuk Celebi Committed: Mon Feb 20 16:00:11 2017 +0100 -- content/blog/index.html | 5 - content/blog/page2/index.html | 5 - content/blog/page3/index.html | 5 - content/blog/page4/index.html | 5 - content/blog/page5/index.html | 5 - content/blog/release_1.0.0-changelog_known_issues.html| 5 - content/blog/release_1.1.0-changelog.html | 5 - content/blog/release_1.2.0-changelog.html | 5 - content/community.html| 10 +- content/contribute-code.html | 5 - content/contribute-documentation.html | 5 - content/documentation.html| 5 - content/downloads.html| 5 - content/ecosystem.html| 5 - content/faq.html | 5 - content/features.html | 5 - content/how-to-contribute.html| 5 - content/improve-website.html | 5 - content/index.html| 5 - content/introduction.html | 5 - content/material.html | 5 - content/news/2014/08/26/release-0.6.html | 5 - content/news/2014/09/26/release-0.6.1.html| 5 - content/news/2014/10/03/upcoming_events.html | 5 - content/news/2014/11/04/release-0.7.0.html| 5 - content/news/2014/11/18/hadoop-compatibility.html | 5 - content/news/2015/01/06/december-in-flink.html| 5 - content/news/2015/01/21/release-0.8.html | 5 - content/news/2015/02/04/january-in-flink.html | 5 - content/news/2015/02/09/streaming-example.html| 5 - content/news/2015/03/02/february-2015-in-flink.html | 5 - .../03/13/peeking-into-Apache-Flinks-Engine-Room.html | 5 - content/news/2015/04/07/march-in-flink.html | 5 - content/news/2015/04/13/release-0.9.0-milestone1.html | 5 - content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html | 5 - content/news/2015/05/14/Community-update-April.html | 5 - .../2015/06/24/announcing-apache-flink-0.9.0-release.html | 5 - content/news/2015/08/24/introducing-flink-gelly.html | 5 - content/news/2015/09/01/release-0.9.1.html| 5 - content/news/2015/09/03/flink-forward.html| 5 - content/news/2015/09/16/off-heap-memory.html | 5 - content/news/2015/11/16/release-0.10.0.html | 5 - content/news/2015/11/27/release-0.10.1.html | 5 - content/news/2015/12/04/Introducing-windows.html | 5 - content/news/2015/12/11/storm-compatibility.html | 5 - content/news/2015/12/18/a-year-in-review.html | 5 - content/news/2016/02/11/release-0.10.2.html | 5 - content/news/2016/03/08/release-1.0.0.html| 5 - content/news/2016/04/06/cep-monitoring.html | 5 - content/news/2016/04/06/release-1.0.1.html| 5 - content/news/2016/04/14/flink-forward-announce.html | 5 - content/news/2016/04/22/release-1.0.2.html| 5 - content/news/2016/05/11/release-1.0.3.html| 5 - content/news/2016/05/24/stream-sql.html | 5 - content/news/2016/08/08/release-1.1.0.html| 5 - content/news/2016/08/11/release-1.1.1.html| 5 - content/news/2016/08/24/ff16-keynotes-panels.html | 5 - content/news/2016/09/05/release-1.1.2.html| 5 - content/news/2016/10/12/release-1.1.3.html| 5 - content/news/2016/12/19/2016-year-in-review.html | 5 - content/news/2016/12/21/release-1.1.4.html| 5 - content/news/2017/02/06/release-1.2.0.html| 5 - content/poweredby.html
[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #47. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/0f490d90 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0f490d90 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0f490d90 Branch: refs/heads/asf-site Commit: 0f490d9095da20a86e63ec0fe4d4546b0037ba9b Parents: cc3b79d Author: Ufuk Celebi Authored: Mon Feb 20 15:57:59 2017 +0100 Committer: Ufuk Celebi Committed: Mon Feb 20 15:57:59 2017 +0100 -- content/poweredby.html | 30 ++ 1 file changed, 22 insertions(+), 8 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/0f490d90/content/poweredby.html -- diff --git a/content/poweredby.html b/content/poweredby.html index d147650..4322384 100644 --- a/content/poweredby.html +++ b/content/poweredby.html @@ -152,6 +152,7 @@ th, td { padding: 10px; } + .height > img {min-height: 137px}; @@ -161,47 +162,60 @@ - + Alibaba, the world's largest retailer, uses a fork of Flink called Blink to optimize search rankings in real time. http://data-artisans.com/blink-flink-alibaba-search/"; target="_blank"> Read more about Flink's role at Alibaba - + Bouygues Telecom is running 30 production applications powered by Flink and is processing 10 billion raw events per day. http://flink-forward.org/kb_sessions/a-brief-history-of-time-with-apache-flink-real-time-monitoring-and-analysis-with-flink-kafka-hb/"; target="_blank"> See Bouygues Telcom at Flink Forward 2016 - + Capital One, a Fortune 500 financial services company, uses Flink for real-time activity monitoring and alerting. http://www.slideshare.net/FlinkForward/flink-case-study-capital-one"; target="_blank"> See Capital One's case study slides - + Ericsson used Flink to build a real-time anomaly detector with machine learning over large infrastructures. https://www.oreilly.com/ideas/applying-the-kappa-architecture-in-the-telco-industry"; target="_blank"> Read a detailed overview on O'Reilly Ideas - + King, the creators of Candy Crush Saga, uses Flink to provide data science teams a real-time analytics dashboard. https://techblog.king.com/rbea-scalable-real-time-analytics-king/"; target="_blank"> Read about King's Flink implementation - + Otto Group, the world's second-largest online retailer, uses Flink for business intelligence stream processing. http://flink-forward.org/kb_sessions/flinkspector-taming-the-squirrel/"; target="_blank"> See Otto at Flink Forward 2016 - + ResearchGate, a social network for scientists, uses Flink for network analysis and near-duplicate detection. http://flink-forward.org/kb_sessions/joining-infinity-windowless-stream-processing-with-flink/"; target="_blank"> See ResearchGate at Flink Forward 2016 - + Zalando, one of the largest ecommerce companies in Europe, uses Flink for real-time process monitoring and ETL. https://tech.zalando.de/blog/apache-showdown-flink-vs.-spark/"; target="_blank"> Read more on the Zalando Tech Blog + +$( document ).ready(function() { +var heights = $(".height").map(function() { +return $(this).height(); +}).get(), + +maxHeight = Math.max.apply(null, heights); + +$(".height").height(maxHeight); +}); + + +
[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #48. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/73d9c720 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/73d9c720 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/73d9c720 Branch: refs/heads/asf-site Commit: 73d9c720e9e4b1a05de309cf9fab16946c6cf9b7 Parents: 76ba013 Author: Ufuk Celebi Authored: Mon Feb 20 15:46:18 2017 +0100 Committer: Ufuk Celebi Committed: Mon Feb 20 15:46:19 2017 +0100 -- content/slides.html | 19 +-- 1 file changed, 13 insertions(+), 6 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/73d9c720/content/slides.html -- diff --git a/content/slides.html b/content/slides.html index c134e8f..99c264a 100644 --- a/content/slides.html +++ b/content/slides.html @@ -147,9 +147,10 @@ Training Flink Forward Slides - 2016 - 2015 - 2014 + 2017 + 2016 + 2015 + 2014 @@ -170,9 +171,15 @@ Note: Keep in mind that code examples on slides have a chance of being incomplete or outdated. Always refer to the http://ci.apache.org/projects/flink/flink-docs-release-1.3";>latest documentation for an up to date reference. -2016 +2017 + + Fabian Hueske: Stream Analytics with SQL on Apache Flink Big Data Tech Summit, Warsaw February 2017: http://www.slideshare.net/dataArtisans/fabian-hueske-stream-analytics-with-sql-on-apache-flink";>SlideShare + + +2016 + Stephan Ewen: Stream Processing as a Foundational Paradigm and Apache Flinkâs Approach to It Big Data, Berlin v 10.0, December 2016: http://www.slideshare.net/dataArtisans/stephan-ewen-stream-processing-as-a-foundational-paradigm-and-apache-flinks-approach-to-it";>SlideShare Kostas Tzoumas & Stephan Ewen: Keynote -The maturing data streaming ecosystem and Apache Flinkâs accelerated growth Flink Forward, Berlin September 2016: http://www.slideshare.net/FlinkForward/kostas-tzoumasstpehan-ewen-keynote-the-maturing-data-streaming-ecosystem-and-apache-flinks-accelerated-growth";>SlideShare Robert Metzger: Connecting Apache Flink to the World - Reviewing the streaming connectors Flink Forward, Berlin September 2016: http://www.slideshare.net/FlinkForward/robert-metzger-connecting-apache-flink-to-the-world-reviewing-the-streaming-connectors";>SlideShare Till Rohrmann & Fabian Hueske: Declarative stream processing with StreamSQL and CEP Flink Forward, Berlin September 2016: http://www.slideshare.net/FlinkForward/fabian-huesketill-rohrmann-declarative-stream-processing-with-streamsql-and-cep";>SlideShare @@ -201,7 +208,7 @@ Till Rohrmann: Streaming Done Right. FOSDEM, January 2016: http://www.slideshare.net/tillrohrmann/apache-flink-streaming-done-right-fosdem-2016";>SlideShare -2015 +2015 Till Rohrmann: Streaming Data Flow with Apache Flink (October 29th, 2015): http://www.slideshare.net/tillrohrmann/streaming-data-flow-with-apache-flink-paris-flink-meetup-2015-54572718";>SlideShare @@ -219,7 +226,7 @@ Kostas Tzoumas: Apache Flink Overview (January 14th, 2015): http://www.slideshare.net/KostasTzoumas/apache-flink-api-runtime-and-project-roadmap";>SlideShare -2014 +2014 Kostas Tzoumas: Flink Internals (November 18th, 2014): http://www.slideshare.net/KostasTzoumas/flink-internals";>SlideShare
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/7491f2a5 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/7491f2a5 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/7491f2a5 Branch: refs/heads/asf-site Commit: 7491f2a53c696e9cdb701437519c1246d6c1decc Parents: 86d7ae0 Author: Greg Hogan Authored: Fri Oct 14 18:33:35 2016 + Committer: Greg Hogan Committed: Fri Oct 14 18:33:59 2016 + -- content/features.html | 14 +++--- 1 file changed, 7 insertions(+), 7 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/7491f2a5/content/features.html -- diff --git a/content/features.html b/content/features.html index 7fd2e4d..c419534 100644 --- a/content/features.html +++ b/content/features.html @@ -394,7 +394,7 @@ val texts: DataStream[String] = ... val counts = text - .flatMap { line => line.split("\\W+") } + .flatMap { line => line.split("\\W+") } .map { token => Word(token, 1) } .keyBy("word") .timeWindow(Time.seconds(5), Time.seconds(1)) @@ -422,13 +422,14 @@ case class Adjacency(id: Long, neighbors: Array[Long]) val result = initialRanks.iterate(30) { pages => - pages.join(adjacency).where("pageId").equalTo("pageId") { + pages.join(adjacency).where("pageId").equalTo("id") { -(page, adj, out : Collector[Page]) => { - out.collect(Page(page.id, 0.15 / numPages)) - +(page, adj, out: Collector[Page]) => { + out.collect(Page(page.pageId, 0.15 / numPages)) + + val nLen = adj.neighbors.length for (n <- adj.neighbors) { -out.collect(Page(n, 0.85*page.rank/adj.neighbors.length)) +out.collect(Page(n, 0.85 * page.rank / nLen)) } } } @@ -487,7 +488,6 @@ -
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/0c8713c2 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0c8713c2 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0c8713c2 Branch: refs/heads/asf-site Commit: 0c8713c21f9d68fe5c991b4e06391de6616fa3f4 Parents: 3f17658 Author: Tzu-Li (Gordon) Tai Authored: Tue Aug 30 12:16:16 2016 +0800 Committer: Tzu-Li (Gordon) Tai Committed: Tue Aug 30 12:16:16 2016 +0800 -- content/community.html | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/0c8713c2/content/community.html -- diff --git a/content/community.html b/content/community.html index 13fc760..3f06251 100644 --- a/content/community.html +++ b/content/community.html @@ -609,6 +609,12 @@ See Suneel Marthiâs http://www.slideshare.net/FlinkForward/suneel-mar Committer greg + +https://avatars1.githubusercontent.com/u/5284370?s=50"; /> +Tzu-Li (Gordon) Tai +Committer +tzulitai + You can reach committers directly at@apache.org. A list of all contributors can be found https://cwiki.apache.org/confluence/display/FLINK/List+of+contributors";>here.
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/a997d719 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/a997d719 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/a997d719 Branch: refs/heads/asf-site Commit: a997d71934b984046556429bbf7da846da8ccac8 Parents: e8b310c Author: Ufuk Celebi Authored: Thu Aug 11 09:27:52 2016 +0200 Committer: Ufuk Celebi Committed: Thu Aug 11 09:27:52 2016 +0200 -- content/downloads.html | 36 ++-- 1 file changed, 18 insertions(+), 18 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/a997d719/content/downloads.html -- diff --git a/content/downloads.html b/content/downloads.html index 3893975..13e5674 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -172,7 +172,7 @@ $( document ).ready(function() { - Latest stable release (v1.1.0) + Latest stable release (v1.1.1) Binaries Source @@ -183,9 +183,9 @@ $( document ).ready(function() { -Latest stable release (v1.1.0) +Latest stable release (v1.1.1) -Apache Flink 1.1.0 is our latest stable release. +Apache Flink 1.1.1 is our latest stable release. You donât have to install Hadoop @@ -204,32 +204,32 @@ pick the Hadoop 1 version. Hadoop 1.2.1 -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop1-scala_2.10.tgz"; class="ga-track" id="download-hadoop1">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop1-scala_2.10.tgz"; class="ga-track" id="download-hadoop1">Download Hadoop 2.3.0 -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop2-scala_2.10.tgz"; class="ga-track" id="download-hadoop2">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop2-scala_2.11.tgz"; class="ga-track" id="download-hadoop2_211">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop2-scala_2.10.tgz"; class="ga-track" id="download-hadoop2">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop2-scala_2.11.tgz"; class="ga-track" id="download-hadoop2_211">Download Hadoop 2.4.1 -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop24-scala_2.10.tgz"; class="ga-track" id="download-hadoop24">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop24-scala_2.11.tgz"; class="ga-track" id="download-hadoop24_211">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop24-scala_2.10.tgz"; class="ga-track" id="download-hadoop24">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop24-scala_2.11.tgz"; class="ga-track" id="download-hadoop24_211">Download Hadoop 2.6.0 -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop26-scala_2.10.tgz"; class="ga-track" id="download-hadoop26">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop26-scala_2.11.tgz"; class="ga-track" id="download-hadoop26_211">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop26-scala_2.10.tgz"; class="ga-track" id="download-hadoop26">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop26-scala_2.11.tgz"; class="ga-track" id="download-hadoop26_211">Download Hadoop 2.7.0 -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop27-scala_2.10.tgz"; class="ga-track" id="download-hadoop27">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop27-scala_2.10.tgz"; class="ga-track" id="download-hadoop27">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download @@ -240,8 +240,8 @@ pick the Hadoop 1 version. - http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-src.tgz"; class="list-group-item ga-track" id="download-source"> - Flink 1.1.0 Source Release + http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-src.tgz"; class="list-group-item ga-track" id="download-source"> + Flink 1.1.1 Source Release Review the source code or build Flink on your own, using this package @@ -253,23 +253,23 @@
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/b6f23140 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/b6f23140 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/b6f23140 Branch: refs/heads/asf-site Commit: b6f23140752b76e91bebbe6f26b852d697ed9b59 Parents: f036d89 Author: Ufuk Celebi Authored: Tue Aug 9 14:01:06 2016 +0200 Committer: Ufuk Celebi Committed: Tue Aug 9 14:01:06 2016 +0200 -- content/blog/feed.xml | 4 +++- content/blog/index.html| 2 +- content/news/2016/08/08/release-1.1.0.html | 2 ++ 3 files changed, 6 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/b6f23140/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index da3a9a0..6f02bb4 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -8,7 +8,9 @@ Announcing Apache Flink 1.1.0 -The Apache Flink community is pleased to announce the availability of Flink 1.1.0.
+Warning: The artifacts published on Maven central have a Hadoop dependency issue. No Hadoop 1 specific version (with version+ +1.1.0-hadoop1) was deployed and1.1.0artifacts have a dependency on Hadoop 1 instead of Hadoop 2. This will be fixed immediately and released as Flink1.1.1(published Maven artifacts are immutable). If you are using Flink with Hadoop 2, we recommend to wait until1.1.1is available before upgrading.The Apache Flink community is pleased to announce the availability of Flink 1.1.0.
This release is the first major release in the 1.X.X series of releases, which maintains API compatibility with 1.0.0. This means that your applications written against stable APIs of Flink 1.0.0 will compile and run with Flink 1.1.0. 95 contributors provided bug fixes, improvements, and new features such that in total more than 450 JIRA issues could be resolved. See the complete changelog for more details.
http://git-wip-us.apache.org/repos/asf/flink-web/blob/b6f23140/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index 7a6a02b..d3ee3e8 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -164,7 +164,7 @@ Announcing Apache Flink 1.1.0 08 Aug 2016 - The Apache Flink community is pleased to announce the availability of Flink 1.1.0. + Warning: The artifacts published on Maven central have a Hadoop dependency issue. No Hadoop 1 specific version (with version 1.1.0-hadoop1) was deployed and 1.1.0 artifacts have a dependency on Hadoop 1 instead of Hadoop 2. This will be fixed immediately and released as Flink 1.1.1 (published Maven artifacts are immutable). If you are using Flink with Hadoop 2, we recommend to wait until 1.1.1 is available before upgrading. http://git-wip-us.apache.org/repos/asf/flink-web/blob/b6f23140/content/news/2016/08/08/release-1.1.0.html -- diff --git a/content/news/2016/08/08/release-1.1.0.html b/content/news/2016/08/08/release-1.1.0.html index 49ef7ff..bfd314d 100644 --- a/content/news/2016/08/08/release-1.1.0.html +++ b/content/news/2016/08/08/release-1.1.0.html @@ -160,6 +160,8 @@ 08 Aug 2016 +Warning: The artifacts published on Maven central have a Hadoop dependency issue. No Hadoop 1 specific version (with version 1.1.0-hadoop1) was deployed and 1.1.0 artifacts have a dependency on Hadoop 1 instead of Hadoop 2. This will be fixed immediately and released as Flink 1.1.1 (published Maven artifacts are immutable). If you are using Flink with Hadoop 2, we recommend to wait until 1.1.1 is available before upgrading. + The Apache Flink community is pleased to announce the availability of Flink 1.1.0. This release is the first major release in the 1.X.X series of releases, which maintains API compatibility with 1.0.0. This means that your applications written against stable APIs of Flink 1.0.0 will compile and run with Flink 1.1.0. 95 contributors provided bug fixes, improvements, and new features such that in total more than 450 JIRA issues could be resolved. See the complete changelog for more details.
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/1f799729 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/1f799729 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/1f799729 Branch: refs/heads/asf-site Commit: 1f7997298f8d3895065f6b9002c9f030a97e9ce3 Parents: f1df969 Author: Ufuk Celebi Authored: Sun Aug 7 22:19:26 2016 +0200 Committer: Ufuk Celebi Committed: Sun Aug 7 22:19:26 2016 +0200 -- content/downloads.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/1f799729/content/downloads.html -- diff --git a/content/downloads.html b/content/downloads.html index 5f9af66..3893975 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -229,7 +229,7 @@ pick the Hadoop 1 version. Hadoop 2.7.0 http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop27-scala_2.10.tgz"; class="ga-track" id="download-hadoop27">Download -http://www.apache.org/dyn/closer.lua/flink/flink-1.0.3/flink-1.0.3-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download +http://www.apache.org/dyn/closer.lua/flink/flink-1.1.0/flink-1.1.0-bin-hadoop27-scala_2.11.tgz"; class="ga-track" id="download-hadoop27_211">Download
[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #27. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f7fd98e8 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/f7fd98e8 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/f7fd98e8 Branch: refs/heads/asf-site Commit: f7fd98e876a670baa593c124f6c54c25cebe3ebf Parents: 9e260a8 Author: Ufuk Celebi Authored: Wed Jul 27 23:34:19 2016 +0200 Committer: Ufuk Celebi Committed: Wed Jul 27 23:34:20 2016 +0200 -- content/img/ericsson-logo.png | Bin 0 -> 3199 bytes content/img/researchgate-logo.png | Bin 0 -> 10074 bytes content/poweredby.html| 62 +++-- 3 files changed, 36 insertions(+), 26 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/f7fd98e8/content/img/ericsson-logo.png -- diff --git a/content/img/ericsson-logo.png b/content/img/ericsson-logo.png new file mode 100644 index 000..bef24b6 Binary files /dev/null and b/content/img/ericsson-logo.png differ http://git-wip-us.apache.org/repos/asf/flink-web/blob/f7fd98e8/content/img/researchgate-logo.png -- diff --git a/content/img/researchgate-logo.png b/content/img/researchgate-logo.png new file mode 100644 index 000..12834e5 Binary files /dev/null and b/content/img/researchgate-logo.png differ http://git-wip-us.apache.org/repos/asf/flink-web/blob/f7fd98e8/content/poweredby.html -- diff --git a/content/poweredby.html b/content/poweredby.html index 39ebe75..a1f9ab6 100644 --- a/content/poweredby.html +++ b/content/poweredby.html @@ -175,50 +175,60 @@ - - + + - - + + - - + + + + + - - Alibaba, the world's largest retailer, built a Flink-based system (Blink) to optimize search rankings in real time. https://www.youtube.com/watch?v=_Nw8NTdIq9A"; target="_blank"> See Alibaba's talk from Hadoop Summit 2016 San Jose. + + Alibaba, the world's largest retailer, built a Flink-based system (Blink) to optimize search rankings in real time. https://www.youtube.com/watch?v=_Nw8NTdIq9A"; target="_blank"> See Alibaba's Blink overview from Hadoop Summit 2016 San Jose. + + + Bouygues Telecom uses Flink for real-time event processing over billions of Kafka messages per day. http://data-artisans.com/flink-at-bouygues-html/"; target="_blank"> Read about stream processing with Flink at Bouygues Telecom. - - Bouygues Telecom uses Flink for real-time event processing over billions of Kafka messages per day. http://data-artisans.com/flink-at-bouygues-html/"; target="_blank"> Read about stream processing at Bouygues. + + Capital One, a Fortune 500 financial services company, uses Flink to monitor real-time customer activity. http://www.slideshare.net/FlinkForward/flink-case-study-capital-one"; target="_blank"> See Capital One's case study slides from Flink Forward 2015. - - Capital One, a Fortune 500 financial services company, uses Flink for real-time customer activity monitoring. http://www.slideshare.net/FlinkForward/flink-case-study-capital-one"; target="_blank"> See Capital One's case study slides from Flink Forward 2015. + + Ericsson used Flink to build a real-time anomaly detector over large infrastructures using machine learning. https://www.oreilly.com/ideas/applying-the-kappa-architecture-in-the-telco-industry"; target="_blank"> Read a detailed overview of Ericsson's architecture on O'Reilly Ideas. - - + + - - + + - - + + + + + - - King, the creators of Candy Crush Saga, uses Flink to provide data science teams with real-time analytics. https://techblog.king.com/rbea-scalable-real-time-analytics-king/"; target="_blank"> Read about their implementation at the King Tech Blog. + + King, the creators of Candy Crush Saga, uses Flink to provide data science teams with real-time analytics. https://techblog.king.com/rbea-scalable-real-time-analytics-king/"; target="_blank"> Read about their Flink implementation at the King Tech Blog. - - Otto Group, the world's 2nd-largest online retailer, uses Flink for business intelligence stream processing. http://data-artisans.com/how-we-selected-apache-flink-at-otto-group/"; target="_blank"> Read about th
[2/2] flink-web git commit: Rebuild website
Rebuild website This closes #26. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/246d7627 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/246d7627 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/246d7627 Branch: refs/heads/asf-site Commit: 246d7627d773840fd1fefa19f1fee48c9f85d007 Parents: 68b46c0 Author: Ufuk Celebi Authored: Thu Jul 21 11:28:30 2016 +0200 Committer: Ufuk Celebi Committed: Thu Jul 21 11:28:36 2016 +0200 -- content/blog/index.html | 2 +- content/blog/page2/index.html | 2 +- content/blog/page3/index.html | 2 +- content/blog/page4/index.html | 2 +- .../release_1.0.0-changelog_known_issues.html | 2 +- content/community.html | 2 +- content/community.md.orig | 2 +- content/contribute-code.html| 2 +- content/contribute-documentation.html | 2 +- content/downloads.html | 2 +- content/faq.html| 2 +- content/features.html | 2 +- content/how-to-contribute.html | 2 +- content/improve-website.html| 2 +- content/index.html | 4 +- content/material.html | 2 +- content/news/2014/08/26/release-0.6.html| 2 +- content/news/2014/09/26/release-0.6.1.html | 2 +- content/news/2014/10/03/upcoming_events.html| 2 +- content/news/2014/11/04/release-0.7.0.html | 2 +- .../news/2014/11/18/hadoop-compatibility.html | 2 +- content/news/2015/01/06/december-in-flink.html | 2 +- content/news/2015/01/21/release-0.8.html| 2 +- content/news/2015/02/04/january-in-flink.html | 2 +- content/news/2015/02/09/streaming-example.html | 2 +- .../news/2015/03/02/february-2015-in-flink.html | 2 +- .../peeking-into-Apache-Flinks-Engine-Room.html | 2 +- content/news/2015/04/07/march-in-flink.html | 2 +- .../2015/04/13/release-0.9.0-milestone1.html| 2 +- .../05/11/Juggling-with-Bits-and-Bytes.html | 2 +- .../news/2015/05/14/Community-update-April.html | 2 +- .../announcing-apache-flink-0.9.0-release.html | 2 +- .../2015/08/24/introducing-flink-gelly.html | 2 +- content/news/2015/09/01/release-0.9.1.html | 2 +- content/news/2015/09/03/flink-forward.html | 2 +- content/news/2015/09/16/off-heap-memory.html| 2 +- content/news/2015/11/16/release-0.10.0.html | 2 +- content/news/2015/11/27/release-0.10.1.html | 2 +- .../news/2015/12/04/Introducing-windows.html| 2 +- .../news/2015/12/11/storm-compatibility.html| 2 +- content/news/2015/12/18/a-year-in-review.html | 2 +- content/news/2016/02/11/release-0.10.2.html | 2 +- content/news/2016/03/08/release-1.0.0.html | 2 +- content/news/2016/04/06/cep-monitoring.html | 2 +- content/news/2016/04/06/release-1.0.1.html | 2 +- .../news/2016/04/14/flink-forward-announce.html | 2 +- content/news/2016/04/22/release-1.0.2.html | 2 +- content/news/2016/05/11/release-1.0.3.html | 2 +- content/news/2016/05/24/stream-sql.html | 2 +- content/poweredby.html | 252 +++ content/privacy-policy.html | 2 +- content/production.html | 252 --- content/project.html| 2 +- content/slides.html | 2 +- 54 files changed, 305 insertions(+), 305 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/246d7627/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index 74dba26..35f85f5 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -118,7 +118,7 @@ Third Party Packages Source Code People -Powered by Flink +Powered by Flink http://git-wip-us.apache.org/repos/asf/flink-web/blob/246d7627/content/blog/page2/index.html -- diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html index 4d72fd3..685e3f9 100644 --- a/content/blog/page2/index.html +++ b/content/blog/page2/index.html @@ -118,7 +118,7 @@ Third Party Packages Source Code People -Powered by Flink +Powered by Flink http://git
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/2b259570 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/2b259570 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/2b259570 Branch: refs/heads/asf-site Commit: 2b2595704d1cdb7186b98e7526f756c0358d7680 Parents: 3b55226 Author: Ufuk Celebi Authored: Wed Jul 20 14:27:44 2016 +0200 Committer: Ufuk Celebi Committed: Wed Jul 20 14:27:44 2016 +0200 -- content/blog/index.html | 2 +- content/blog/page2/index.html | 2 +- content/blog/page3/index.html | 2 +- content/blog/page4/index.html | 2 +- .../release_1.0.0-changelog_known_issues.html | 2 +- content/community.html | 2 +- content/community.md.orig | 2 +- content/contribute-code.html| 2 +- content/contribute-documentation.html | 2 +- content/css/flink.css | 8 + content/downloads.html | 2 +- content/faq.html| 2 +- content/features.html | 2 +- content/how-to-contribute.html | 2 +- content/img/alibaba-logo.png| Bin 0 -> 22897 bytes content/img/bouygues-logo.jpg | Bin 0 -> 10810 bytes content/img/capital-one-logo.png| Bin 0 -> 32868 bytes content/img/king-logo.png | Bin 0 -> 42453 bytes content/img/otto-group-logo.jpg | Bin 0 -> 125443 bytes content/img/zalando-logo.png| Bin 0 -> 26407 bytes content/improve-website.html| 2 +- content/index.html | 6 +- content/material.html | 2 +- content/news/2014/08/26/release-0.6.html| 2 +- content/news/2014/09/26/release-0.6.1.html | 2 +- content/news/2014/10/03/upcoming_events.html| 2 +- content/news/2014/11/04/release-0.7.0.html | 2 +- .../news/2014/11/18/hadoop-compatibility.html | 2 +- content/news/2015/01/06/december-in-flink.html | 2 +- content/news/2015/01/21/release-0.8.html| 2 +- content/news/2015/02/04/january-in-flink.html | 2 +- content/news/2015/02/09/streaming-example.html | 2 +- .../news/2015/03/02/february-2015-in-flink.html | 2 +- .../peeking-into-Apache-Flinks-Engine-Room.html | 2 +- content/news/2015/04/07/march-in-flink.html | 2 +- .../2015/04/13/release-0.9.0-milestone1.html| 2 +- .../05/11/Juggling-with-Bits-and-Bytes.html | 2 +- .../news/2015/05/14/Community-update-April.html | 2 +- .../announcing-apache-flink-0.9.0-release.html | 2 +- .../2015/08/24/introducing-flink-gelly.html | 2 +- content/news/2015/09/01/release-0.9.1.html | 2 +- content/news/2015/09/03/flink-forward.html | 2 +- content/news/2015/09/16/off-heap-memory.html| 2 +- content/news/2015/11/16/release-0.10.0.html | 2 +- content/news/2015/11/27/release-0.10.1.html | 2 +- .../news/2015/12/04/Introducing-windows.html| 2 +- .../news/2015/12/11/storm-compatibility.html| 2 +- content/news/2015/12/18/a-year-in-review.html | 2 +- content/news/2016/02/11/release-0.10.2.html | 2 +- content/news/2016/03/08/release-1.0.0.html | 2 +- content/news/2016/04/06/cep-monitoring.html | 2 +- content/news/2016/04/06/release-1.0.1.html | 2 +- .../news/2016/04/14/flink-forward-announce.html | 2 +- content/news/2016/04/22/release-1.0.2.html | 2 +- content/news/2016/05/11/release-1.0.3.html | 2 +- content/news/2016/05/24/stream-sql.html | 2 +- content/privacy-policy.html | 2 +- content/production.html | 252 +++ content/project.html| 2 +- content/slides.html | 2 +- 60 files changed, 314 insertions(+), 54 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/2b259570/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index e240bbd..74dba26 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -118,7 +118,7 @@ Third Party Packages Source Code People -https://cwiki.apache.org/confluence/display/FLINK/Powered+by+Flink";> Powered by Flink +Powered by Flink http://git-wip-us.apache.org/repos/asf/flink-web/blob/2b259570/content/blog/page2/index.html --
[2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f439e228 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/f439e228 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/f439e228 Branch: refs/heads/asf-site Commit: f439e2281c3fe88270c21604a56bbb4863fc61f5 Parents: 0603fed Author: Greg Hogan Authored: Mon Mar 14 22:54:52 2016 -0400 Committer: Greg Hogan Committed: Mon Mar 14 22:54:52 2016 -0400 -- content/community.html | 6 ++ 1 file changed, 6 insertions(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/f439e228/content/community.html -- diff --git a/content/community.html b/content/community.html index 9746a5c..1bdbf26 100644 --- a/content/community.html +++ b/content/community.html @@ -594,6 +594,12 @@ See Suneel Marthiâs http://www.slideshare.net/FlinkForward/suneel-mar Committer chengxiang + +https://avatars1.githubusercontent.com/u/569655?s=50"; /> +Greg Hogan +Committer +greg + You can reach committers directly at@apache.org. A list of all contributors can be found https://cwiki.apache.org/confluence/display/FLINK/List+of+contributors";>here.
[2/2] flink-web git commit: rebuild website
rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/0e401f75 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0e401f75 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0e401f75 Branch: refs/heads/asf-site Commit: 0e401f755dd0f74c4214f5ce4a23893abea52324 Parents: 31f3a04 Author: Maximilian Michels Authored: Fri Nov 20 10:36:21 2015 +0100 Committer: Maximilian Michels Committed: Fri Nov 20 10:36:21 2015 +0100 -- content/downloads.html | 7 ++- 1 file changed, 6 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/0e401f75/content/downloads.html -- diff --git a/content/downloads.html b/content/downloads.html index 5559b21..f6ab963 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -250,6 +250,11 @@ pick the Hadoop 1 version.+ org.apache.flink +flink-streaming-java +0.10.0 ++ @@ -258,7 +263,7 @@ pick the Hadoop 1 version. Hadoop 1: If you want to interact with Hadoop 1, use 0.10.0-hadoop1 as the version. - Scala API: To use the Scala API, replace the flink-java artifact id with flink-scala. + Scala API: To use the Scala API, replace the flink-java artifact id with flink-scala and flink-streaming-java with flink-streaming-scala. All releasesorg.apache.flink flink-clients 0.10.0
[2/2] flink-web git commit: rebuild website
rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/4e2b2396 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/4e2b2396 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/4e2b2396 Branch: refs/heads/asf-site Commit: 4e2b23965480cc69573037eb2d106a0217a2ac2c Parents: f82224b Author: Fabian Hueske Authored: Mon Nov 16 14:34:22 2015 +0100 Committer: Fabian Hueske Committed: Mon Nov 16 14:34:22 2015 +0100 -- content/blog/feed.xml | 175 ++ content/blog/index.html | 34 +- content/blog/page2/index.html | 37 +- content/blog/page3/index.html | 45 +-- content/blog/page4/index.html | 29 ++ content/img/blog/new-dashboard-screenshot.png | Bin 0 -> 570241 bytes content/index.html| 8 +- content/news/2015/11/16/release-0.10.0.html | 371 + 8 files changed, 649 insertions(+), 50 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/4e2b2396/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index b3b8d04..135033f 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,181 @@ http://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> +Announcing Apache Flink 0.10.0 +The Apache Flink community is pleased to announce the availability of the 0.10.0 release. The community put significant effort into improving and extending Apache Flink since the last release, focusing on data stream processing and operational features. About 80 contributors provided bug fixes, improvements, and new features such that in total more than 400 JIRA issues could be resolved.
+ +For Flink 0.10.0, the focus of the community was to graduate the DataStream API from beta and to evolve Apache Flink into a production-ready stream data processor with a competitive feature set. These efforts resulted in support for event-time and out-of-order streams, exactly-once guarantees in the case of failures, a very flexible windowing mechanism, sophisticated operator state management, and a highly-available cluster operation mode. Flink 0.10.0 also brings a new monitoring dashboard with real-time system and job monitoring capabilities. Both batch and streaming modes of Flink benefit from the new high availability and improved monitoring features. Needless to say that Flink 0.10.0 includes many more features, improvements, and bug fixes.
+ +We encourage everyone to download the release and check out the documentation. Feedback through the Flink mailing lists is, as always, very welcome!
+ +New Features
+ +Event-time Stream Processing
+ +Many stream processing applications consume data from sources that produce events with associated timestamps such as sensor or user-interaction events. Very often, events have to be collected from several sources such that it is usually not guaranteed that events arrive in the exact order of their timestamps at the stream processor. Consequently, stream processors must take out-of-order elements into account in order to produce results which are correct and consistent with respect to the timestamps of the events. With release 0.10.0, Apache Flink supports event-time processing as well as ingestion-time and processing-time processing. See FLINK-2674; for details.
+ +Stateful Stream Processing
+ +Operators that maintain and update state are a common pattern in many stream processing applications. Since streaming applications tend to run for a very long time, operator state can become very valuable and impossible to recompute. In order to enable fault-tolerance, operator state must be backed up to persistent storage in regular intervals. Flink 0.10.0 offers flexible interfaces to define, update, and query operator state and hooks to connect various state backends.
+ +Highly-available Cluster Operations
+ +Stream processing applications may be live for months. Therefore, a production-ready stream processor must be highly-available and continue to process data even in the face of failures. With release 0.10.0, Flink supports high availability modes for standalone cluster and [2/2] flink-web git commit: Rebuild website
Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/57ea2465 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/57ea2465 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/57ea2465 Branch: refs/heads/asf-site Commit: 57ea2465e93ba8f353196312070110f60a02149f Parents: 5f29a0e Author: Maximilian Michels Authored: Thu Oct 8 14:10:12 2015 +0200 Committer: Maximilian Michels Committed: Thu Oct 8 14:10:12 2015 +0200 -- content/downloads.html | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/57ea2465/content/downloads.html -- diff --git a/content/downloads.html b/content/downloads.html index c27193e..48aae69 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -236,6 +236,7 @@ $( document ).ready(function() { All releases + Flink 0.9.0 (http://archive.apache.org/dist/flink/flink-0.9.0/";>Jars, http://ci.apache.org/projects/flink/flink-docs-release-0.9/";>Docs, http://ci.apache.org/projects/flink/flink-docs-release-0.9/api/java";>Javadocs, http://ci.apache.org/projects/flink/flink-docs-release-0.9/api/scala/index.html";>ScalaDocs) Flink 0.9.0-milestone-1 (http://archive.apache.org/dist/flink/flink-0.9.0-milestone-1/";>Jars, http://ci.apache.org/projects/flink/flink-docs-release-0.9/";>Docs, http://ci.apache.org/projects/flink/flink-docs-release-0.9/api/java";>Javadocs, http://ci.apache.org/projects/flink/flink-docs-release-0.9/api/scala/index.html";>ScalaDocs) Flink 0.8.1 (http://archive.apache.org/dist/flink/flink-0.8.1/";>Jars, http://ci.apache.org/projects/flink/flink-docs-release-0.8.1/";>Docs, http://ci.apache.org/projects/flink/flink-docs-release-0.8.1/api/java";>Javadocs, http://ci.apache.org/projects/flink/flink-docs-release-0.8.1/api/scala/index.html";>ScalaDocs) Flink 0.8.0 (http://archive.apache.org/dist/flink/flink-0.8.0/";>Jars, http://ci.apache.org/projects/flink/flink-docs-release-0.8.0/";>Docs, http://ci.apache.org/projects/flink/flink-docs-release-0.8.0/api/java";>Javadocs, http://ci.apache.org/projects/flink/flink-docs-release-0.8.0/api/scala/index.html";>ScalaDocs)
