You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/08/08 16:32:01 UTC

[2/5] flink-web git commit: Rebuild website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/609ba062/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
new file mode 100644
index 0000000..49ef7ff
--- /dev/null
+++ b/content/news/2016/08/08/release-1.1.0.html
@@ -0,0 +1,414 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="utf-8">
+    <meta http-equiv="X-UA-Compatible" content="IE=edge">
+    <meta name="viewport" content="width=device-width, initial-scale=1">
+    <!-- The above 3 meta tags *must* come first in the head; any other head content must come *after* these tags -->
+    <title>Apache Flink: Announcing Apache Flink 1.1.0</title>
+    <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
+    <link rel="icon" href="/favicon.ico" type="image/x-icon">
+
+    <!-- Bootstrap -->
+    <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/css/bootstrap.min.css">
+    <link rel="stylesheet" href="/css/flink.css">
+    <link rel="stylesheet" href="/css/syntax.css">
+
+    <!-- Blog RSS feed -->
+    <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" />
+
+    <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
+    <!-- We need to load Jquery in the header for custom google analytics event tracking-->
+    <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
+
+    <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries -->
+    <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
+    <!--[if lt IE 9]>
+      <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js"></script>
+      <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js"></script>
+    <![endif]-->
+  </head>
+  <body>  
+    
+
+  <!-- Top navbar. -->
+    <nav class="navbar navbar-default navbar-fixed-top">
+      <div class="container">
+        <!-- The logo. -->
+        <div class="navbar-header">
+          <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1">
+            <span class="icon-bar"></span>
+            <span class="icon-bar"></span>
+            <span class="icon-bar"></span>
+          </button>
+          <div class="navbar-logo">
+            <a href="/">
+              <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px">
+            </a>
+          </div>
+        </div><!-- /.navbar-header -->
+
+        <!-- The navigation links. -->
+        <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+          <ul class="nav navbar-nav">
+
+            <!-- Overview -->
+            <li><a href="/index.html">Overview</a></li>
+
+            <!-- Features -->
+            <li><a href="/features.html">Features</a></li>
+
+            <!-- Downloads -->
+            <li><a href="/downloads.html">Downloads</a></li>
+
+            <!-- FAQ -->
+            <li><a href="/faq.html">FAQ</a></li>
+
+
+            <!-- Quickstart -->
+            <li class="dropdown">
+              <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a>
+              <ul class="dropdown-menu" role="menu">
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/setup_quickstart.html">Setup</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/run_example_quickstart.html">Example: Wikipedia Edit Stream</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/java_api_quickstart.html">Java API</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/scala_api_quickstart.html">Scala API</a></li>
+              </ul>
+            </li>
+
+            <!-- Documentation -->
+            <li class="dropdown">
+              <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a>
+              <ul class="dropdown-menu" role="menu">
+                <!-- Latest stable release -->
+                <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1">1.1 Documentation</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/java" class="active">1.1 Javadocs</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/scala/index.html" class="active">1.1 ScalaDocs</a></li>
+
+                <!-- Snapshot docs -->
+                <li class="divider"></li>
+                <li role="presentation" class="dropdown-header"><strong>Snapshot</strong> (Development)</li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-master">1.2 Documentation</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-master/api/java" class="active">1.2 Javadocs</a></li>
+                <li><a href="http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html" class="active">1.2 ScalaDocs</a></li>
+
+                <!-- Wiki -->
+                <li class="divider"></li>
+                <li><a href="/visualizer/"><small><span class="glyphicon glyphicon-new-window"></span></small> Plan Visualizer</a></li>
+                <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home"><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li>
+              </ul>
+            </li>
+
+          </ul>
+
+          <ul class="nav navbar-nav navbar-right">
+            <!-- Blog -->
+            <li class=" active hidden-md hidden-sm"><a href="/blog/">Blog</a></li>
+
+            <li class="dropdown hidden-md hidden-sm">
+              <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Community <span class="caret"></span></a>
+              <ul class="dropdown-menu" role="menu">
+                <!-- Community -->
+                <li role="presentation" class="dropdown-header"><strong>Community</strong></li>
+                <li><a href="/community.html#mailing-lists">Mailing Lists</a></li>
+                <li><a href="/community.html#irc">IRC</a></li>
+                <li><a href="/community.html#stack-overflow">Stack Overflow</a></li>
+                <li><a href="/community.html#issue-tracker">Issue Tracker</a></li>
+                <li><a href="/community.html#third-party-packages">Third Party Packages</a></li>
+                <li><a href="/community.html#source-code">Source Code</a></li>
+                <li><a href="/community.html#people">People</a></li>
+                <li><a href="/poweredby.html">Powered by Flink</a></li>
+
+                <!-- Contribute -->
+                <li class="divider"></li>
+                <li role="presentation" class="dropdown-header"><strong>Contribute</strong></li>
+                <li><a href="/how-to-contribute.html">How to Contribute</a></li>
+                <li><a href="/contribute-code.html">Contribute Code</a></li>
+                <li><a href="/contribute-documentation.html">Contribute Documentation</a></li>
+                <li><a href="/improve-website.html">Improve the Website</a></li>
+              </ul>
+            </li>
+
+            <li class="dropdown hidden-md hidden-sm">
+              <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Project <span class="caret"></span></a>
+              <ul class="dropdown-menu" role="menu">
+                <!-- Project -->
+                <li role="presentation" class="dropdown-header"><strong>Project</strong></li>
+                <li><a href="/slides.html">Slides</a></li>
+                <li><a href="/material.html">Material</a></li>
+                <li><a href="https://twitter.com/apacheflink"><small><span class="glyphicon glyphicon-new-window"></span></small> Twitter</a></li>
+                <li><a href="https://github.com/apache/flink"><small><span class="glyphicon glyphicon-new-window"></span></small> GitHub</a></li>
+                <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home"><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li>
+              </ul>
+            </li>
+          </ul>
+        </div><!-- /.navbar-collapse -->
+      </div><!-- /.container -->
+    </nav>
+
+
+    <!-- Main content. -->
+    <div class="container">
+      
+
+<div class="row">
+  <div class="col-sm-8 col-sm-offset-2">
+    <div class="row">
+      <h1>Announcing Apache Flink 1.1.0</h1>
+
+      <article>
+        <p>08 Aug 2016</p>
+
+<p>The Apache Flink community is pleased to announce the availability of Flink 1.1.0.</p>
+
+<p>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 <a href="/blog/release_1.1.0-changelog.html">complete changelog</a> for more details.</p>
+
+<p><strong>We encourage everyone to <a href="http://flink.apache.org/downloads.html">download the release</a> and <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/">check out the documentation</a>. Feedback through the Flink <a href="http://flink.apache.org/community.html#mailing-lists">mailing lists</a> is, as always, very welcome!</strong></p>
+
+<p>Some highlights of the release are listed in the following sections.</p>
+
+<h2 id="connectors">Connectors</h2>
+
+<p>The <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/index.html">streaming connectors</a> are a major part of Flink\u2019s DataStream API. This release adds support for new external systems and further improves on the available connectors.</p>
+
+<h3 id="continuous-file-system-sources">Continuous File System Sources</h3>
+
+<p>A frequently requested feature for Flink 1.0 was to be able to monitor directories and process files continuously. Flink 1.1 now adds support for this via <code>FileProcessingMode</code>s:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">DataStream</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;</span> <span class="n">stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">readFile</span><span class="o">(</span>
+  <span class="n">textInputFormat</span><span class="o">,</span>
+  <span class="s">&quot;hdfs:///file-path&quot;</span><span class="o">,</span>
+  <span class="n">FileProcessingMode</span><span class="o">.</span><span class="na">PROCESS_CONTINUOUSLY</span><span class="o">,</span>
+  <span class="mi">5000</span><span class="o">,</span> <span class="c1">// monitoring interval (millis)</span>
+  <span class="n">FilePathFilter</span><span class="o">.</span><span class="na">createDefaultFilter</span><span class="o">());</span> <span class="c1">// file path filter</span></code></pre></div>
+
+<p>This will monitor <code>hdfs:///file-path</code> every <code>5000</code> milliseconds. Check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/index.html#data-sources">DataSource documentation for more details</a>.</p>
+
+<h3 id="kinesis-source-and-sink">Kinesis Source and Sink</h3>
+
+<p>Flink 1.1 adds a Kinesis connector for both consuming (<code>FlinkKinesisConsumer</code>) from and producing (<code>FlinkKinesisProduer</code>) to <a href="https://aws.amazon.com/kinesis/">Amazon Kinesis Streams</a>, which is a managed service purpose-built to make it easy to work with streaming data on AWS.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">DataStream</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;</span> <span class="n">kinesis</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span>
+  <span class="k">new</span> <span class="n">FlinkKinesisConsumer</span><span class="o">&lt;&gt;(</span><span class="s">&quot;stream-name&quot;</span><span class="o">,</span> <span class="n">schema</span><span class="o">,</span> <span class="n">config</span><span class="o">));</span></code></pre></div>
+
+<p>Check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/kinesis.html">Kinesis connector documentation for more details</a>.</p>
+
+<h3 id="cassandra-sink">Cassandra Sink</h3>
+
+<p>The <a href="http://wiki.apache.org/cassandra/GettingStarted">Apache Cassandra</a> sink allows you to write from Flink to Cassandra. Flink can provide exactly-once guarantees if the query is idempotent, meaning it can be applied multiple times without changing the result.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">CassandraSink</span><span class="o">.</span><span class="na">addSink</span><span class="o">(</span><span class="n">input</span><span class="o">)</span></code></pre></div>
+
+<p>Check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/cassandra.html">Cassandra Sink documentation for more details</a>.</p>
+
+<h2 id="table-api-and-sql">Table API and SQL</h2>
+
+<p>The Table API is a SQL-like expression language for relational stream and batch processing that can be easily embedded in Flink\u2019s DataSet and DataStream APIs (for both Java and Scala).</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">Table</span> <span class="n">custT</span> <span class="o">=</span> <span class="n">tableEnv</span>
+  <span class="o">.</span><span class="na">toTable</span><span class="o">(</span><span class="n">custDs</span><span class="o">,</span> <span class="s">&quot;name, zipcode&quot;</span><span class="o">)</span>
+  <span class="o">.</span><span class="na">where</span><span class="o">(</span><span class="s">&quot;zipcode = &#39;12345&#39;&quot;</span><span class="o">)</span>
+  <span class="o">.</span><span class="na">select</span><span class="o">(</span><span class="s">&quot;name&quot;</span><span class="o">)</span></code></pre></div>
+
+<p>An initial version of this API was already available in Flink 1.0. For Flink 1.1, the community put a lot of work into reworking the architecture of the Table API and integrating it with <a href="https://calcite.apache.org">Apache Calcite</a>.</p>
+
+<p>In this first version, SQL (and Table API) queries on streams are limited to selection, filter, and union operators. Compared to Flink 1.0, the revised Table API supports many more scalar functions and is able to read tables from external sources and write them back to external sinks.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">Table</span> <span class="n">result</span> <span class="o">=</span> <span class="n">tableEnv</span><span class="o">.</span><span class="na">sql</span><span class="o">(</span>
+  <span class="s">&quot;SELECT STREAM product, amount FROM Orders WHERE product LIKE &#39;%Rubber%&#39;&quot;</span><span class="o">);</span></code></pre></div>
+<p>A more detailed introduction can be found in the <a href="http://flink.apache.org/news/2016/05/24/stream-sql.html">Flink blog</a> and the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/table.html">Table API documentation</a>.</p>
+
+<h2 id="datastream-api">DataStream API</h2>
+
+<p>The DataStream API now exposes <strong>session windows</strong> and <strong>allowed lateness</strong> as first-class citizens.</p>
+
+<h3 id="session-windows">Session Windows</h3>
+
+<p>Session windows are ideal for cases where the window boundaries need to adjust to the incoming data. This enables you to have windows that start at individual points in time for each key and that end once there has been a <em>certain period of inactivity</em>. The configuration parameter is the session gap that specifies how long to wait for new data before considering a session as closed.</p>
+
+<center>
+<img src="/img/blog/session-windows.svg" style="height:400px" />
+</center>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">input</span><span class="o">.</span><span class="na">keyBy</span><span class="o">(&lt;</span><span class="n">key</span> <span class="n">selector</span><span class="o">&gt;)</span>
+    <span class="o">.</span><span class="na">window</span><span class="o">(</span><span class="n">EventTimeSessionWindows</span><span class="o">.</span><span class="na">withGap</span><span class="o">(</span><span class="n">Time</span><span class="o">.</span><span class="na">minutes</span><span class="o">(</span><span class="mi">10</span><span class="o">)))</span>
+    <span class="o">.&lt;</span><span class="n">windowed</span> <span class="n">transformation</span><span class="o">&gt;(&lt;</span><span class="n">window</span> <span class="n">function</span><span class="o">&gt;);</span></code></pre></div>
+
+<h3 id="support-for-late-elements">Support for Late Elements</h3>
+
+<p>You can now specify how a windowed transformation should deal with late elements and how much lateness is allowed. The parameter for this is called <em>allowed lateness</em>. This specifies by how much time elements can be late.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">input</span><span class="o">.</span><span class="na">keyBy</span><span class="o">(&lt;</span><span class="n">key</span> <span class="n">selector</span><span class="o">&gt;).</span><span class="na">window</span><span class="o">(&lt;</span><span class="n">window</span> <span class="n">assigner</span><span class="o">&gt;)</span>
+    <span class="o">.</span><span class="na">allowedLateness</span><span class="o">(&lt;</span><span class="n">time</span><span class="o">&gt;)</span>
+    <span class="o">.&lt;</span><span class="n">windowed</span> <span class="n">transformation</span><span class="o">&gt;(&lt;</span><span class="n">window</span> <span class="n">function</span><span class="o">&gt;);</span></code></pre></div>
+
+<p>Elements that arrive within the allowed lateness are still put into windows and are considered when computing window results. If elements arrive after the allowed lateness they will be dropped. Flink will also make sure that any state held by the windowing operation is garbage collected once the watermark passes the end of a window plus the allowed lateness.</p>
+
+<p>Check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/windows.html">Windows documentation for more details</a>.</p>
+
+<h2 id="scala-api-for-complex-event-processing-cep">Scala API for Complex Event Processing (CEP)</h2>
+
+<p>Flink 1.0 added the initial version of the CEP library. The core of the library is a Pattern API, which allows you to easily specify patterns to match against in your event stream. While in Flink 1.0 this API was only available for Java, Flink 1.1. now exposes the same API for Scala, allowing you to specify your event patterns in a more concise manner.</p>
+
+<p>A more detailed introduction can be found in the <a href="http://flink.apache.org/news/2016/04/06/cep-monitoring.html">Flink blog</a> and the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/libs/cep.html">CEP documentation</a>.</p>
+
+<h2 id="metrics">Metrics</h2>
+
+<p>Flink\u2019s new metrics system allows you to easily gather and expose metrics from your user application to external systems. You can add counters, gauges, and histograms to your application via the runtime context:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">Counter</span> <span class="n">counter</span> <span class="o">=</span> <span class="n">getRuntimeContext</span><span class="o">()</span>
+  <span class="o">.</span><span class="na">getMetricGroup</span><span class="o">()</span>
+  <span class="o">.</span><span class="na">counter</span><span class="o">(</span><span class="s">&quot;my-counter&quot;</span><span class="o">);</span></code></pre></div>
+
+<p>All registered metrics will be exposed via reporters. Out of the box, Flinks comes with support for JMX, Ganglia, Graphite, and statsD. In addition to your custom metrics, Flink exposes many internal metrics like checkpoint sizes and JVM stats.</p>
+
+<p>Check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/metrics.html">Metrics documentation for more details</a>.</p>
+
+<h2 id="list-of-contributors">List of Contributors</h2>
+
+<p>The following 95 people contributed to this release:</p>
+
+<ul>
+  <li>Abdullah Ozturk</li>
+  <li>Ajay Bhat</li>
+  <li>Alexey Savartsov</li>
+  <li>Aljoscha Krettek</li>
+  <li>Andrea Sella</li>
+  <li>Andrew Palumbo</li>
+  <li>Chenguang He</li>
+  <li>Chiwan Park</li>
+  <li>David Moravek</li>
+  <li>Dominik Bruhn</li>
+  <li>Dyana Rose</li>
+  <li>Fabian Hueske</li>
+  <li>Flavio Pompermaier</li>
+  <li>Gabor Gevay</li>
+  <li>Gabor Horvath</li>
+  <li>Geoffrey Mon</li>
+  <li>Gordon Tai</li>
+  <li>Greg Hogan</li>
+  <li>Gyula Fora</li>
+  <li>Henry Saputra</li>
+  <li>Ignacio N. Lucero Ascencio</li>
+  <li>Igor Berman</li>
+  <li>Isma�l Mej�a</li>
+  <li>Ivan Mushketyk</li>
+  <li>Jark Wu</li>
+  <li>Jiri Simsa</li>
+  <li>Jonas Traub</li>
+  <li>Josh</li>
+  <li>Joshi</li>
+  <li>Joshua Herman</li>
+  <li>Ken Krugler</li>
+  <li>Konstantin Knauf</li>
+  <li>Lasse Dalegaard</li>
+  <li>Li Fanxi</li>
+  <li>MaBiao</li>
+  <li>Mao Wei</li>
+  <li>Mark Reddy</li>
+  <li>Martin Junghanns</li>
+  <li>Martin Liesenberg</li>
+  <li>Maximilian Michels</li>
+  <li>Michal Fijolek</li>
+  <li>M�rton Balassi</li>
+  <li>Nathan Howell</li>
+  <li>Niels Basjes</li>
+  <li>Niels Zeilemaker</li>
+  <li>Phetsarath, Sourigna</li>
+  <li>Robert Metzger</li>
+  <li>Scott Kidder</li>
+  <li>Sebastian Klemke</li>
+  <li>Shahin</li>
+  <li>Shannon Carey</li>
+  <li>Shannon Quinn</li>
+  <li>Stefan Richter</li>
+  <li>Stefano Baghino</li>
+  <li>Stefano Bortoli</li>
+  <li>Stephan Ewen</li>
+  <li>Steve Cosenza</li>
+  <li>Sumit Chawla</li>
+  <li>Tatu Saloranta</li>
+  <li>Tianji Li</li>
+  <li>Till Rohrmann</li>
+  <li>Todd Lisonbee</li>
+  <li>Tony Baines</li>
+  <li>Trevor Grant</li>
+  <li>Ufuk Celebi</li>
+  <li>Vasudevan</li>
+  <li>Yijie Shen</li>
+  <li>Zack Pierce</li>
+  <li>Zhai Jia</li>
+  <li>chengxiang li</li>
+  <li>chobeat</li>
+  <li>danielblazevski</li>
+  <li>dawid</li>
+  <li>dawidwys</li>
+  <li>eastcirclek</li>
+  <li>erli ding</li>
+  <li>gallenvara</li>
+  <li>kl0u</li>
+  <li>mans2singh</li>
+  <li>markreddy</li>
+  <li>mjsax</li>
+  <li>nikste</li>
+  <li>omaralvarez</li>
+  <li>philippgrulich</li>
+  <li>ramkrishna</li>
+  <li>sahitya-pavurala</li>
+  <li>samaitra</li>
+  <li>smarthi</li>
+  <li>spkavuly</li>
+  <li>subhankar</li>
+  <li>twalthr</li>
+  <li>vasia</li>
+  <li>xueyan.li</li>
+  <li>zentol</li>
+  <li>\u536b\u4e50</li>
+</ul>
+
+      </article>
+    </div>
+
+    <div class="row">
+      <div id="disqus_thread"></div>
+      <script type="text/javascript">
+        /* * * CONFIGURATION VARIABLES: EDIT BEFORE PASTING INTO YOUR WEBPAGE * * */
+        var disqus_shortname = 'stratosphere-eu'; // required: replace example with your forum shortname
+
+        /* * * DON'T EDIT BELOW THIS LINE * * */
+        (function() {
+            var dsq = document.createElement('script'); dsq.type = 'text/javascript'; dsq.async = true;
+            dsq.src = '//' + disqus_shortname + '.disqus.com/embed.js';
+             (document.getElementsByTagName('head')[0] || document.getElementsByTagName('body')[0]).appendChild(dsq);
+        })();
+      </script>
+    </div>
+  </div>
+</div>
+
+      <hr />
+      <div class="footer text-center">
+        <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+        <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+        <p><a href="/privacy-policy.html">Privacy Policy</a> &middot; <a href="/blog/feed.xml">RSS feed</a></p>
+      </div>
+
+    </div><!-- /.container -->
+
+    <!-- Include all compiled plugins (below), or include individual files as needed -->
+    <script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js"></script>
+    <script src="/js/codetabs.js"></script>
+
+    <!-- Google Analytics -->
+    <script>
+      (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+      (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+      m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+      })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+      ga('create', 'UA-52545728-1', 'auto');
+      ga('send', 'pageview');
+    </script>
+  </body>
+</html>