You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kt...@apache.org on 2015/03/02 20:19:25 UTC
svn commit: r1663400 - in /flink: _posts/ site/ site/blog/ site/blog/page2/
site/blog/page3/
site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/
site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/
site/news/2015/03/ si...
Author: ktzoumas
Date: Mon Mar 2 19:19:25 2015
New Revision: 1663400
URL: http://svn.apache.org/r1663400
Log:
Added blog post on February 2015 in Flink community
Added:
flink/_posts/2015-02-02-february-2015-in-flink.md
flink/site/news/2015/03/
flink/site/news/2015/03/02/
flink/site/news/2015/03/02/february-2015-in-flink.html
Modified:
flink/site/blog/feed.xml
flink/site/blog/index.html
flink/site/blog/page2/index.html
flink/site/blog/page3/index.html
flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html
flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html
flink/site/downloads.html
Added: flink/_posts/2015-02-02-february-2015-in-flink.md
URL: http://svn.apache.org/viewvc/flink/_posts/2015-02-02-february-2015-in-flink.md?rev=1663400&view=auto
==============================================================================
--- flink/_posts/2015-02-02-february-2015-in-flink.md (added)
+++ flink/_posts/2015-02-02-february-2015-in-flink.md Mon Mar 2 19:19:25 2015
@@ -0,0 +1,112 @@
+---
+layout: post
+title: 'February 2015 in the Flink community'
+date: 2015-03-02 10:00:00
+categories: news
+---
+
+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.
+
+###0.8.1 release
+
+Flink 0.8.1 was released. This bugfixing release resolves a total of 22 issues.
+
+###New committer
+
+[Max Michels](https://github.com/mxm) has been voted a committer by the Flink PMC.
+
+###Flink adapter for Apache SAMOA
+
+[Apache SAMOA (incubating)](http://samoa.incubator.apache.org) is a
+distributed streaming machine learning (ML) framework with a
+programming abstraction for distributed streaming ML algorithms. SAMOA
+runs on a variety of backend engines, currently Apache Storm and
+Apache S4. A [pull
+request](https://github.com/apache/incubator-samoa/pull/11) is
+available at the SAMOA repository that adds a Flink adapter for SAMOA.
+
+###Easy Flink deployment on Google Compute Cloud
+
+Flink is now integrated in bdutil, Googleâs open source tool for
+creating and configuring (Hadoop) clusters in Google Compute
+Engine. Deployment of Flink clusters in now supported starting with
+[bdutil
+1.2.0](https://groups.google.com/forum/#!topic/gcp-hadoop-announce/uVJ_6y9cGKM).
+
+###Flink on the Web
+
+A new blog post on [Flink
+Streaming](http://flink.apache.org/news/2015/02/09/streaming-example.html)
+was published at the blog. Flink was mentioned in several articles on
+the web. Here are some examples:
+
+- [How Flink became an Apache Top-Level Project](http://dataconomy.com/how-flink-became-an-apache-top-level-project/)
+
+- [Stale Synchronous Parallelism: The new frontier for Apache Flink?](https://www.linkedin.com/pulse/stale-synchronous-parallelism-new-frontier-apache-flink-nam-luc-tran?utm_content=buffer461af&utm_medium=social&utm_source=linkedin.com&utm_campaign=buffer)
+
+- [Distributed data processing with Apache Flink](http://www.hadoopsphere.com/2015/02/distributed-data-processing-with-apache.html)
+
+- [Ciao latency, hello speed](http://www.hadoopsphere.com/2015/02/ciao-latency-hallo-speed.html)
+
+##In the Flink master
+
+The following features have been now merged in Flinkâs master repository.
+
+###Gelly
+
+Gelly, Flinkâs Graph API allows users to manipulate graph-shaped data
+directly. Hereâs for example a calculation of shortest paths in a
+graph:
+
+{% highlight java %}
+Graph<Long, Double, Double> graph = Graph.fromDataSet(vertices, edges, env);
+
+DataSet<Vertex<Long, Double>> singleSourceShortestPaths = graph
+ .run(new SingleSourceShortestPaths<Long>(srcVertexId,
+ maxIterations)).getVertices();
+{% endhighlight %}
+
+See more Gelly examples
+[here](https://github.com/apache/flink/tree/master/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example).
+
+###Flink Expressions
+
+The newly merged
+[flink-expressions](https://github.com/apache/flink/tree/master/flink-staging/flink-expressions)
+module is the first step in Flinkâs roadmap towards logical queries
+and SQL support. Hereâs a preview on how you can read two CSV file,
+assign a logical schema to, and apply transformations like filters and
+joins using logical attributes rather than physical data types.
+
+{% highlight scala %}
+val customers = getCustomerDataSet(env)
+ .as('id, 'mktSegment)
+ .filter( 'mktSegment === "AUTOMOBILE" )
+
+val orders = getOrdersDataSet(env)
+ .filter( o => dateFormat.parse(o.orderDate).before(date) )
+ .as('orderId, 'custId, 'orderDate, 'shipPrio)
+
+val items =
+ orders.join(customers)
+ .where('custId === 'id)
+ .select('orderId, 'orderDate, 'shipPrio)
+{% endhighlight %}
+
+###Access to HCatalog tables
+
+With the [flink-hcatalog
+module](https://github.com/apache/flink/tree/master/flink-staging/flink-hcatalog),
+you can now conveniently access HCatalog/Hive tables. The module
+supports projection (selection and order of fields) and partition
+filters.
+
+###Access to secured YARN clusters/HDFS.
+
+With this change users can access Kerberos secured YARN (and HDFS)
+Hadoop clusters. Also, basic support for accessing secured HDFS with
+a standalone Flink setup is now available.
+
Modified: flink/site/blog/feed.xml
URL: http://svn.apache.org/viewvc/flink/site/blog/feed.xml?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
Binary files - no diff available.
Modified: flink/site/blog/index.html
URL: http://svn.apache.org/viewvc/flink/site/blog/index.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/blog/index.html (original)
+++ flink/site/blog/index.html Mon Mar 2 19:19:25 2015
@@ -140,6 +140,115 @@
<div class="col-md-8">
<article>
+ <h2><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2>
+ <p class="meta">02 Mar 2015</p>
+
+ <div><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>
+
+<h3 id="0.8.1-release">0.8.1 release</h3>
+
+<p>Flink 0.8.1 was released. This bugfixing release resolves a total of 22 issues.</p>
+
+<h3 id="new-committer">New committer</h3>
+
+<p><a href="https://github.com/mxm">Max Michels</a> has been voted a committer by the Flink PMC.</p>
+
+<h3 id="flink-adapter-for-apache-samoa">Flink adapter for Apache SAMOA</h3>
+
+<p><a href="http://samoa.incubator.apache.org">Apache SAMOA (incubating)</a> is a
+distributed streaming machine learning (ML) framework with a
+programming abstraction for distributed streaming ML algorithms. SAMOA
+runs on a variety of backend engines, currently Apache Storm and
+Apache S4. A <a href="https://github.com/apache/incubator-samoa/pull/11">pull
+request</a> is
+available at the SAMOA repository that adds a Flink adapter for SAMOA.</p>
+
+<h3 id="easy-flink-deployment-on-google-compute-cloud">Easy Flink deployment on Google Compute Cloud</h3>
+
+<p>Flink is now integrated in bdutil, Googleâs open source tool for
+creating and configuring (Hadoop) clusters in Google Compute
+Engine. Deployment of Flink clusters in now supported starting with
+<a href="https://groups.google.com/forum/#!topic/gcp-hadoop-announce/uVJ_6y9cGKM">bdutil
+1.2.0</a>.</p>
+
+<h3 id="flink-on-the-web">Flink on the Web</h3>
+
+<p>A new blog post on <a href="http://flink.apache.org/news/2015/02/09/streaming-example.html">Flink
+Streaming</a>
+was published at the blog. Flink was mentioned in several articles on
+the web. Here are some examples:</p>
+
+<ul>
+<li><p><a href="http://dataconomy.com/how-flink-became-an-apache-top-level-project/">How Flink became an Apache Top-Level Project</a></p></li>
+<li><p><a href="https://www.linkedin.com/pulse/stale-synchronous-parallelism-new-frontier-apache-flink-nam-luc-tran?utm_content=buffer461af&utm_medium=social&utm_source=linkedin.com&utm_campaign=buffer">Stale Synchronous Parallelism: The new frontier for Apache Flink?</a></p></li>
+<li><p><a href="http://www.hadoopsphere.com/2015/02/distributed-data-processing-with-apache.html">Distributed data processing with Apache Flink</a></p></li>
+<li><p><a href="http://www.hadoopsphere.com/2015/02/ciao-latency-hallo-speed.html">Ciao latency, hello speed</a></p></li>
+</ul>
+
+<h2 id="in-the-flink-master">In the Flink master</h2>
+
+<p>The following features have been now merged in Flinkâs master repository.</p>
+
+<h3 id="gelly">Gelly</h3>
+
+<p>Gelly, Flinkâs Graph API allows users to manipulate graph-shaped data
+directly. Hereâs for example a calculation of shortest paths in a
+graph:</p>
+
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">Graph</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">,</span> <span class="n">Double</span><span class="o">></span> <span class="n">graph</span> <span class="o">=</span> <span class="n">Graph</span><span class="o">.</span><span class="na">fromDataSet</span><span class="o">(</span><span class="n">vertices</span><span class="o">,</span> <span class="n">edges</span><span class="o">,</span> <span class="n">env</span><span class="o">);</span>
+
+<span class="n">DataSet</span><span class="o"><</span><span class="n">Vertex</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">>></span> <span class="n">singleSourceShortestPaths</span> <span class="o">=</span> <span class="n">graph</span>
+ <span class="o">.</span><span class="na">run</span><span class="o">(</span><span class="k">new</span> <span class="n">SingleSourceShortestPaths</span><span class="o"><</span><span class="n">Long</span><span class="o">>(</span><span class="n">srcVertexId</span><span class="o">,</span>
+ <span class="n">maxIterations</span><span class="o">)).</span><span class="na">getVertices</span><span class="o">();</span></code></pre></div>
+
+
+<p>See more Gelly examples
+<a href="https://github.com/apache/flink/tree/master/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example">here</a>.</p>
+
+<h3 id="flink-expressions">Flink Expressions</h3>
+
+<p>The newly merged
+<a href="https://github.com/apache/flink/tree/master/flink-staging/flink-expressions">flink-expressions</a>
+module is the first step in Flinkâs roadmap towards logical queries
+and SQL support. Hereâs a preview on how you can read two CSV file,
+assign a logical schema to, and apply transformations like filters and
+joins using logical attributes rather than physical data types.</p>
+
+<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">customers</span> <span class="k">=</span> <span class="n">getCustomerDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">as</span><span class="o">(</span><span class="-Symbol">'id</span><span class="o">,</span> <span class="-Symbol">'mktSegment</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="-Symbol">'mktSegment</span> <span class="o">===</span> <span class="s">"AUTOMOBILE"</span> <span class="o">)</span>
+
+<span class="k">val</span> <span class="n">orders</span> <span class="k">=</span> <span class="n">getOrdersDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="n">o</span> <span class="k">=></span> <span class="n">dateFormat</span><span class="o">.</span><span class="n">parse</span><span class="o">(</span><span class="n">o</span><span class="o">.</span><span class="n">orderDate</span><span class="o">).</span><span class="n">before</span><span class="o">(</span><span class="n">date</span><span class="o">)</span> <span class="o">)</span>
+ <span class="o">.</span><span class="n">as</span><span class="o">(</span><span class="-Symbol">'orderId</span><span class="o">,</span> <span class="-Symbol">'custId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'shipPrio</span><span class="o">)</span>
+
+<span class="k">val</span> <span class="n">items</span> <span class="k">=</span>
+ <span class="n">orders</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">customers</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">where</span><span class="o">(</span><span class="-Symbol">'custId</span> <span class="o">===</span> <span class="-Symbol">'id</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">select</span><span class="o">(</span><span class="-Symbol">'orderId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'shipPrio</span><span class="o">)</span></code></pre></div>
+
+
+<h3 id="access-to-hcatalog-tables">Access to HCatalog tables</h3>
+
+<p>With the <a href="https://github.com/apache/flink/tree/master/flink-staging/flink-hcatalog">flink-hcatalog
+module</a>,
+you can now conveniently access HCatalog/Hive tables. The module
+supports projection (selection and order of fields) and partition
+filters.</p>
+
+<h3 id="access-to-secured-yarn-clusters/hdfs.">Access to secured YARN clusters/HDFS.</h3>
+
+<p>With this change users can access Kerberos secured YARN (and HDFS)
+Hadoop clusters. Also, basic support for accessing secured HDFS with
+a standalone Flink setup is now available.</p>
+</div>
+ <a href="/news/2015/03/02/february-2015-in-flink.html#disqus_thread">February 2015 in the Flink community</a>
+ </article>
+
+ <article>
<h2><a href="/news/2015/02/09/streaming-example.html">Introducing Flink Streaming</a></h2>
<p class="meta">09 Feb 2015</p>
@@ -1331,96 +1440,6 @@ robust, as well as breaking API changes.
<a href="/news/2014/08/26/release-0.6.html#disqus_thread">Apache Flink 0.6 available</a>
</article>
- <article>
- <h2><a href="/news/2014/05/31/release-0.5.html">Stratosphere version 0.5 available</a></h2>
- <p class="meta">31 May 2014</p>
-
- <div><p>We are happy to announce a new major Stratosphere release, version 0.5. This release adds many new features and improves the interoperability, stability, and performance of the system. The major theme of the release is the completely new Java API that makes it easy to write powerful distributed programs.</p>
-
-<p>The release can be downloaded from the <a href="http://stratosphere.eu/downloads/">Stratosphere website</a> and from <a href="https://github.com/stratosphere/stratosphere/releases/tag/release-0.5">GitHub</a>. All components are available as Apache Maven dependencies, making it simple to include Stratosphere in other projects. The website provides <a href="http://stratosphere.eu/docs/0.5/">extensive documentation</a> of the system and the new features.</p>
-
-<h2 id="shortlist-of-new-features">Shortlist of new Features</h2>
-
-<p>Below is a short list of the most important additions to the Stratosphere system.</p>
-
-<h4 id="new-java-api">New Java API</h4>
-
-<p>This release introduces a completely new <strong>data set-centric Java API</strong>. This programming model significantly eases the development of Stratosphere programs, supports flexible use of regular Java classes as data types, and adds many new built-in operators to simplify the writing of powerful programs. The result are programs that need less code, are more readable, interoperate better with existing code, and execute faster.</p>
-
-<p>Take a look at the <a href="http://stratosphere.eu/docs/0.5/programming_guides/examples_java.html">examples</a> to get a feel for the API.</p>
-
-<h4 id="general-api-improvements">General API Improvements</h4>
-
-<p><strong>Broadcast Variables:</strong> Publish a data set to all instances of another operator. This is handy if the your operator depends on the result of a computation, e.g., filter all values smaller than the average.</p>
-
-<p><strong>Distributed Cache:</strong> Make (local and HDFS) files locally available on each machine processing a task.</p>
-
-<p><strong>Iteration Termination Improvements</strong> Iterative algorithms can now terminate based on intermediate data sets, not only through aggregated statistics.</p>
-
-<p><strong>Collection data sources and sinks:</strong> Speed-up the development and testing of Stratosphere programs by reading data from regular Java collections and inserting back into them.</p>
-
-<p><strong>JDBC data sources and sinks:</strong> Read data from and write data to relational databases using a JDBC driver.</p>
-
-<p><strong>Hadoop input format and output format support:</strong> Read and write data with any Hadoop input or output format.</p>
-
-<p><strong>Support for Avro encoded data:</strong> Read data that has been materialized using Avro.</p>
-
-<p><strong>Deflate Files:</strong> Stratosphere now transparently reads <code>.deflate</code> compressed files.</p>
-
-<h4 id="runtime-and-optimizer-improvements">Runtime and Optimizer Improvements</h4>
-
-<p><strong>DAG Runtime Streaming:</strong> Detection and resolution of streaming data flow deadlocks in the data flow optimizer.</p>
-
-<p><strong>Intermediate results across iteration boundaries:</strong> Intermediate results computed outside iterative parts can be used inside iterative parts of the program.</p>
-
-<p><strong>Stability fixes:</strong> Various stability fixes in both optimizer and runtime.</p>
-
-<h4 id="setup-&-tooling">Setup & Tooling</h4>
-
-<p><strong>Improved YARN support:</strong> Many improvements based on user-feedback: Packaging, Permissions, Error handling.</p>
-
-<p><strong>Java 8 compatibility</strong></p>
-
-<h2 id="contributors">Contributors</h2>
-
-<p>In total, 26 people have contributed to Stratosphere since the last release. Thank you for making this project possible!</p>
-
-<ul>
-<li>Alexander Alexandrov</li>
-<li>Jesus Camacho</li>
-<li>Ufuk Celebi</li>
-<li>Mikhail Erofeev</li>
-<li>Stephan Ewen</li>
-<li>Alexandr Ferodov</li>
-<li>Filip Haase</li>
-<li>Jonathan Hasenberg</li>
-<li>Markus Holzemer</li>
-<li>Fabian Hueske</li>
-<li>Vasia Kalavri</li>
-<li>Aljoscha Krettek</li>
-<li>Rajika Kumarasiri</li>
-<li>Sebastian Kunert</li>
-<li>Aaron Lam</li>
-<li>Robert Metzger</li>
-<li>Faisal Moeen</li>
-<li>Martin Neumann</li>
-<li>Mingliang Qi</li>
-<li>Till Rohrmann</li>
-<li>Chesnay Schepler</li>
-<li>Vyachislav Soludev</li>
-<li>Tuan Trieu</li>
-<li>Artem Tsikiridis</li>
-<li>Timo Walther</li>
-<li>Robert Waury</li>
-</ul>
-
-<h2 id="stratosphere-is-going-apache">Stratosphere is going Apache</h2>
-
-<p>The Stratosphere project has been accepted to the Apache Incubator and will continue its work under the umbrella of the Apache Software Foundation. Due to a name conflict, we are switching the name of the project. We will make future releases of Stratosphere through the Apache foundation under a new name.</p>
-</div>
- <a href="/news/2014/05/31/release-0.5.html#disqus_thread">Stratosphere version 0.5 available</a>
- </article>
-
</div>
<div class="col-md-2"></div>
</div>
Modified: flink/site/blog/page2/index.html
URL: http://svn.apache.org/viewvc/flink/site/blog/page2/index.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/blog/page2/index.html (original)
+++ flink/site/blog/page2/index.html Mon Mar 2 19:19:25 2015
@@ -140,6 +140,96 @@
<div class="col-md-8">
<article>
+ <h2><a href="/news/2014/05/31/release-0.5.html">Stratosphere version 0.5 available</a></h2>
+ <p class="meta">31 May 2014</p>
+
+ <div><p>We are happy to announce a new major Stratosphere release, version 0.5. This release adds many new features and improves the interoperability, stability, and performance of the system. The major theme of the release is the completely new Java API that makes it easy to write powerful distributed programs.</p>
+
+<p>The release can be downloaded from the <a href="http://stratosphere.eu/downloads/">Stratosphere website</a> and from <a href="https://github.com/stratosphere/stratosphere/releases/tag/release-0.5">GitHub</a>. All components are available as Apache Maven dependencies, making it simple to include Stratosphere in other projects. The website provides <a href="http://stratosphere.eu/docs/0.5/">extensive documentation</a> of the system and the new features.</p>
+
+<h2 id="shortlist-of-new-features">Shortlist of new Features</h2>
+
+<p>Below is a short list of the most important additions to the Stratosphere system.</p>
+
+<h4 id="new-java-api">New Java API</h4>
+
+<p>This release introduces a completely new <strong>data set-centric Java API</strong>. This programming model significantly eases the development of Stratosphere programs, supports flexible use of regular Java classes as data types, and adds many new built-in operators to simplify the writing of powerful programs. The result are programs that need less code, are more readable, interoperate better with existing code, and execute faster.</p>
+
+<p>Take a look at the <a href="http://stratosphere.eu/docs/0.5/programming_guides/examples_java.html">examples</a> to get a feel for the API.</p>
+
+<h4 id="general-api-improvements">General API Improvements</h4>
+
+<p><strong>Broadcast Variables:</strong> Publish a data set to all instances of another operator. This is handy if the your operator depends on the result of a computation, e.g., filter all values smaller than the average.</p>
+
+<p><strong>Distributed Cache:</strong> Make (local and HDFS) files locally available on each machine processing a task.</p>
+
+<p><strong>Iteration Termination Improvements</strong> Iterative algorithms can now terminate based on intermediate data sets, not only through aggregated statistics.</p>
+
+<p><strong>Collection data sources and sinks:</strong> Speed-up the development and testing of Stratosphere programs by reading data from regular Java collections and inserting back into them.</p>
+
+<p><strong>JDBC data sources and sinks:</strong> Read data from and write data to relational databases using a JDBC driver.</p>
+
+<p><strong>Hadoop input format and output format support:</strong> Read and write data with any Hadoop input or output format.</p>
+
+<p><strong>Support for Avro encoded data:</strong> Read data that has been materialized using Avro.</p>
+
+<p><strong>Deflate Files:</strong> Stratosphere now transparently reads <code>.deflate</code> compressed files.</p>
+
+<h4 id="runtime-and-optimizer-improvements">Runtime and Optimizer Improvements</h4>
+
+<p><strong>DAG Runtime Streaming:</strong> Detection and resolution of streaming data flow deadlocks in the data flow optimizer.</p>
+
+<p><strong>Intermediate results across iteration boundaries:</strong> Intermediate results computed outside iterative parts can be used inside iterative parts of the program.</p>
+
+<p><strong>Stability fixes:</strong> Various stability fixes in both optimizer and runtime.</p>
+
+<h4 id="setup-&-tooling">Setup & Tooling</h4>
+
+<p><strong>Improved YARN support:</strong> Many improvements based on user-feedback: Packaging, Permissions, Error handling.</p>
+
+<p><strong>Java 8 compatibility</strong></p>
+
+<h2 id="contributors">Contributors</h2>
+
+<p>In total, 26 people have contributed to Stratosphere since the last release. Thank you for making this project possible!</p>
+
+<ul>
+<li>Alexander Alexandrov</li>
+<li>Jesus Camacho</li>
+<li>Ufuk Celebi</li>
+<li>Mikhail Erofeev</li>
+<li>Stephan Ewen</li>
+<li>Alexandr Ferodov</li>
+<li>Filip Haase</li>
+<li>Jonathan Hasenberg</li>
+<li>Markus Holzemer</li>
+<li>Fabian Hueske</li>
+<li>Vasia Kalavri</li>
+<li>Aljoscha Krettek</li>
+<li>Rajika Kumarasiri</li>
+<li>Sebastian Kunert</li>
+<li>Aaron Lam</li>
+<li>Robert Metzger</li>
+<li>Faisal Moeen</li>
+<li>Martin Neumann</li>
+<li>Mingliang Qi</li>
+<li>Till Rohrmann</li>
+<li>Chesnay Schepler</li>
+<li>Vyachislav Soludev</li>
+<li>Tuan Trieu</li>
+<li>Artem Tsikiridis</li>
+<li>Timo Walther</li>
+<li>Robert Waury</li>
+</ul>
+
+<h2 id="stratosphere-is-going-apache">Stratosphere is going Apache</h2>
+
+<p>The Stratosphere project has been accepted to the Apache Incubator and will continue its work under the umbrella of the Apache Software Foundation. Due to a name conflict, we are switching the name of the project. We will make future releases of Stratosphere through the Apache foundation under a new name.</p>
+</div>
+ <a href="/news/2014/05/31/release-0.5.html#disqus_thread">Stratosphere version 0.5 available</a>
+ </article>
+
+ <article>
<h2><a href="/news/2014/04/16/stratosphere-goes-apache-incubator.html">Stratosphere accepted as Apache Incubator Project</a></h2>
<p class="meta">16 Apr 2014</p>
@@ -685,54 +775,6 @@ For a complete overview of the renamings
<a href="/news/2013/12/13/humboldt-innovation-award.html#disqus_thread">Stratosphere wins award at Humboldt Innovation Competition "Big Data: Research meets Startups"</a>
</article>
- <article>
- <h2><a href="/news/2013/10/21/cikm2013-paper.html">Paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed Iterative Data Processing" accepted at CIKM 2013</a></h2>
- <p class="meta">21 Oct 2013</p>
-
- <div><p>Our paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed
-Iterative Data Processing" authored by Sebastian Schelter, Kostas
-Tzoumas, Stephan Ewen and Volker Markl has been accepted accepted at the
-ACM International Conference on Information and Knowledge Management
-(CIKM 2013) in San Francisco.</p>
-
-<p><strong>Abstract</strong></p>
-
-<p>Executing data-parallel iterative algorithms on large datasets is
-crucial for many advanced analytical applications in the fields of data
-mining and machine learning. Current systems for executing iterative
-tasks in large clusters typically achieve fault tolerance through
-rollback recovery. The principle behind this pessimistic approach is to
-periodically checkpoint the algorithm state. Upon failure, the system
-restores a consistent state from a previously written checkpoint and
-resumes execution from that point.</p>
-
-<p>We propose an optimistic recovery mechanism using algorithmic
-compensations. Our method leverages the robust, self-correcting nature
-of a large class of fixpoint algorithms used in data mining and machine
-learning, which converge to the correct solution from various
-intermediate consistent states. In the case of a failure, we apply a
-user-defined compensate function that algorithmically creates such a
-consistent state, instead of rolling back to a previous checkpointed
-state. Our optimistic recovery does not checkpoint any state and hence
-achieves optimal failure-free performance with respect to the overhead
-necessary for guaranteeing fault tolerance. We illustrate the
-applicability of this approach for three wide classes of problems.
-Furthermore, we show how to implement the proposed optimistic recovery
-mechanism in a data flow system. Similar to the Combine operator in
-MapReduce, our proposed functionality is optional and can be applied to
-increase performance without changing the semantics of programs. In an
-experimental evaluation on large datasets, we show that our proposed
-approach provides optimal failure-free performance. In the absence of
-failures our optimistic scheme is able to outperform a pessimistic
-approach by a factor of two to five. In presence of failures, our
-approach provides fast recovery and outperforms pessimistic approaches
-in the majority of cases.</p>
-
-<p><a href="/assets/papers/optimistic.pdf">Download the paper [PDF]</a></p>
-</div>
- <a href="/news/2013/10/21/cikm2013-paper.html#disqus_thread">Paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed Iterative Data Processing" accepted at CIKM 2013</a>
- </article>
-
</div>
<div class="col-md-2"></div>
</div>
Modified: flink/site/blog/page3/index.html
URL: http://svn.apache.org/viewvc/flink/site/blog/page3/index.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/blog/page3/index.html (original)
+++ flink/site/blog/page3/index.html Mon Mar 2 19:19:25 2015
@@ -140,6 +140,54 @@
<div class="col-md-8">
<article>
+ <h2><a href="/news/2013/10/21/cikm2013-paper.html">Paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed Iterative Data Processing" accepted at CIKM 2013</a></h2>
+ <p class="meta">21 Oct 2013</p>
+
+ <div><p>Our paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed
+Iterative Data Processing" authored by Sebastian Schelter, Kostas
+Tzoumas, Stephan Ewen and Volker Markl has been accepted accepted at the
+ACM International Conference on Information and Knowledge Management
+(CIKM 2013) in San Francisco.</p>
+
+<p><strong>Abstract</strong></p>
+
+<p>Executing data-parallel iterative algorithms on large datasets is
+crucial for many advanced analytical applications in the fields of data
+mining and machine learning. Current systems for executing iterative
+tasks in large clusters typically achieve fault tolerance through
+rollback recovery. The principle behind this pessimistic approach is to
+periodically checkpoint the algorithm state. Upon failure, the system
+restores a consistent state from a previously written checkpoint and
+resumes execution from that point.</p>
+
+<p>We propose an optimistic recovery mechanism using algorithmic
+compensations. Our method leverages the robust, self-correcting nature
+of a large class of fixpoint algorithms used in data mining and machine
+learning, which converge to the correct solution from various
+intermediate consistent states. In the case of a failure, we apply a
+user-defined compensate function that algorithmically creates such a
+consistent state, instead of rolling back to a previous checkpointed
+state. Our optimistic recovery does not checkpoint any state and hence
+achieves optimal failure-free performance with respect to the overhead
+necessary for guaranteeing fault tolerance. We illustrate the
+applicability of this approach for three wide classes of problems.
+Furthermore, we show how to implement the proposed optimistic recovery
+mechanism in a data flow system. Similar to the Combine operator in
+MapReduce, our proposed functionality is optional and can be applied to
+increase performance without changing the semantics of programs. In an
+experimental evaluation on large datasets, we show that our proposed
+approach provides optimal failure-free performance. In the absence of
+failures our optimistic scheme is able to outperform a pessimistic
+approach by a factor of two to five. In presence of failures, our
+approach provides fast recovery and outperforms pessimistic approaches
+in the majority of cases.</p>
+
+<p><a href="/assets/papers/optimistic.pdf">Download the paper [PDF]</a></p>
+</div>
+ <a href="/news/2013/10/21/cikm2013-paper.html#disqus_thread">Paper "âAll Roads Lead to Rome:â Optimistic Recovery for Distributed Iterative Data Processing" accepted at CIKM 2013</a>
+ </article>
+
+ <article>
<h2><a href="/news/2013/03/27/www-demo-paper.html">Demo Paper "Large-Scale Social-Media Analytics on Stratosphere" Accepted at WWW 2013</a></h2>
<p class="meta">27 Mar 2013</p>
Modified: flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html
URL: http://svn.apache.org/viewvc/flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html (original)
+++ flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html Mon Mar 2 19:19:25 2015
@@ -2,16 +2,16 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_71) on Fri Feb 20 12:21:56 CET 2015 -->
+<!-- Generated by javadoc (version 1.7.0_71) on Thu Feb 05 13:11:32 CET 2015 -->
<meta http-equiv="Content-Type" content="text/html" charset="UTF-8">
-<title>JobManagerInfoServlet (Apache Flink 0.8-SNAPSHOT API)</title>
-<meta name="date" content="2015-02-20">
+<title>JobmanagerInfoServlet (flink 0.7-incubating-SNAPSHOT API)</title>
+<meta name="date" content="2015-02-05">
<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="JobManagerInfoServlet (Apache Flink 0.8-SNAPSHOT API)";
+ parent.document.title="JobmanagerInfoServlet (flink 0.7-incubating-SNAPSHOT API)";
}
//-->
</script>
@@ -28,13 +28,13 @@
<li><a href="../../../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/JobManagerInfoServlet.html">Use</a></li>
+<li><a href="class-use/JobmanagerInfoServlet.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../../help-doc.html">Help</a></li>
</ul>
-<div class="aboutLanguage"><em><a href=/docs/0.8/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
+<div class="aboutLanguage"><em><a href=/docs/0.7-incubating/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
</div>
<div class="subNav">
<ul class="navList">
@@ -42,8 +42,8 @@
<li><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JsonFactory.html" title="class in org.apache.flink.runtime.jobmanager.web"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
-<li><a href="../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html" target="_top">Frames</a></li>
-<li><a href="JobManagerInfoServlet.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html" target="_top">Frames</a></li>
+<li><a href="JobmanagerInfoServlet.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li>
@@ -82,7 +82,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.flink.runtime.jobmanager.web</div>
-<h2 title="Class JobManagerInfoServlet" class="title">Class JobManagerInfoServlet</h2>
+<h2 title="Class JobmanagerInfoServlet" class="title">Class JobmanagerInfoServlet</h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
@@ -95,7 +95,7 @@
<li>javax.servlet.http.HttpServlet</li>
<li>
<ul class="inheritance">
-<li>org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet</li>
+<li>org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet</li>
</ul>
</li>
</ul>
@@ -112,9 +112,9 @@
</dl>
<hr>
<br>
-<pre>public class <span class="strong">JobManagerInfoServlet</span>
+<pre>public class <span class="strong">JobmanagerInfoServlet</span>
extends javax.servlet.http.HttpServlet</pre>
-<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../../serialized-form.html#org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet">Serialized Form</a></dd></dl>
+<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../../serialized-form.html#org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet">Serialized Form</a></dd></dl>
</li>
</ul>
</div>
@@ -133,7 +133,7 @@ extends javax.servlet.http.HttpServlet</
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html#JobManagerInfoServlet(org.apache.flink.runtime.jobmanager.JobManager)">JobManagerInfoServlet</a></strong>(<a href="../../../../../../org/apache/flink/runtime/jobmanager/JobManager.html" title="class in org.apache.flink.runtime.jobmanager">JobManager</a> jobmanager)</code> </td>
+<td class="colOne"><code><strong><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html#JobmanagerInfoServlet(org.apache.flink.runtime.jobmanager.JobManager)">JobmanagerInfoServlet</a></strong>(<a href="../../../../../../org/apache/flink/runtime/jobmanager/JobManager.html" title="class in org.apache.flink.runtime.jobmanager">JobManager</a> jobmanager)</code> </td>
</tr>
</table>
</li>
@@ -152,7 +152,7 @@ extends javax.servlet.http.HttpServlet</
</tr>
<tr class="altColor">
<td class="colFirst"><code>protected void</code></td>
-<td class="colLast"><code><strong><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html#doGet(javax.servlet.http.HttpServletRequest,%20javax.servlet.http.HttpServletResponse)">doGet</a></strong>(javax.servlet.http.HttpServletRequest req,
+<td class="colLast"><code><strong><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html#doGet(javax.servlet.http.HttpServletRequest,%20javax.servlet.http.HttpServletResponse)">doGet</a></strong>(javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)</code> </td>
</tr>
</table>
@@ -191,13 +191,13 @@ extends javax.servlet.http.HttpServlet</
<!-- -->
</a>
<h3>Constructor Detail</h3>
-<a name="JobManagerInfoServlet(org.apache.flink.runtime.jobmanager.JobManager)">
+<a name="JobmanagerInfoServlet(org.apache.flink.runtime.jobmanager.JobManager)">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
-<h4>JobManagerInfoServlet</h4>
-<pre>public JobManagerInfoServlet(<a href="../../../../../../org/apache/flink/runtime/jobmanager/JobManager.html" title="class in org.apache.flink.runtime.jobmanager">JobManager</a> jobmanager)</pre>
+<h4>JobmanagerInfoServlet</h4>
+<pre>public JobmanagerInfoServlet(<a href="../../../../../../org/apache/flink/runtime/jobmanager/JobManager.html" title="class in org.apache.flink.runtime.jobmanager">JobManager</a> jobmanager)</pre>
</li>
</ul>
</li>
@@ -243,13 +243,13 @@ extends javax.servlet.http.HttpServlet</
<li><a href="../../../../../../overview-summary.html">Overview</a></li>
<li><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/JobManagerInfoServlet.html">Use</a></li>
+<li><a href="class-use/JobmanagerInfoServlet.html">Use</a></li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../../help-doc.html">Help</a></li>
</ul>
-<div class="aboutLanguage"><em><a href=/docs/0.8/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
+<div class="aboutLanguage"><em><a href=/docs/0.7-incubating/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
</div>
<div class="subNav">
<ul class="navList">
@@ -257,8 +257,8 @@ extends javax.servlet.http.HttpServlet</
<li><a href="../../../../../../org/apache/flink/runtime/jobmanager/web/JsonFactory.html" title="class in org.apache.flink.runtime.jobmanager.web"><span class="strong">Next Class</span></a></li>
</ul>
<ul class="navList">
-<li><a href="../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html" target="_top">Frames</a></li>
-<li><a href="JobManagerInfoServlet.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html" target="_top">Frames</a></li>
+<li><a href="JobmanagerInfoServlet.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li>
@@ -294,6 +294,6 @@ extends javax.servlet.http.HttpServlet</
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2015 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
+<p class="legalCopy"><small>Copyright © 2014–2015 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
</body>
</html>
Modified: flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html
URL: http://svn.apache.org/viewvc/flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html (original)
+++ flink/site/docs/0.8/api/java/org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html Mon Mar 2 19:19:25 2015
@@ -2,16 +2,16 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_71) on Fri Feb 20 12:21:59 CET 2015 -->
+<!-- Generated by javadoc (version 1.7.0_71) on Thu Feb 05 13:11:34 CET 2015 -->
<meta http-equiv="Content-Type" content="text/html" charset="UTF-8">
-<title>Uses of Class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet (Apache Flink 0.8-SNAPSHOT API)</title>
-<meta name="date" content="2015-02-20">
+<title>Uses of Class org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet (flink 0.7-incubating-SNAPSHOT API)</title>
+<meta name="date" content="2015-02-05">
<link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Uses of Class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet (Apache Flink 0.8-SNAPSHOT API)";
+ parent.document.title="Uses of Class org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet (flink 0.7-incubating-SNAPSHOT API)";
}
//-->
</script>
@@ -27,14 +27,14 @@
<ul class="navList" title="Navigation">
<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
<li><a href="../package-summary.html">Package</a></li>
-<li><a href="../../../../../../../org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html" title="class in org.apache.flink.runtime.jobmanager.web">Class</a></li>
+<li><a href="../../../../../../../org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html" title="class in org.apache.flink.runtime.jobmanager.web">Class</a></li>
<li class="navBarCell1Rev">Use</li>
<li><a href="../package-tree.html">Tree</a></li>
<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../../../help-doc.html">Help</a></li>
</ul>
-<div class="aboutLanguage"><em><a href=/docs/0.8/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
+<div class="aboutLanguage"><em><a href=/docs/0.7-incubating/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
</div>
<div class="subNav">
<ul class="navList">
@@ -42,8 +42,8 @@
<li>Next</li>
</ul>
<ul class="navList">
-<li><a href="../../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html" target="_top">Frames</a></li>
-<li><a href="JobManagerInfoServlet.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/class-use/JobmanagerInfoServlet.html" target="_top">Frames</a></li>
+<li><a href="JobmanagerInfoServlet.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li>
@@ -65,9 +65,9 @@
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<div class="header">
-<h2 title="Uses of Class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet" class="title">Uses of Class<br>org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet</h2>
+<h2 title="Uses of Class org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet" class="title">Uses of Class<br>org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet</h2>
</div>
-<div class="classUseContainer">No usage of org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet</div>
+<div class="classUseContainer">No usage of org.apache.flink.runtime.jobmanager.web.JobmanagerInfoServlet</div>
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a name="navbar_bottom">
<!-- -->
@@ -77,14 +77,14 @@
<ul class="navList" title="Navigation">
<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
<li><a href="../package-summary.html">Package</a></li>
-<li><a href="../../../../../../../org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.html" title="class in org.apache.flink.runtime.jobmanager.web">Class</a></li>
+<li><a href="../../../../../../../org/apache/flink/runtime/jobmanager/web/JobmanagerInfoServlet.html" title="class in org.apache.flink.runtime.jobmanager.web">Class</a></li>
<li class="navBarCell1Rev">Use</li>
<li><a href="../package-tree.html">Tree</a></li>
<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../../../help-doc.html">Help</a></li>
</ul>
-<div class="aboutLanguage"><em><a href=/docs/0.8/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
+<div class="aboutLanguage"><em><a href=/docs/0.7-incubating/ target=_top><h1>Back to Flink Documentation</h1></a></em></div>
</div>
<div class="subNav">
<ul class="navList">
@@ -92,8 +92,8 @@
<li>Next</li>
</ul>
<ul class="navList">
-<li><a href="../../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/class-use/JobManagerInfoServlet.html" target="_top">Frames</a></li>
-<li><a href="JobManagerInfoServlet.html" target="_top">No Frames</a></li>
+<li><a href="../../../../../../../index.html?org/apache/flink/runtime/jobmanager/web/class-use/JobmanagerInfoServlet.html" target="_top">Frames</a></li>
+<li><a href="JobmanagerInfoServlet.html" target="_top">No Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../../../../allclasses-noframe.html">All Classes</a></li>
@@ -114,6 +114,6 @@
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2015 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
+<p class="legalCopy"><small>Copyright © 2014–2015 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
</body>
</html>
Modified: flink/site/downloads.html
URL: http://svn.apache.org/viewvc/flink/site/downloads.html?rev=1663400&r1=1663399&r2=1663400&view=diff
==============================================================================
--- flink/site/downloads.html (original)
+++ flink/site/downloads.html Mon Mar 2 19:19:25 2015
@@ -136,16 +136,16 @@
<div style="padding-top:120px" class="container">
<h1>Downloads</h1>
-<script type="text/javascript">
+<p><script type="text/javascript">
$( document ).ready(function() {
// Handler for .ready() called.
- $('.ga-track').on('click', function() {
+ $('.ga-track').on('click', function() {
// we just use the element id for tracking with google analytics
- ga('send', 'event', 'button', 'click', $(this).attr('id'));
- });
+ ga('send', 'event', 'button', 'click', $(this).attr('id'));
+ });</p>
-});
-</script>
+<p>});
+</script></p>
<p class="lead">Pick the <strong>Apache Flink</strong> package matching your Hadoop version.</p>
Added: flink/site/news/2015/03/02/february-2015-in-flink.html
URL: http://svn.apache.org/viewvc/flink/site/news/2015/03/02/february-2015-in-flink.html?rev=1663400&view=auto
==============================================================================
--- flink/site/news/2015/03/02/february-2015-in-flink.html (added)
+++ flink/site/news/2015/03/02/february-2015-in-flink.html Mon Mar 2 19:19:25 2015
@@ -0,0 +1,399 @@
+<!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">
+
+ <title>Apache Flink: February 2015 in the Flink community</title>
+ <link rel="shortcut icon" href="favicon.ico" type="image/x-icon">
+ <link rel="icon" href="favicon.ico" type="image/x-icon">
+ <link rel="stylesheet" href="/css/bootstrap.css">
+ <link rel="stylesheet" href="/css/bootstrap-lumen-custom.css">
+ <link rel="stylesheet" href="/css/syntax.css">
+ <link rel="stylesheet" href="/css/custom.css">
+ <link href="/css/main/main.css" rel="stylesheet">
+ <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Flink Blog RSS feed" />
+ <!-- <link href="//maxcdn.bootstrapcdn.com/font-awesome/4.1.0/css/font-awesome.min.css" rel="stylesheet"> -->
+ <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.0/jquery.min.js"></script>
+ <script src="/js/bootstrap.min.js"></script>
+ <script src="/js/codetabs.js"></script>
+ </head>
+ <body>
+ <div class="af-header-container af-inner-pages-navigation">
+ <header>
+ <div class="container">
+ <div class="row">
+ <div class="col-md-1 af-mobile-nav-bar">
+ <a href="/" title="Home">
+ <img class="hidden-xs hidden-sm img-responsive"
+ src="/img/main/logo.png" alt="Apache Flink Logo">
+ </a>
+ <div class="row visible-xs">
+ <div class="col-xs-3">
+ <a href="/" title="Home">
+ <img class="hidden-x hidden-sm img-responsive"
+ src="/img/main/logo.png" alt="Apache Flink Logo">
+ </a>
+ </div>
+ <div class="col-xs-5"></div>
+ <div class="col-xs-4">
+ <div class="af-mobile-btn">
+ <span class="glyphicon glyphicon-plus"></span>
+ </div>
+ </div>
+ </div>
+ </div>
+ <!-- Navigation -->
+ <div class="col-md-11">
+ <nav class="af-main-nav" role="navigation">
+ <ul>
+ <li><a href="#" class="af-nav-links">Quickstart
+ <b class="caret"></b>
+ </a>
+ <ul class="af-dropdown-menu">
+ <li><a href="/docs/0.8/setup_quickstart.html">Setup
+ Flink</a></li>
+ <li><a
+ href="/docs/0.8/java_api_quickstart.html">Java
+ API</a></li>
+ <li><a
+ href="/docs/0.8/scala_api_quickstart.html">Scala
+ API</a></li>
+ </ul></li>
+ <li><a href="/downloads.html">Download</a></li>
+ <li><a href="/docs/0.8/faq.html">FAQ</a></li>
+ <li><a href="#" class="af-nav-links">Documentation <b
+ class="caret"></b></a>
+ <ul class="af-dropdown-menu">
+ <li class="af-separator">Current Stable:</li>
+ <li></li>
+ <li><a href="/docs/0.8/">0.8.1</a></li>
+ <li><a href="/docs/0.8/api/java">0.8.1 Javadocs</a></li>
+ <li><a
+ href="/docs/0.8/api/scala/index.html#org.apache.flink.api.scala.package">0.8.1 Scaladocs</a></li>
+ <li class="divider"></li>
+ <li class="af-separator">Previous:</li>
+ <li></li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating
+ Javadocs</a></li>
+ <li><a
+ href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating
+ Scaladocs</a></li>
+ <li class="divider"></li>
+ <li></li>
+ <li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
+ <li><a href="/docs/0.6-incubating/api/java">0.6-incubating
+ Javadocs</a></li>
+
+ </ul></li>
+ <li><a href="#" class="af-nav-links">Community <b
+ class="caret"></b></a>
+ <ul class="af-dropdown-menu">
+ <li><a href="/community.html#mailing-lists">Mailing
+ Lists</a></li>
+ <li><a href="/community.html#issues">Issues</a></li>
+ <li><a href="/community.html#team">Team</a></li>
+ <li class="divider"></li>
+ <li><a href="/how-to-contribute.html">How To
+ Contribute</a></li>
+ <li><a href="/coding_guidelines.html">Coding
+ Guidelines</a></li>
+ </ul></li>
+ <li><a href="#" class="af-nav-links">Project <b
+ class="caret"></b></a>
+ <ul class="af-dropdown-menu">
+ <li><a href="/material.html">Material</a></li>
+ <li><a href="http://www.apache.org/">Apache Software
+ Foundation <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ <li><a
+ href="https://cwiki.apache.org/confluence/display/FLINK">Wiki
+ <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ <li><a
+ href="https://wiki.apache.org/incubator/StratosphereProposal">Incubator
+ Proposal <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ <li><a href="http://www.apache.org/licenses/LICENSE-2.0">License
+ <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ <li><a href="https://github.com/apache/incubator-flink">Source
+ Code <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ </ul></li>
+ <li><a href="/blog/index.html" class="">Blog</a></li>
+ </ul>
+ </nav>
+ </div>
+ </div>
+ </div>
+ </header>
+</div>
+
+
+ <div style="padding-top:120px" class="container">
+ <div class="container">
+ <div class="row">
+ <div class="col-md-2"></div>
+ <div class="col-md-8">
+ <article>
+ <h2>February 2015 in the Flink community</h2>
+ <p class="meta">02 Mar 2015</p>
+ <div>
+ <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>
+
+<h3 id="0.8.1-release">0.8.1 release</h3>
+
+<p>Flink 0.8.1 was released. This bugfixing release resolves a total of 22 issues.</p>
+
+<h3 id="new-committer">New committer</h3>
+
+<p><a href="https://github.com/mxm">Max Michels</a> has been voted a committer by the Flink PMC.</p>
+
+<h3 id="flink-adapter-for-apache-samoa">Flink adapter for Apache SAMOA</h3>
+
+<p><a href="http://samoa.incubator.apache.org">Apache SAMOA (incubating)</a> is a
+distributed streaming machine learning (ML) framework with a
+programming abstraction for distributed streaming ML algorithms. SAMOA
+runs on a variety of backend engines, currently Apache Storm and
+Apache S4. A <a href="https://github.com/apache/incubator-samoa/pull/11">pull
+request</a> is
+available at the SAMOA repository that adds a Flink adapter for SAMOA.</p>
+
+<h3 id="easy-flink-deployment-on-google-compute-cloud">Easy Flink deployment on Google Compute Cloud</h3>
+
+<p>Flink is now integrated in bdutil, Googleâs open source tool for
+creating and configuring (Hadoop) clusters in Google Compute
+Engine. Deployment of Flink clusters in now supported starting with
+<a href="https://groups.google.com/forum/#!topic/gcp-hadoop-announce/uVJ_6y9cGKM">bdutil
+1.2.0</a>.</p>
+
+<h3 id="flink-on-the-web">Flink on the Web</h3>
+
+<p>A new blog post on <a href="http://flink.apache.org/news/2015/02/09/streaming-example.html">Flink
+Streaming</a>
+was published at the blog. Flink was mentioned in several articles on
+the web. Here are some examples:</p>
+
+<ul>
+<li><p><a href="http://dataconomy.com/how-flink-became-an-apache-top-level-project/">How Flink became an Apache Top-Level Project</a></p></li>
+<li><p><a href="https://www.linkedin.com/pulse/stale-synchronous-parallelism-new-frontier-apache-flink-nam-luc-tran?utm_content=buffer461af&utm_medium=social&utm_source=linkedin.com&utm_campaign=buffer">Stale Synchronous Parallelism: The new frontier for Apache Flink?</a></p></li>
+<li><p><a href="http://www.hadoopsphere.com/2015/02/distributed-data-processing-with-apache.html">Distributed data processing with Apache Flink</a></p></li>
+<li><p><a href="http://www.hadoopsphere.com/2015/02/ciao-latency-hallo-speed.html">Ciao latency, hello speed</a></p></li>
+</ul>
+
+<h2 id="in-the-flink-master">In the Flink master</h2>
+
+<p>The following features have been now merged in Flinkâs master repository.</p>
+
+<h3 id="gelly">Gelly</h3>
+
+<p>Gelly, Flinkâs Graph API allows users to manipulate graph-shaped data
+directly. Hereâs for example a calculation of shortest paths in a
+graph:</p>
+
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">Graph</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">,</span> <span class="n">Double</span><span class="o">></span> <span class="n">graph</span> <span class="o">=</span> <span class="n">Graph</span><span class="o">.</span><span class="na">fromDataSet</span><span class="o">(</span><span class="n">vertices</span><span class="o">,</span> <span class="n">edges</span><span class="o">,</span> <span class="n">env</span><span class="o">);</span>
+
+<span class="n">DataSet</span><span class="o"><</span><span class="n">Vertex</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">>></span> <span class="n">singleSourceShortestPaths</span> <span class="o">=</span> <span class="n">graph</span>
+ <span class="o">.</span><span class="na">run</span><span class="o">(</span><span class="k">new</span> <span class="n">SingleSourceShortestPaths</span><span class="o"><</span><span class="n">Long</span><span class="o">>(</span><span class="n">srcVertexId</span><span class="o">,</span>
+ <span class="n">maxIterations</span><span class="o">)).</span><span class="na">getVertices</span><span class="o">();</span></code></pre></div>
+
+
+<p>See more Gelly examples
+<a href="https://github.com/apache/flink/tree/master/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example">here</a>.</p>
+
+<h3 id="flink-expressions">Flink Expressions</h3>
+
+<p>The newly merged
+<a href="https://github.com/apache/flink/tree/master/flink-staging/flink-expressions">flink-expressions</a>
+module is the first step in Flinkâs roadmap towards logical queries
+and SQL support. Hereâs a preview on how you can read two CSV file,
+assign a logical schema to, and apply transformations like filters and
+joins using logical attributes rather than physical data types.</p>
+
+<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">customers</span> <span class="k">=</span> <span class="n">getCustomerDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">as</span><span class="o">(</span><span class="-Symbol">'id</span><span class="o">,</span> <span class="-Symbol">'mktSegment</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="-Symbol">'mktSegment</span> <span class="o">===</span> <span class="s">"AUTOMOBILE"</span> <span class="o">)</span>
+
+<span class="k">val</span> <span class="n">orders</span> <span class="k">=</span> <span class="n">getOrdersDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="n">o</span> <span class="k">=></span> <span class="n">dateFormat</span><span class="o">.</span><span class="n">parse</span><span class="o">(</span><span class="n">o</span><span class="o">.</span><span class="n">orderDate</span><span class="o">).</span><span class="n">before</span><span class="o">(</span><span class="n">date</span><span class="o">)</span> <span class="o">)</span>
+ <span class="o">.</span><span class="n">as</span><span class="o">(</span><span class="-Symbol">'orderId</span><span class="o">,</span> <span class="-Symbol">'custId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'shipPrio</span><span class="o">)</span>
+
+<span class="k">val</span> <span class="n">items</span> <span class="k">=</span>
+ <span class="n">orders</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">customers</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">where</span><span class="o">(</span><span class="-Symbol">'custId</span> <span class="o">===</span> <span class="-Symbol">'id</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">select</span><span class="o">(</span><span class="-Symbol">'orderId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'shipPrio</span><span class="o">)</span></code></pre></div>
+
+
+<h3 id="access-to-hcatalog-tables">Access to HCatalog tables</h3>
+
+<p>With the <a href="https://github.com/apache/flink/tree/master/flink-staging/flink-hcatalog">flink-hcatalog
+module</a>,
+you can now conveniently access HCatalog/Hive tables. The module
+supports projection (selection and order of fields) and partition
+filters.</p>
+
+<h3 id="access-to-secured-yarn-clusters/hdfs.">Access to secured YARN clusters/HDFS.</h3>
+
+<p>With this change users can access Kerberos secured YARN (and HDFS)
+Hadoop clusters. Also, basic support for accessing secured HDFS with
+a standalone Flink setup is now available.</p>
+
+ </div>
+ </article>
+ </div>
+ <div class="col-md-2"></div>
+ </div>
+ <div class="row" style="padding-top:30px">
+ <div class="col-md-2"></div>
+ <div class="col-md-8">
+ <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>
+ <noscript>Please enable JavaScript to view the <a href="http://disqus.com/?ref_noscript">comments powered by Disqus.</a></noscript>
+ <a href="http://disqus.com" class="dsq-brlink">comments powered by <span class="logo-disqus">Disqus</span></a>
+ </div>
+ <div class="col-md-2"></div>
+ </div>
+</div>
+
+ </div>
+ <!--<section id="af-upfooter" class="af-section">
+ <div class="container">
+ <p>Apache Flink is an effort undergoing incubation at The Apache
+ Software Foundation (ASF), sponsored by the Apache Incubator PMC.
+ Incubation is required of all newly accepted projects until a further
+ review indicates that the infrastructure, communications, and
+ decision making process have stabilized in a manner consistent with
+ other successful ASF projects. While incubation status is not
+ necessarily a reflection of the completeness or stability of the
+ code, it does indicate that the project has yet to be fully endorsed
+ by the ASF.</p>
+ <a href="http://incubator.apache.org"> <img class="img-responsive"
+ src="/img/main/apache-incubator-logo.png" alt="Apache Flink" />
+ </a>
+ <p class="text-center">
+ <a href="/privacy-policy.html" title="Privacy Policy"
+ class="af-privacy-policy">Privacy Policy</a>
+ </p>
+ </div>
+</section>-->
+
+<footer id="af-footer">
+ <div class="container">
+ <div class="row">
+ <div class="col-md-3">
+ <h3>Documentation</h3>
+ <ul class="af-footer-menu">
+
+ <li><a href="/docs/0.8/">0.8.1</a></li>
+ <li><a href="/docs/0.8/api/java/">0.8.1 Javadocs</a></li>
+ <li><a
+ href="/docs/0.8/api/scala/index.html#org.apache.flink.api.scala.package">0.8.1 Scaladocs</a></li>
+ </ul>
+ </div>
+ <div class="col-md-3">
+ <h3>Community</h3>
+ <ul class="af-footer-menu">
+ <li><a href="/community.html#mailing-lists">Mailing Lists</a></li>
+ <li><a href="https://issues.apache.org/jira/browse/FLINK"
+ target="blank">Issues <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a href="/community.html#team">Team</a></li>
+ <li><a href="/how-to-contribute.html">How to contribute</a></li>
+ <li><a href="/coding_guidelines.html">Coding Guidelines</a></li>
+ </ul>
+ </div>
+ <div class="col-md-3">
+ <h3>ASF</h3>
+ <ul class="af-footer-menu">
+ <li><a href="http://www.apache.org/" target="blank">Apache
+ Software foundation <span class="glyphicon glyphicon-new-window"></span>
+ </a></li>
+ <li><a
+ href="http://www.apache.org/foundation/how-it-works.html"
+ target="blank">How it works <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html"
+ target="blank">Thanks <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a
+ href="http://www.apache.org/foundation/sponsorship.html"
+ target="blank">Become a sponsor <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a href="http://incubator.apache.org/projects/flink.html"
+ target="blank">Incubation status page <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ </ul>
+ </div>
+ <div class="col-md-3">
+ <h3>Project</h3>
+ <ul class="af-footer-menu">
+ <li><a href="/material.html" target="blank">Material <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a
+ href="https://cwiki.apache.org/confluence/display/FLINK"
+ target="blank">Wiki <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a
+ href="https://wiki.apache.org/incubator/StratosphereProposal"
+ target="blank">Incubator proposal <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a href="http://www.apache.org/licenses/LICENSE-2.0"
+ target="blank">License <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ <li><a href="https://github.com/apache/incubator-flink"
+ target="blank">Source code <span
+ class="glyphicon glyphicon-new-window"></span></a></li>
+ </ul>
+ </div>
+ </div>
+ </div>
+ <div class="af-footer-bar">
+ <div class="container">
+ <p>Copyright © 2014-2015, <a href="http://www.apache.org">The Apache Software Foundation</a>. All Rights Reserved. Apache and the Apache feather logo are trademarks of the Apache Software Foundation.
+ </p>
+ <div>
+ <div style="float:left">
+ <p>
+ <a href="/privacy-policy.html" title="Privacy Policy" class="af-privacy-policy">Privacy Policy</a>
+ </p>
+ </div>
+ <div style="float:right">
+ <p>
+ <a href="/blog/feed.xml" class="af-privacy-policy">RSS Feed</a>
+ </p>
+ </div>
+ </div>
+ </div>
+ </div>
+</footer>
+
+ <!-- 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>
+ <script src="/js/main/jquery.mobile.events.min.js"></script>
+ <script src="/js/main/main.js"></script>
+ </body>
+</html>