You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2016/04/14 15:12:06 UTC
[4/6] flink-web git commit: Rebuild Website
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/blog/index.html
----------------------------------------------------------------------
diff --git a/content/blog/index.html b/content/blog/index.html
index 4c083bc..23b36d7 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -161,6 +161,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></h2>
+ <p>14 Apr 2016 by Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>)</p>
+
+ <p><p>We are happy to announce that the call for submissions for Flink Forward 2016 is now open! The conference will take place September 12-14, 2016 in Berlin, Germany, bringing together the open source stream processing community. Most Apache Flink committers will attend the conference, making it the ideal venue to learn more about the project and its roadmap and connect with the community.</p>
+
+</p>
+
+ <p><a href="/news/2016/04/14/flink-forward-announce.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></h2>
<p>06 Apr 2016 by Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p>
@@ -188,7 +201,7 @@
<h2 class="blog-title"><a href="/news/2016/03/08/release-1.0.0.html">Announcing Apache Flink 1.0.0</a></h2>
<p>08 Mar 2016</p>
- <p><p>The Apache Flink community is pleased to announce the availability of the 1.0.0 release. The community put significant effort into improving and extending Apache Flink since the last release, focusing on improving the experience of writing and executing data stream processing pipelines in production. </p>
+ <p><p>The Apache Flink community is pleased to announce the availability of the 1.0.0 release. The community put significant effort into improving and extending Apache Flink since the last release, focusing on improving the experience of writing and executing data stream processing pipelines in production.</p>
</p>
@@ -270,18 +283,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/09/16/off-heap-memory.html">Off-heap Memory in Apache Flink and the curious JIT compiler</a></h2>
- <p>16 Sep 2015 by Stephan Ewen (<a href="https://twitter.com/stephanewen">@stephanewen</a>)</p>
-
- <p><p>Running data-intensive code in the JVM and making it well-behaved is tricky. Systems that put billions of data objects naively onto the JVM heap face unpredictable OutOfMemoryErrors and Garbage Collection stalls. Of course, you still want to to keep your data in memory as much as possible, for speed and responsiveness of the processing applications. In that context, "off-heap" has become almost something like a magic word to solve these problems.</p>
-<p>In this blog post, we will look at how Flink exploits off-heap memory. The feature is part of the upcoming release, but you can try it out with the latest nightly builds. We will also give a few interesting insights into the behavior for Java's JIT compiler for highly optimized methods and loops.</p></p>
-
- <p><a href="/news/2015/09/16/off-heap-memory.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -314,6 +315,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/blog/page2/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index cd7b9c8..612b5ac 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -161,6 +161,18 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/09/16/off-heap-memory.html">Off-heap Memory in Apache Flink and the curious JIT compiler</a></h2>
+ <p>16 Sep 2015 by Stephan Ewen (<a href="https://twitter.com/stephanewen">@stephanewen</a>)</p>
+
+ <p><p>Running data-intensive code in the JVM and making it well-behaved is tricky. Systems that put billions of data objects naively onto the JVM heap face unpredictable OutOfMemoryErrors and Garbage Collection stalls. Of course, you still want to to keep your data in memory as much as possible, for speed and responsiveness of the processing applications. In that context, "off-heap" has become almost something like a magic word to solve these problems.</p>
+<p>In this blog post, we will look at how Flink exploits off-heap memory. The feature is part of the upcoming release, but you can try it out with the latest nightly builds. We will also give a few interesting insights into the behavior for Java's JIT compiler for highly optimized methods and loops.</p></p>
+
+ <p><a href="/news/2015/09/16/off-heap-memory.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/09/03/flink-forward.html">Announcing Flink Forward 2015</a></h2>
<p>03 Sep 2015</p>
@@ -284,22 +296,6 @@ release is a preview release that contains known issues.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2>
- <p>02 Mar 2015</p>
-
- <p><p>February might be the shortest month of the year, but this does not
-mean that the Flink community has not been busy adding features to the
-system and fixing bugs. Here’s a rundown of the activity in the Flink
-community last month.</p>
-
-</p>
-
- <p><a href="/news/2015/03/02/february-2015-in-flink.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -332,6 +328,16 @@ community last month.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/blog/page3/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index ff9d4aa..421831d 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -161,6 +161,22 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2>
+ <p>02 Mar 2015</p>
+
+ <p><p>February might be the shortest month of the year, but this does not
+mean that the Flink community has not been busy adding features to the
+system and fixing bugs. Here’s a rundown of the activity in the Flink
+community last month.</p>
+
+</p>
+
+ <p><a href="/news/2015/03/02/february-2015-in-flink.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/02/09/streaming-example.html">Introducing Flink Streaming</a></h2>
<p>09 Feb 2015</p>
@@ -316,6 +332,16 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/blog/release_1.0.0-changelog_known_issues.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.0.0-changelog_known_issues.html b/content/blog/release_1.0.0-changelog_known_issues.html
index 6b312e0..e01a722 100644
--- a/content/blog/release_1.0.0-changelog_known_issues.html
+++ b/content/blog/release_1.0.0-changelog_known_issues.html
@@ -159,16 +159,16 @@
</div>
<ul id="markdown-toc">
- <li><a href="#changelog">Changelog</a> <ul>
- <li><a href="#sub-task">Sub-task</a></li>
- <li><a href="#bug">Bug</a></li>
- <li><a href="#improvement">Improvement</a></li>
- <li><a href="#task">Task</a></li>
- <li><a href="#test">Test</a></li>
- <li><a href="#wish">Wish</a></li>
+ <li><a href="#changelog" id="markdown-toc-changelog">Changelog</a> <ul>
+ <li><a href="#sub-task" id="markdown-toc-sub-task">Sub-task</a></li>
+ <li><a href="#bug" id="markdown-toc-bug">Bug</a></li>
+ <li><a href="#improvement" id="markdown-toc-improvement">Improvement</a></li>
+ <li><a href="#task" id="markdown-toc-task">Task</a></li>
+ <li><a href="#test" id="markdown-toc-test">Test</a></li>
+ <li><a href="#wish" id="markdown-toc-wish">Wish</a></li>
</ul>
</li>
- <li><a href="#known-issues">Known Issues</a></li>
+ <li><a href="#known-issues" id="markdown-toc-known-issues">Known Issues</a></li>
</ul>
<h2 id="changelog">Changelog</h2>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/community.html
----------------------------------------------------------------------
diff --git a/content/community.html b/content/community.html
index 809a52a..554aa36 100644
--- a/content/community.html
+++ b/content/community.html
@@ -162,31 +162,31 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#mailing-lists">Mailing Lists</a></li>
- <li><a href="#irc">IRC</a></li>
- <li><a href="#stack-overflow">Stack Overflow</a></li>
- <li><a href="#issue-tracker">Issue Tracker</a></li>
- <li><a href="#source-code">Source Code</a> <ul>
- <li><a href="#main-source-repositories">Main source repositories</a></li>
- <li><a href="#website-repositories">Website repositories</a></li>
+ <li><a href="#mailing-lists" id="markdown-toc-mailing-lists">Mailing Lists</a></li>
+ <li><a href="#irc" id="markdown-toc-irc">IRC</a></li>
+ <li><a href="#stack-overflow" id="markdown-toc-stack-overflow">Stack Overflow</a></li>
+ <li><a href="#issue-tracker" id="markdown-toc-issue-tracker">Issue Tracker</a></li>
+ <li><a href="#source-code" id="markdown-toc-source-code">Source Code</a> <ul>
+ <li><a href="#main-source-repositories" id="markdown-toc-main-source-repositories">Main source repositories</a></li>
+ <li><a href="#website-repositories" id="markdown-toc-website-repositories">Website repositories</a></li>
</ul>
</li>
- <li><a href="#third-party-packages">Third party packages</a> <ul>
- <li><a href="#apache-zeppelin">Apache Zeppelin</a></li>
- <li><a href="#apache-mahout">Apache Mahout</a></li>
- <li><a href="#cascading">Cascading</a></li>
- <li><a href="#google-dataflow">Google Dataflow</a></li>
- <li><a href="#gradoop">GRADOOP</a></li>
- <li><a href="#bigpetstore">BigPetStore</a></li>
- <li><a href="#fastr">FastR</a></li>
- <li><a href="#apache-samoa">Apache SAMOA</a></li>
- <li><a href="#python-examples-on-flink">Python Examples on Flink</a></li>
- <li><a href="#wordcount-example-in-clojure">WordCount Example in Clojure</a></li>
- <li><a href="#anomaly-detection-and-prediction-in-flink">Anomaly Detection and Prediction in Flink</a></li>
+ <li><a href="#third-party-packages" id="markdown-toc-third-party-packages">Third party packages</a> <ul>
+ <li><a href="#apache-zeppelin" id="markdown-toc-apache-zeppelin">Apache Zeppelin</a></li>
+ <li><a href="#apache-mahout" id="markdown-toc-apache-mahout">Apache Mahout</a></li>
+ <li><a href="#cascading" id="markdown-toc-cascading">Cascading</a></li>
+ <li><a href="#google-dataflow" id="markdown-toc-google-dataflow">Google Dataflow</a></li>
+ <li><a href="#gradoop" id="markdown-toc-gradoop">GRADOOP</a></li>
+ <li><a href="#bigpetstore" id="markdown-toc-bigpetstore">BigPetStore</a></li>
+ <li><a href="#fastr" id="markdown-toc-fastr">FastR</a></li>
+ <li><a href="#apache-samoa" id="markdown-toc-apache-samoa">Apache SAMOA</a></li>
+ <li><a href="#python-examples-on-flink" id="markdown-toc-python-examples-on-flink">Python Examples on Flink</a></li>
+ <li><a href="#wordcount-example-in-clojure" id="markdown-toc-wordcount-example-in-clojure">WordCount Example in Clojure</a></li>
+ <li><a href="#anomaly-detection-and-prediction-in-flink" id="markdown-toc-anomaly-detection-and-prediction-in-flink">Anomaly Detection and Prediction in Flink</a></li>
</ul>
</li>
- <li><a href="#people">People</a> <ul>
- <li><a href="#former-mentors">Former mentors</a></li>
+ <li><a href="#people" id="markdown-toc-people">People</a> <ul>
+ <li><a href="#former-mentors" id="markdown-toc-former-mentors">Former mentors</a></li>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/contribute-code.html
----------------------------------------------------------------------
diff --git a/content/contribute-code.html b/content/contribute-code.html
index 75a2cc3..f4df7b8 100644
--- a/content/contribute-code.html
+++ b/content/contribute-code.html
@@ -166,22 +166,22 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#code-contribution-process">Code Contribution Process</a> <ul>
- <li><a href="#before-you-start-coding">Before you start coding…</a></li>
- <li><a href="#while-coding">While coding…</a></li>
- <li><a href="#verifying-the-compliance-of-your-code">Verifying the compliance of your code</a></li>
- <li><a href="#preparing-and-submitting-your-contribution">Preparing and submitting your contribution</a></li>
+ <li><a href="#code-contribution-process" id="markdown-toc-code-contribution-process">Code Contribution Process</a> <ul>
+ <li><a href="#before-you-start-coding" id="markdown-toc-before-you-start-coding">Before you start coding…</a></li>
+ <li><a href="#while-coding" id="markdown-toc-while-coding">While coding…</a></li>
+ <li><a href="#verifying-the-compliance-of-your-code" id="markdown-toc-verifying-the-compliance-of-your-code">Verifying the compliance of your code</a></li>
+ <li><a href="#preparing-and-submitting-your-contribution" id="markdown-toc-preparing-and-submitting-your-contribution">Preparing and submitting your contribution</a></li>
</ul>
</li>
- <li><a href="#coding-guidelines">Coding guidelines</a></li>
- <li><a href="#code-style">Code style</a></li>
- <li><a href="#best-practices">Best practices</a></li>
- <li><a href="#setup-a-development-environment">Setup a development environment</a> <ul>
- <li><a href="#requirements-for-developing-and-building-flink">Requirements for developing and building Flink</a></li>
+ <li><a href="#coding-guidelines" id="markdown-toc-coding-guidelines">Coding guidelines</a></li>
+ <li><a href="#code-style" id="markdown-toc-code-style">Code style</a></li>
+ <li><a href="#best-practices" id="markdown-toc-best-practices">Best practices</a></li>
+ <li><a href="#setup-a-development-environment" id="markdown-toc-setup-a-development-environment">Setup a development environment</a> <ul>
+ <li><a href="#requirements-for-developing-and-building-flink" id="markdown-toc-requirements-for-developing-and-building-flink">Requirements for developing and building Flink</a></li>
</ul>
</li>
- <li><a href="#how-to-use-git-as-a-committer">How to use Git as a committer</a></li>
- <li><a href="#snapshots-nightly-builds">Snapshots (Nightly Builds)</a></li>
+ <li><a href="#how-to-use-git-as-a-committer" id="markdown-toc-how-to-use-git-as-a-committer">How to use Git as a committer</a></li>
+ <li><a href="#snapshots-nightly-builds" id="markdown-toc-snapshots-nightly-builds">Snapshots (Nightly Builds)</a></li>
</ul>
</div>
@@ -213,7 +213,7 @@
<li>Take any discussion or requirement that is recorded in the JIRA issue into account.</li>
<li>Follow the design document (if a design document is required) as close as possible. Please update the design document and seek consensus, if your implementation deviates too much from the solution proposed by the design document. Minor variations are OK but should be pointed out when the contribution is submitted.</li>
<li>Closely follow the <a href="/contribute-code.html#coding-guidelines">coding guidelines</a> and the <a href="/contribute-code.html#code-style">code style</a>.</li>
- <li>Do not mix unrelated issues into one contribution. </li>
+ <li>Do not mix unrelated issues into one contribution.</li>
</ul>
<p><strong>Please feel free to ask questions at any time.</strong> Either send a mail to the <a href="/community.html#mailing-lists">dev mailing list</a> or comment on the JIRA issue.</p>
@@ -231,7 +231,7 @@
<li>Making sure no unrelated or unnecessary reformatting changes are included.</li>
</ul>
-<p>You can build the code, run the tests, and check (parts of) the code style by calling </p>
+<p>You can build the code, run the tests, and check (parts of) the code style by calling</p>
<div class="highlight"><pre><code>mvn clean verify
</code></pre></div>
@@ -417,7 +417,7 @@ we found it to be the version that works most robustly for a complex project lik
Open “Window” -> “Preferences” -> “Scala” -> “Compiler” -> “Advanced” and put into the “Xplugin” field the path to
the <em>macroparadise</em> jar file (typically “/home/<em>-your-user-</em>/.m2/repository/org/scalamacros/paradise_2.10.4/2.0.1/paradise_2.10.4-2.0.1.jar”).
Note: If you do not have the jar file, you probably did not run the command line build.</li>
- <li>Import the Flink Maven projects (“File” -> “Import” -> “Maven” -> “Existing Maven Projects”) </li>
+ <li>Import the Flink Maven projects (“File” -> “Import” -> “Maven” -> “Existing Maven Projects”)</li>
<li>During the import, Eclipse will ask to automatically install additional Maven build helper plugins.</li>
<li>Close the “flink-java8” project. Since Eclipse Kepler does not support Java 8, you cannot develop this project.</li>
</ol>
@@ -435,7 +435,7 @@ Note: If you do not have the jar file, you probably did not run the command line
<p>This will build Flink and run all tests. Flink is now installed in <code>build-target</code>.</p>
-<p>To build Flink without executing the tests you can call </p>
+<p>To build Flink without executing the tests you can call</p>
<div class="highlight"><pre><code>mvn -DskipTests clean package
</code></pre></div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/contribute-documentation.html
----------------------------------------------------------------------
diff --git a/content/contribute-documentation.html b/content/contribute-documentation.html
index aa67550..1912178 100644
--- a/content/contribute-documentation.html
+++ b/content/contribute-documentation.html
@@ -162,17 +162,17 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#obtain-the-documentation-sources">Obtain the documentation sources</a></li>
- <li><a href="#before-you-start-working-on-the-documentation-">Before you start working on the documentation …</a></li>
- <li><a href="#update-or-extend-the-documentation">Update or extend the documentation</a></li>
- <li><a href="#submit-your-contribution">Submit your contribution</a></li>
+ <li><a href="#obtain-the-documentation-sources" id="markdown-toc-obtain-the-documentation-sources">Obtain the documentation sources</a></li>
+ <li><a href="#before-you-start-working-on-the-documentation-" id="markdown-toc-before-you-start-working-on-the-documentation-">Before you start working on the documentation …</a></li>
+ <li><a href="#update-or-extend-the-documentation" id="markdown-toc-update-or-extend-the-documentation">Update or extend the documentation</a></li>
+ <li><a href="#submit-your-contribution" id="markdown-toc-submit-your-contribution">Submit your contribution</a></li>
</ul>
</div>
<h2 id="obtain-the-documentation-sources">Obtain the documentation sources</h2>
-<p>Apache Flink’s documentation is maintained in the same <a href="http://git-scm.com/">git</a> repository as the code base. This is done to ensure that code and documentation can be easily kept in sync. </p>
+<p>Apache Flink’s documentation is maintained in the same <a href="http://git-scm.com/">git</a> repository as the code base. This is done to ensure that code and documentation can be easily kept in sync.</p>
<p>The easiest way to contribute documentation is to fork <a href="https://github.com/apache/flink">Flink’s mirrored repository on Github</a> into your own Github account by clicking on the fork button at the top right. If you have no Github account, you can create one for free.</p>
@@ -185,7 +185,7 @@
<h2 id="before-you-start-working-on-the-documentation-">Before you start working on the documentation …</h2>
-<p>… please make sure there exists a <a href="https://issues.apache.org/jira/browse/FLINK">JIRA</a> issue that corresponds to your contribution. We require all documentation changes to refer to a JIRA issue, except for trivial fixes such as typos. </p>
+<p>… please make sure there exists a <a href="https://issues.apache.org/jira/browse/FLINK">JIRA</a> issue that corresponds to your contribution. We require all documentation changes to refer to a JIRA issue, except for trivial fixes such as typos.</p>
<h2 id="update-or-extend-the-documentation">Update or extend the documentation</h2>
@@ -209,7 +209,7 @@
<ol>
<li>
- <p>Commit your changes to your local git repository. The commit message should point to the corresponding JIRA issue by starting with <code>[FLINK-XXXX]</code>. </p>
+ <p>Commit your changes to your local git repository. The commit message should point to the corresponding JIRA issue by starting with <code>[FLINK-XXXX]</code>.</p>
</li>
<li>
<p>Push your committed contribution to your fork of the Flink repository at Github.</p>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/downloads.html
----------------------------------------------------------------------
diff --git a/content/downloads.html b/content/downloads.html
index dcb66a1..7ac8244 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -172,13 +172,13 @@ $( document ).ready(function() {
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#latest-stable-release-v101">Latest stable release (v1.0.1)</a> <ul>
- <li><a href="#binaries">Binaries</a></li>
- <li><a href="#source">Source</a></li>
+ <li><a href="#latest-stable-release-v101" id="markdown-toc-latest-stable-release-v101">Latest stable release (v1.0.1)</a> <ul>
+ <li><a href="#binaries" id="markdown-toc-binaries">Binaries</a></li>
+ <li><a href="#source" id="markdown-toc-source">Source</a></li>
</ul>
</li>
- <li><a href="#maven-dependencies">Maven Dependencies</a></li>
- <li><a href="#all-releases">All releases</a></li>
+ <li><a href="#maven-dependencies" id="markdown-toc-maven-dependencies">Maven Dependencies</a></li>
+ <li><a href="#all-releases" id="markdown-toc-all-releases">All releases</a></li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/faq.html
----------------------------------------------------------------------
diff --git a/content/faq.html b/content/faq.html
index 839e398..8fea89c 100644
--- a/content/faq.html
+++ b/content/faq.html
@@ -181,41 +181,41 @@ under the License.
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#general">General</a> <ul>
- <li><a href="#is-flink-a-hadoop-project">Is Flink a Hadoop Project?</a></li>
- <li><a href="#do-i-have-to-install-apache-hadoop-to-use-flink">Do I have to install Apache Hadoop to use Flink?</a></li>
+ <li><a href="#general" id="markdown-toc-general">General</a> <ul>
+ <li><a href="#is-flink-a-hadoop-project" id="markdown-toc-is-flink-a-hadoop-project">Is Flink a Hadoop Project?</a></li>
+ <li><a href="#do-i-have-to-install-apache-hadoop-to-use-flink" id="markdown-toc-do-i-have-to-install-apache-hadoop-to-use-flink">Do I have to install Apache Hadoop to use Flink?</a></li>
</ul>
</li>
- <li><a href="#usage">Usage</a> <ul>
- <li><a href="#how-do-i-assess-the-progress-of-a-flink-program">How do I assess the progress of a Flink program?</a></li>
- <li><a href="#how-can-i-figure-out-why-a-program-failed">How can I figure out why a program failed?</a></li>
- <li><a href="#how-do-i-debug-flink-programs">How do I debug Flink programs?</a></li>
- <li><a href="#what-is-the-parallelism-how-do-i-set-it">What is the parallelism? How do I set it?</a></li>
+ <li><a href="#usage" id="markdown-toc-usage">Usage</a> <ul>
+ <li><a href="#how-do-i-assess-the-progress-of-a-flink-program" id="markdown-toc-how-do-i-assess-the-progress-of-a-flink-program">How do I assess the progress of a Flink program?</a></li>
+ <li><a href="#how-can-i-figure-out-why-a-program-failed" id="markdown-toc-how-can-i-figure-out-why-a-program-failed">How can I figure out why a program failed?</a></li>
+ <li><a href="#how-do-i-debug-flink-programs" id="markdown-toc-how-do-i-debug-flink-programs">How do I debug Flink programs?</a></li>
+ <li><a href="#what-is-the-parallelism-how-do-i-set-it" id="markdown-toc-what-is-the-parallelism-how-do-i-set-it">What is the parallelism? How do I set it?</a></li>
</ul>
</li>
- <li><a href="#errors">Errors</a> <ul>
- <li><a href="#why-am-i-getting-a-nonserializableexception-">Why am I getting a “NonSerializableException” ?</a></li>
- <li><a href="#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters">In Scala API, I get an error about implicit values and evidence parameters</a></li>
- <li><a href="#i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this">I get an error message saying that not enough buffers are available. How do I fix this?</a></li>
- <li><a href="#my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause">My job fails early with a java.io.EOFException. What could be the cause?</a></li>
- <li><a href="#my-job-fails-with-various-exceptions-from-the-hdfshadoop-code-what-can-i-do">My job fails with various exceptions from the HDFS/Hadoop code. What can I do?</a></li>
- <li><a href="#in-eclipse-i-get-compilation-errors-in-the-scala-projects">In Eclipse, I get compilation errors in the Scala projects</a></li>
- <li><a href="#my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types">My program does not compute the correct result. Why are my custom key types</a></li>
- <li><a href="#i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong">I get a java.lang.InstantiationException for my data type, what is wrong?</a></li>
- <li><a href="#i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do">I can’t stop Flink with the provided stop-scripts. What can I do?</a></li>
- <li><a href="#i-got-an-outofmemoryexception-what-can-i-do">I got an OutOfMemoryException. What can I do?</a></li>
- <li><a href="#why-do-the-taskmanager-log-files-become-so-huge">Why do the TaskManager log files become so huge?</a></li>
- <li><a href="#the-slot-allocated-for-my-task-manager-has-been-released-what-should-i-do">The slot allocated for my task manager has been released. What should I do?</a></li>
+ <li><a href="#errors" id="markdown-toc-errors">Errors</a> <ul>
+ <li><a href="#why-am-i-getting-a-nonserializableexception-" id="markdown-toc-why-am-i-getting-a-nonserializableexception-">Why am I getting a “NonSerializableException” ?</a></li>
+ <li><a href="#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters" id="markdown-toc-in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters">In Scala API, I get an error about implicit values and evidence parameters</a></li>
+ <li><a href="#i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this" id="markdown-toc-i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this">I get an error message saying that not enough buffers are available. How do I fix this?</a></li>
+ <li><a href="#my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause" id="markdown-toc-my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause">My job fails early with a java.io.EOFException. What could be the cause?</a></li>
+ <li><a href="#my-job-fails-with-various-exceptions-from-the-hdfshadoop-code-what-can-i-do" id="markdown-toc-my-job-fails-with-various-exceptions-from-the-hdfshadoop-code-what-can-i-do">My job fails with various exceptions from the HDFS/Hadoop code. What can I do?</a></li>
+ <li><a href="#in-eclipse-i-get-compilation-errors-in-the-scala-projects" id="markdown-toc-in-eclipse-i-get-compilation-errors-in-the-scala-projects">In Eclipse, I get compilation errors in the Scala projects</a></li>
+ <li><a href="#my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types" id="markdown-toc-my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types">My program does not compute the correct result. Why are my custom key types</a></li>
+ <li><a href="#i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong" id="markdown-toc-i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong">I get a java.lang.InstantiationException for my data type, what is wrong?</a></li>
+ <li><a href="#i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do" id="markdown-toc-i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do">I can’t stop Flink with the provided stop-scripts. What can I do?</a></li>
+ <li><a href="#i-got-an-outofmemoryexception-what-can-i-do" id="markdown-toc-i-got-an-outofmemoryexception-what-can-i-do">I got an OutOfMemoryException. What can I do?</a></li>
+ <li><a href="#why-do-the-taskmanager-log-files-become-so-huge" id="markdown-toc-why-do-the-taskmanager-log-files-become-so-huge">Why do the TaskManager log files become so huge?</a></li>
+ <li><a href="#the-slot-allocated-for-my-task-manager-has-been-released-what-should-i-do" id="markdown-toc-the-slot-allocated-for-my-task-manager-has-been-released-what-should-i-do">The slot allocated for my task manager has been released. What should I do?</a></li>
</ul>
</li>
- <li><a href="#yarn-deployment">YARN Deployment</a> <ul>
- <li><a href="#the-yarn-session-runs-only-for-a-few-seconds">The YARN session runs only for a few seconds</a></li>
- <li><a href="#the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup">The YARN session crashes with a HDFS permission exception during startup</a></li>
+ <li><a href="#yarn-deployment" id="markdown-toc-yarn-deployment">YARN Deployment</a> <ul>
+ <li><a href="#the-yarn-session-runs-only-for-a-few-seconds" id="markdown-toc-the-yarn-session-runs-only-for-a-few-seconds">The YARN session runs only for a few seconds</a></li>
+ <li><a href="#the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup" id="markdown-toc-the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup">The YARN session crashes with a HDFS permission exception during startup</a></li>
</ul>
</li>
- <li><a href="#features">Features</a> <ul>
- <li><a href="#what-kind-of-fault-tolerance-does-flink-provide">What kind of fault-tolerance does Flink provide?</a></li>
- <li><a href="#are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported">Are Hadoop-like utilities, such as Counters and the DistributedCache supported?</a></li>
+ <li><a href="#features" id="markdown-toc-features">Features</a> <ul>
+ <li><a href="#what-kind-of-fault-tolerance-does-flink-provide" id="markdown-toc-what-kind-of-fault-tolerance-does-flink-provide">What kind of fault-tolerance does Flink provide?</a></li>
+ <li><a href="#are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported" id="markdown-toc-are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported">Are Hadoop-like utilities, such as Counters and the DistributedCache supported?</a></li>
</ul>
</li>
</ul>
@@ -445,7 +445,7 @@ cluster.sh</code>). You can kill their processes on Linux/Mac as follows:</p>
<ul>
<li>Determine the process id (pid) of the JobManager / TaskManager process. You
can use the <code>jps</code> command on Linux(if you have OpenJDK installed) or command
-<code>ps -ef | grep java</code> to find all Java processes. </li>
+<code>ps -ef | grep java</code> to find all Java processes.</li>
<li>Kill the process with <code>kill -9 <pid></code>, where <code>pid</code> is the process id of the
affected JobManager or TaskManager process.</li>
</ul>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/features.html
----------------------------------------------------------------------
diff --git a/content/features.html b/content/features.html
index e03d48d..9c8d9a3 100644
--- a/content/features.html
+++ b/content/features.html
@@ -389,7 +389,7 @@
<div class="col-sm-7">
<p class="lead">WindowWordCount in Flink's DataStream API</p>
-<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Word</span><span class="o">(</span><span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">freq</span><span class="k">:</span> <span class="kt">Long</span><span class="o">)</span>
+<figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Word</span><span class="o">(</span><span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">freq</span><span class="k">:</span> <span class="kt">Long</span><span class="o">)</span>
<span class="k">val</span> <span class="n">texts</span><span class="k">:</span> <span class="kt">DataStream</span><span class="o">[</span><span class="kt">String</span><span class="o">]</span> <span class="k">=</span> <span class="o">...</span>
@@ -398,7 +398,7 @@
<span class="o">.</span><span class="n">map</span> <span class="o">{</span> <span class="n">token</span> <span class="k">=></span> <span class="nc">Word</span><span class="o">(</span><span class="n">token</span><span class="o">,</span> <span class="mi">1</span><span class="o">)</span> <span class="o">}</span>
<span class="o">.</span><span class="n">keyBy</span><span class="o">(</span><span class="s">"word"</span><span class="o">)</span>
<span class="o">.</span><span class="n">timeWindow</span><span class="o">(</span><span class="nc">Time</span><span class="o">.</span><span class="n">seconds</span><span class="o">(</span><span class="mi">5</span><span class="o">),</span> <span class="nc">Time</span><span class="o">.</span><span class="n">seconds</span><span class="o">(</span><span class="mi">1</span><span class="o">))</span>
- <span class="o">.</span><span class="n">sum</span><span class="o">(</span><span class="s">"freq"</span><span class="o">)</span></code></pre></div>
+ <span class="o">.</span><span class="n">sum</span><span class="o">(</span><span class="s">"freq"</span><span class="o">)</span></code></pre></figure>
</div>
</div>
@@ -418,7 +418,7 @@
</div>
<div class="col-sm-7">
-<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Page</span><span class="o">(</span><span class="n">pageId</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">rank</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)</span>
+<figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Page</span><span class="o">(</span><span class="n">pageId</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">rank</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)</span>
<span class="k">case</span> <span class="k">class</span> <span class="nc">Adjacency</span><span class="o">(</span><span class="n">id</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">neighbors</span><span class="k">:</span> <span class="kt">Array</span><span class="o">[</span><span class="kt">Long</span><span class="o">])</span>
<span class="k">val</span> <span class="n">result</span> <span class="k">=</span> <span class="n">initialRanks</span><span class="o">.</span><span class="n">iterate</span><span class="o">(</span><span class="mi">30</span><span class="o">)</span> <span class="o">{</span> <span class="n">pages</span> <span class="k">=></span>
@@ -433,7 +433,7 @@
<span class="o">}</span>
<span class="o">}</span>
<span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="s">"pageId"</span><span class="o">).</span><span class="n">sum</span><span class="o">(</span><span class="s">"rank"</span><span class="o">)</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/how-to-contribute.html
----------------------------------------------------------------------
diff --git a/content/how-to-contribute.html b/content/how-to-contribute.html
index 86bbe0e..c79620d 100644
--- a/content/how-to-contribute.html
+++ b/content/how-to-contribute.html
@@ -162,17 +162,17 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#ask-questions">Ask questions!</a></li>
- <li><a href="#file-a-bug-report">File a bug report</a></li>
- <li><a href="#propose-an-improvement-or-a-new-feature">Propose an improvement or a new feature</a></li>
- <li><a href="#help-others-and-join-the-discussions">Help others and join the discussions</a></li>
- <li><a href="#test-a-release-candidate">Test a release candidate</a></li>
- <li><a href="#contribute-code">Contribute code</a></li>
- <li><a href="#contribute-documentation">Contribute documentation</a></li>
- <li><a href="#improve-the-website">Improve the website</a></li>
- <li><a href="#more-ways-to-contribute">More ways to contribute…</a></li>
- <li><a href="#submit-a-contributor-license-agreement">Submit a Contributor License Agreement</a></li>
- <li><a href="#how-to-become-a-committer">How to become a committer</a></li>
+ <li><a href="#ask-questions" id="markdown-toc-ask-questions">Ask questions!</a></li>
+ <li><a href="#file-a-bug-report" id="markdown-toc-file-a-bug-report">File a bug report</a></li>
+ <li><a href="#propose-an-improvement-or-a-new-feature" id="markdown-toc-propose-an-improvement-or-a-new-feature">Propose an improvement or a new feature</a></li>
+ <li><a href="#help-others-and-join-the-discussions" id="markdown-toc-help-others-and-join-the-discussions">Help others and join the discussions</a></li>
+ <li><a href="#test-a-release-candidate" id="markdown-toc-test-a-release-candidate">Test a release candidate</a></li>
+ <li><a href="#contribute-code" id="markdown-toc-contribute-code">Contribute code</a></li>
+ <li><a href="#contribute-documentation" id="markdown-toc-contribute-documentation">Contribute documentation</a></li>
+ <li><a href="#improve-the-website" id="markdown-toc-improve-the-website">Improve the website</a></li>
+ <li><a href="#more-ways-to-contribute" id="markdown-toc-more-ways-to-contribute">More ways to contribute…</a></li>
+ <li><a href="#submit-a-contributor-license-agreement" id="markdown-toc-submit-a-contributor-license-agreement">Submit a Contributor License Agreement</a></li>
+ <li><a href="#how-to-become-a-committer" id="markdown-toc-how-to-become-a-committer">How to become a committer</a></li>
</ul>
</div>
@@ -199,7 +199,7 @@
<li>It allow for constructive discussions that might arise around this issue.</li>
</ul>
-<p>Detailed information is also required, if you plan to contribute the improvement or feature you proposed yourself. Please read the <a href="/contribute-code.html">Contribute code</a> guide in this case as well. </p>
+<p>Detailed information is also required, if you plan to contribute the improvement or feature you proposed yourself. Please read the <a href="/contribute-code.html">Contribute code</a> guide in this case as well.</p>
<hr />
@@ -226,7 +226,7 @@
<li>Going back to step 1 if the release candidate had issues otherwise we publish the release.</li>
</ol>
-<p>Our wiki contains a page that summarizes the <a href="https://cwiki.apache.org/confluence/display/FLINK/Releasing">test procedure for a release</a>. Release testing is a big effort if done by a small group of people but can be easily scaled out to more people. The Flink community encourages everybody to participate in the testing of a release candidate. By testing a release candidate, you can ensure that the next Flink release is working properly for your setup and help to improve the quality of releases. </p>
+<p>Our wiki contains a page that summarizes the <a href="https://cwiki.apache.org/confluence/display/FLINK/Releasing">test procedure for a release</a>. Release testing is a big effort if done by a small group of people but can be easily scaled out to more people. The Flink community encourages everybody to participate in the testing of a release candidate. By testing a release candidate, you can ensure that the next Flink release is working properly for your setup and help to improve the quality of releases.</p>
<hr />
@@ -240,7 +240,7 @@
<h3 class="no_toc" id="looking-for-an-issue-to-work-on">Looking for an issue to work on?</h3>
-<p>We maintain a list of all known bugs, proposed improvements and suggested features in <a href="https://issues.apache.org/jira/browse/FLINK/?selectedTab=com.atlassian.jira.jira-projects-plugin:issues-panel">Flink’s JIRA</a>. Issues that we believe are good tasks for new contributors are tagged with a special “starter” tag. Those tasks are supposed to be rather easy to solve and will help you to become familiar with the project and the contribution process. </p>
+<p>We maintain a list of all known bugs, proposed improvements and suggested features in <a href="https://issues.apache.org/jira/browse/FLINK/?selectedTab=com.atlassian.jira.jira-projects-plugin:issues-panel">Flink’s JIRA</a>. Issues that we believe are good tasks for new contributors are tagged with a special “starter” tag. Those tasks are supposed to be rather easy to solve and will help you to become familiar with the project and the contribution process.</p>
<p>Please have a look at the list of <a href="https://issues.apache.org/jira/issues/?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20labels%20%3D%20starter%20ORDER%20BY%20priority%20DESC">starter issues</a>, if you are looking for an issue to work on. You can of course also choose <a href="https://issues.apache.org/jira/issues/?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20ORDER%20BY%20priority%20DESC">any other issue</a> to work on. Feel free to ask questions about issues that you would be interested in working on.</p>
@@ -305,7 +305,7 @@
<h2 id="how-to-become-a-committer">How to become a committer</h2>
-<p>Committers are community members that have write access to the project’s repositories, i.e., they can modify the code, documentation, and website by themselves and also accept other contributions. </p>
+<p>Committers are community members that have write access to the project’s repositories, i.e., they can modify the code, documentation, and website by themselves and also accept other contributions.</p>
<p>There is no strict protocol for becoming a committer. Candidates for new committers are typically people that are active contributors and community members.</p>
@@ -313,7 +313,7 @@
<p>Of course, contributing code and documentation to the project is important as well. A good way to start is contributing improvements, new features, or bug fixes. You need to show that you take responsibility for the code that you contribute, add tests and documentation, and help maintaining it.</p>
-<p>Candidates for new committers are suggested by current committers or PMC members, and voted upon by the PMC. </p>
+<p>Candidates for new committers are suggested by current committers or PMC members, and voted upon by the PMC.</p>
<p>If you would like to become a committer, you should engage with the community and start contributing to Apache Flink in any of the above ways. You might also want to talk to other committers and ask for their advice and guidance.</p>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/improve-website.html
----------------------------------------------------------------------
diff --git a/content/improve-website.html b/content/improve-website.html
index 49039b2..32cb2fc 100644
--- a/content/improve-website.html
+++ b/content/improve-website.html
@@ -170,11 +170,11 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#obtain-the-website-sources">Obtain the website sources</a></li>
- <li><a href="#directory-structure-and-files">Directory structure and files</a></li>
- <li><a href="#update-or-extend-the-documentation">Update or extend the documentation</a></li>
- <li><a href="#submit-your-contribution">Submit your contribution</a></li>
- <li><a href="#committer-section">Committer section</a></li>
+ <li><a href="#obtain-the-website-sources" id="markdown-toc-obtain-the-website-sources">Obtain the website sources</a></li>
+ <li><a href="#directory-structure-and-files" id="markdown-toc-directory-structure-and-files">Directory structure and files</a></li>
+ <li><a href="#update-or-extend-the-documentation" id="markdown-toc-update-or-extend-the-documentation">Update or extend the documentation</a></li>
+ <li><a href="#submit-your-contribution" id="markdown-toc-submit-your-contribution">Submit your contribution</a></li>
+ <li><a href="#committer-section" id="markdown-toc-committer-section">Committer section</a></li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/index.html
----------------------------------------------------------------------
diff --git a/content/index.html b/content/index.html
index 85b4b89..754120f 100644
--- a/content/index.html
+++ b/content/index.html
@@ -53,7 +53,7 @@
<ul class="nav navbar-nav">
<!-- Overview -->
- <li class="active"><a href="/index.html">Overview</a></li>
+ <li><a href="/index.html">Overview</a></li>
<!-- Features -->
<li><a href="/features.html">Features</a></li>
@@ -234,6 +234,10 @@
<ul class="list-group">
+ <li class="list-group-item"><span>14 Apr 2016</span> »
+ <a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a>
+ </li>
+
<li class="list-group-item"><span>06 Apr 2016</span> »
<a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a>
</li>
@@ -249,10 +253,6 @@
<li class="list-group-item"><span>11 Feb 2016</span> »
<a href="/news/2016/02/11/release-0.10.2.html">Flink 0.10.2 Released</a>
</li>
-
- <li class="list-group-item"><span>18 Dec 2015</span> »
- <a href="/news/2015/12/18/a-year-in-review.html">Flink 2015: A year in review, and a lookout to 2016</a>
- </li>
</ul>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/material.html
----------------------------------------------------------------------
diff --git a/content/material.html b/content/material.html
index 41df227..1be5515 100644
--- a/content/material.html
+++ b/content/material.html
@@ -160,13 +160,13 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-logos">Apache Flink Logos</a> <ul>
- <li><a href="#portable-network-graphics-png">Portable Network Graphics (PNG)</a></li>
- <li><a href="#scalable-vector-graphics-svg">Scalable Vector Graphics (SVG)</a></li>
- <li><a href="#photoshop-psd">Photoshop (PSD)</a></li>
+ <li><a href="#apache-flink-logos" id="markdown-toc-apache-flink-logos">Apache Flink Logos</a> <ul>
+ <li><a href="#portable-network-graphics-png" id="markdown-toc-portable-network-graphics-png">Portable Network Graphics (PNG)</a></li>
+ <li><a href="#scalable-vector-graphics-svg" id="markdown-toc-scalable-vector-graphics-svg">Scalable Vector Graphics (SVG)</a></li>
+ <li><a href="#photoshop-psd" id="markdown-toc-photoshop-psd">Photoshop (PSD)</a></li>
</ul>
</li>
- <li><a href="#color-scheme">Color Scheme</a></li>
+ <li><a href="#color-scheme" id="markdown-toc-color-scheme">Color Scheme</a></li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/news/2014/11/04/release-0.7.0.html
----------------------------------------------------------------------
diff --git a/content/news/2014/11/04/release-0.7.0.html b/content/news/2014/11/04/release-0.7.0.html
index c6e71af..5bf7fad 100644
--- a/content/news/2014/11/04/release-0.7.0.html
+++ b/content/news/2014/11/04/release-0.7.0.html
@@ -180,7 +180,7 @@
<p><strong>Record API deprecated:</strong> The (old) Stratosphere Record API has been marked as deprecated and is planned for removal in the 0.9.0 release.</p>
-<p><strong>BLOB service:</strong> This release contains a new service to distribute jar files and other binary data among the JobManager, TaskManagers and the client. </p>
+<p><strong>BLOB service:</strong> This release contains a new service to distribute jar files and other binary data among the JobManager, TaskManagers and the client.</p>
<p><strong>Intermediate data sets:</strong> A major rewrite of the system internals introduces intermediate data sets as first class citizens. The internal state machine that tracks the distributed tasks has also been completely rewritten for scalability. While this is not visible as a user-facing feature yet, it is the foundation for several upcoming exciting features.</p>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/news/2014/11/18/hadoop-compatibility.html
----------------------------------------------------------------------
diff --git a/content/news/2014/11/18/hadoop-compatibility.html b/content/news/2014/11/18/hadoop-compatibility.html
index beea975..38e8c33 100644
--- a/content/news/2014/11/18/hadoop-compatibility.html
+++ b/content/news/2014/11/18/hadoop-compatibility.html
@@ -168,7 +168,7 @@
<img src="/img/blog/hcompat-logos.png" style="width:30%;margin:15px" />
</center>
-<p>To close this gap, Flink provides a Hadoop Compatibility package to wrap functions implemented against Hadoop’s MapReduce interfaces and embed them in Flink programs. This package was developed as part of a <a href="https://developers.google.com/open-source/soc/">Google Summer of Code</a> 2014 project. </p>
+<p>To close this gap, Flink provides a Hadoop Compatibility package to wrap functions implemented against Hadoop’s MapReduce interfaces and embed them in Flink programs. This package was developed as part of a <a href="https://developers.google.com/open-source/soc/">Google Summer of Code</a> 2014 project.</p>
<p>With the Hadoop Compatibility package, you can reuse all your Hadoop</p>
@@ -181,7 +181,7 @@
<p>in Flink programs without changing a line of code. Moreover, Flink also natively supports all Hadoop data types (<code>Writables</code> and <code>WritableComparable</code>).</p>
-<p>The following code snippet shows a simple Flink WordCount program that solely uses Hadoop data types, InputFormat, OutputFormat, Mapper, and Reducer functions. </p>
+<p>The following code snippet shows a simple Flink WordCount program that solely uses Hadoop data types, InputFormat, OutputFormat, Mapper, and Reducer functions.</p>
<div class="highlight"><pre><code class="language-java"><span class="c1">// Definition of Hadoop Mapper function</span>
<span class="kd">public</span> <span class="kd">class</span> <span class="nc">Tokenizer</span> <span class="kd">implements</span> <span class="n">Mapper</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">></span> <span class="o">{</span> <span class="o">...</span> <span class="o">}</span>
@@ -197,25 +197,25 @@
<span class="c1">// Setup Hadoop’s TextInputFormat</span>
<span class="n">HadoopInputFormat</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">></span> <span class="n">hadoopInputFormat</span> <span class="o">=</span>
<span class="k">new</span> <span class="n">HadoopInputFormat</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">>(</span>
- <span class="k">new</span> <span class="n">TextInputFormat</span><span class="o">(),</span> <span class="n">LongWritable</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">Text</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">());</span>
- <span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Path</span><span class="o">(</span><span class="n">inputPath</span><span class="o">));</span>
+ <span class="k">new</span> <span class="nf">TextInputFormat</span><span class="o">(),</span> <span class="n">LongWritable</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">Text</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">());</span>
+ <span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Path</span><span class="o">(</span><span class="n">inputPath</span><span class="o">));</span>
<span class="c1">// Read a DataSet with the Hadoop InputFormat</span>
<span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">>></span> <span class="n">text</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">createInput</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">);</span>
<span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>></span> <span class="n">words</span> <span class="o">=</span> <span class="n">text</span>
<span class="c1">// Wrap Tokenizer Mapper function</span>
- <span class="o">.</span><span class="na">flatMap</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopMapFunction</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span><span class="k">new</span> <span class="n">Tokenizer</span><span class="o">()))</span>
+ <span class="o">.</span><span class="na">flatMap</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopMapFunction</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span><span class="k">new</span> <span class="nf">Tokenizer</span><span class="o">()))</span>
<span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="mi">0</span><span class="o">)</span>
<span class="c1">// Wrap Counter Reducer function (used as Reducer and Combiner)</span>
<span class="o">.</span><span class="na">reduceGroup</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopReduceCombineFunction</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span>
- <span class="k">new</span> <span class="n">Counter</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Counter</span><span class="o">()));</span>
+ <span class="k">new</span> <span class="nf">Counter</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Counter</span><span class="o">()));</span>
<span class="c1">// Setup Hadoop’s TextOutputFormat</span>
<span class="n">HadoopOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">></span> <span class="n">hadoopOutputFormat</span> <span class="o">=</span>
<span class="k">new</span> <span class="n">HadoopOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span>
- <span class="k">new</span> <span class="n">TextOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(),</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">());</span>
+ <span class="k">new</span> <span class="n">TextOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(),</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">());</span>
<span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">().</span><span class="na">set</span><span class="o">(</span><span class="s">"mapred.textoutputformat.separator"</span><span class="o">,</span> <span class="s">" "</span><span class="o">);</span>
- <span class="n">TextOutputFormat</span><span class="o">.</span><span class="na">setOutputPath</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Path</span><span class="o">(</span><span class="n">outputPath</span><span class="o">));</span>
+ <span class="n">TextOutputFormat</span><span class="o">.</span><span class="na">setOutputPath</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Path</span><span class="o">(</span><span class="n">outputPath</span><span class="o">));</span>
<span class="c1">// Output & Execute</span>
<span class="n">words</span><span class="o">.</span><span class="na">output</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">);</span>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/news/2015/01/21/release-0.8.html
----------------------------------------------------------------------
diff --git a/content/news/2015/01/21/release-0.8.html b/content/news/2015/01/21/release-0.8.html
index ee397d3..033c68f 100644
--- a/content/news/2015/01/21/release-0.8.html
+++ b/content/news/2015/01/21/release-0.8.html
@@ -211,7 +211,7 @@
<li>Stefan Bunk</li>
<li>Paris Carbone</li>
<li>Ufuk Celebi</li>
- <li>Nils Engelbach </li>
+ <li>Nils Engelbach</li>
<li>Stephan Ewen</li>
<li>Gyula Fora</li>
<li>Gabor Hermann</li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/news/2015/02/04/january-in-flink.html
----------------------------------------------------------------------
diff --git a/content/news/2015/02/04/january-in-flink.html b/content/news/2015/02/04/january-in-flink.html
index 7febbcf..718488e 100644
--- a/content/news/2015/02/04/january-in-flink.html
+++ b/content/news/2015/02/04/january-in-flink.html
@@ -188,7 +188,7 @@
<h3 id="using-off-heap-memoryhttpsgithubcomapacheflinkpull290"><a href="https://github.com/apache/flink/pull/290">Using off-heap memory</a></h3>
-<p>This pull request enables Flink to use off-heap memory for its internal memory uses (sort, hash, caching of intermediate data sets). </p>
+<p>This pull request enables Flink to use off-heap memory for its internal memory uses (sort, hash, caching of intermediate data sets).</p>
<h3 id="gelly-flinks-graph-apihttpsgithubcomapacheflinkpull335"><a href="https://github.com/apache/flink/pull/335">Gelly, Flink’s Graph API</a></h3>