You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/07/01 12:01:03 UTC
[11/54] [partial] flink-web git commit: Revert "[hotfix] Manual build
of docs"
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/apis/web_client.html
----------------------------------------------------------------------
diff --git a/content/docs/master/apis/web_client.html b/content/docs/master/apis/web_client.html
deleted file mode 100644
index 2cf81aa..0000000
--- a/content/docs/master/apis/web_client.html
+++ /dev/null
@@ -1,272 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-<!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 0.10-SNAPSHOT Documentation: Web Client</title>
-
- <link rel="shortcut icon" href="http://flink.apache.org/docs/master/page/favicon.ico" type="image/x-icon">
- <link rel="icon" href="http://flink.apache.org/docs/master/page/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="http://flink.apache.org/docs/master/page/css/flink.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/syntax.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/codetabs.css">
-
- <!-- 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="http://flink.apache.org"><img alt="Apache Flink" src="http://flink.apache.org/docs/master/page/img/navbar-brand-logo.jpg"></a>
- </div>
- </div><!-- /.navbar-header -->
-
- <!-- The navigation links. -->
- <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
- <ul class="nav navbar-nav">
- <li><a href="http://flink.apache.org/docs/master/index.html">Overview<span class="hidden-sm hidden-xs"> 0.10</span></a></li>
-
- <!-- Setup -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/setup" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Setup <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/setup/building.html">Get Flink 0.10-SNAPSHOT</a></li>
-
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Deployment</strong></li>
- <li><a href="http://flink.apache.org/docs/master/setup/local_setup.html" class="active">Local</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/cluster_setup.html">Cluster (Standalone)</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/yarn_setup.html">YARN</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/gce_setup.html">GCloud</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/flink_on_tez.html">Flink on Tez <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="http://flink.apache.org/docs/master/setup/config.html">Configuration</a></li>
- </ul>
- </li>
-
- <!-- Programming Guides -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/apis" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Programming Guides <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/apis/programming_guide.html"><strong>Batch: DataSet API</strong></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/streaming_guide.html"><strong>Streaming: DataStream API</strong> <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/python.html">Python API <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="scala_shell.html">Interactive Scala Shell</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/dataset_transformations.html">Dataset Transformations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/best_practices.html">Best Practices</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/example_connectors.html">Connectors</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/examples.html">Examples</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/local_execution.html">Local Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cluster_execution.html">Cluster Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cli.html">Command Line Interface</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/web_client.html">Web Client</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/iterations.html">Iterations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/java8.html">Java 8</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/hadoop_compatibility.html">Hadoop Compatability <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Libraries -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/libs" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Libraries <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/libs/spargel_guide.html">Graphs: Spargel</a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/gelly_guide.html">Graphs: Gelly <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/ml/">Machine Learning <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/table.html">Relational: Table <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Internals -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/internals" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Internals <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li role="presentation" class="dropdown-header"><strong>Contribute</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/how_to_contribute.html">How to Contribute</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/coding_guidelines.html">Coding Guidelines</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/ide_setup.html">IDE Setup</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/logging.html">Logging</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Internals</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/general_arch.html">Architecture & Process Model</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/types_serialization.html">Type Extraction & Serialization</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/job_scheduling.html">Jobs & Scheduling</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/add_operator.html">How-To: Add an Operator</a></li>
- </ul>
- </li>
- </ul>
- <form class="navbar-form navbar-right hidden-sm hidden-md" role="search" action="http://flink.apache.org/docs/master/search-results.html">
- <div class="form-group">
- <input type="text" class="form-control" name="q" placeholder="Search all pages">
- </div>
- <button type="submit" class="btn btn-default">Search</button>
- </form>
- </div><!-- /.navbar-collapse -->
- </div><!-- /.container -->
- </nav>
-
-
-
-
- <!-- Main content. -->
- <div class="container">
-
-
-<div class="row">
- <div class="col-sm-10 col-sm-offset-1">
- <h1>Web Client</h1>
-
-
-
-<p>Flink provides a web interface to upload jobs, inspect their execution plans, and execute them. The interface is a great tool to showcase programs, debug execution plans, or demonstrate the system as a whole.</p>
-
-<ul id="markdown-toc">
- <li><a href="#starting-stopping-and-configuring-the-web-interface" id="markdown-toc-starting-stopping-and-configuring-the-web-interface">Starting, Stopping, and Configuring the Web Interface</a></li>
- <li><a href="#using-the-web-interface" id="markdown-toc-using-the-web-interface">Using the Web Interface</a> <ul>
- <li><a href="#job-view" id="markdown-toc-job-view">Job View</a></li>
- <li><a href="#plan-view" id="markdown-toc-plan-view">Plan View</a></li>
- </ul>
- </li>
-</ul>
-
-<h2 id="starting-stopping-and-configuring-the-web-interface">Starting, Stopping, and Configuring the Web Interface</h2>
-
-<p>Start the web interface by executing:</p>
-
-<div class="highlight"><pre><code>./bin/start-webclient.sh
-</code></pre></div>
-
-<p>and stop it by calling:</p>
-
-<div class="highlight"><pre><code>./bin/stop-webclient.sh
-</code></pre></div>
-
-<p>The web interface runs on port 8080 by default. To specify a custom port set the <code>webclient.port</code> property in the <em>./conf/flink.yaml</em> configuration file. Jobs are submitted to the JobManager specified by <code>jobmanager.rpc.address</code> and <code>jobmanager.rpc.port</code>. Please consult the <a href="http://flink.apache.org/docs/master/setup/config.html#webclient">configuration</a> page for details and further configuration options.</p>
-
-<h2 id="using-the-web-interface">Using the Web Interface</h2>
-
-<p>The web interface provides two views:</p>
-
-<ol>
- <li>The <strong>job view</strong> to upload, preview, and submit Flink programs.</li>
- <li>The <strong>plan view</strong> to analyze the optimized execution plans of Flink programs.</li>
-</ol>
-
-<h3 id="job-view">Job View</h3>
-
-<p>The interface starts serving the job view.</p>
-
-<p>You can <strong>upload</strong> a Flink program as a jar file. To <strong>execute</strong> an uploaded program:</p>
-
-<ul>
- <li>select it from the job list on the left,</li>
- <li>enter the program arguments in the <em>“Arguments”</em> field (bottom left), and</li>
- <li>click on the <em>“Run Job”</em> button (bottom right).</li>
-</ul>
-
-<p>If the <em>“Show optimizer plan”</em> option is enabled (default), the <em>plan view</em> is display next, otherwise the job is directly submitted to the JobManager for execution.</p>
-
-<p>In case the jar’s manifest file does not specify the program class, you can specify it before the argument list as:</p>
-
-<p><code>
--c <assemblerClass> <programArgs...>
-</code></p>
-
-<h3 id="plan-view">Plan View</h3>
-
-<p>The plan view shows the optimized execution plan of the submitted program in the upper half of the page. The bottom part of the page displays detailed information about the currently selected plan operator including:</p>
-
-<ul>
- <li>the chosen shipping strategies (local forward, hash partition, range partition, broadcast, …),</li>
- <li>the chosen local strategy (sort, hash join, merge join, …),</li>
- <li>inferred data properties (partitioning, grouping, sorting), and</li>
- <li>used optimizer estimates (data size, I/O and network costs, …).</li>
-</ul>
-
-<p>To submit the job for execution, click again on the <em>“Run Job”</em> button in the bottom right.</p>
-
- </div>
-
- <div class="col-sm-10 col-sm-offset-1">
- <!-- Disqus thread and some vertical offset -->
- <div style="margin-top: 75px; margin-bottom: 50px" id="disqus_thread"></div>
- </div>
-</div>
-
- </div><!-- /.container -->
-
- <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
- <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
- <!-- 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="http://flink.apache.org/docs/master/page/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>
-
- <!-- Disqus -->
- <script type="text/javascript">
- var disqus_shortname = 'stratosphere-eu';
- (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>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/apis/zip_elements_guide.html
----------------------------------------------------------------------
diff --git a/content/docs/master/apis/zip_elements_guide.html b/content/docs/master/apis/zip_elements_guide.html
deleted file mode 100644
index 3d71675..0000000
--- a/content/docs/master/apis/zip_elements_guide.html
+++ /dev/null
@@ -1,251 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-<!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 0.10-SNAPSHOT Documentation: Zipping Elements in a DataSet</title>
-
- <link rel="shortcut icon" href="http://flink.apache.org/docs/master/page/favicon.ico" type="image/x-icon">
- <link rel="icon" href="http://flink.apache.org/docs/master/page/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="http://flink.apache.org/docs/master/page/css/flink.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/syntax.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/codetabs.css">
-
- <!-- 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="http://flink.apache.org"><img alt="Apache Flink" src="http://flink.apache.org/docs/master/page/img/navbar-brand-logo.jpg"></a>
- </div>
- </div><!-- /.navbar-header -->
-
- <!-- The navigation links. -->
- <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
- <ul class="nav navbar-nav">
- <li><a href="http://flink.apache.org/docs/master/index.html">Overview<span class="hidden-sm hidden-xs"> 0.10</span></a></li>
-
- <!-- Setup -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/setup" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Setup <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/setup/building.html">Get Flink 0.10-SNAPSHOT</a></li>
-
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Deployment</strong></li>
- <li><a href="http://flink.apache.org/docs/master/setup/local_setup.html" class="active">Local</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/cluster_setup.html">Cluster (Standalone)</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/yarn_setup.html">YARN</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/gce_setup.html">GCloud</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/flink_on_tez.html">Flink on Tez <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="http://flink.apache.org/docs/master/setup/config.html">Configuration</a></li>
- </ul>
- </li>
-
- <!-- Programming Guides -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/apis" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Programming Guides <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/apis/programming_guide.html"><strong>Batch: DataSet API</strong></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/streaming_guide.html"><strong>Streaming: DataStream API</strong> <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/python.html">Python API <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="scala_shell.html">Interactive Scala Shell</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/dataset_transformations.html">Dataset Transformations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/best_practices.html">Best Practices</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/example_connectors.html">Connectors</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/examples.html">Examples</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/local_execution.html">Local Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cluster_execution.html">Cluster Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cli.html">Command Line Interface</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/web_client.html">Web Client</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/iterations.html">Iterations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/java8.html">Java 8</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/hadoop_compatibility.html">Hadoop Compatability <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Libraries -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/libs" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Libraries <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/libs/spargel_guide.html">Graphs: Spargel</a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/gelly_guide.html">Graphs: Gelly <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/ml/">Machine Learning <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/table.html">Relational: Table <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Internals -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/internals" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Internals <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li role="presentation" class="dropdown-header"><strong>Contribute</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/how_to_contribute.html">How to Contribute</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/coding_guidelines.html">Coding Guidelines</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/ide_setup.html">IDE Setup</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/logging.html">Logging</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Internals</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/general_arch.html">Architecture & Process Model</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/types_serialization.html">Type Extraction & Serialization</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/job_scheduling.html">Jobs & Scheduling</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/add_operator.html">How-To: Add an Operator</a></li>
- </ul>
- </li>
- </ul>
- <form class="navbar-form navbar-right hidden-sm hidden-md" role="search" action="http://flink.apache.org/docs/master/search-results.html">
- <div class="form-group">
- <input type="text" class="form-control" name="q" placeholder="Search all pages">
- </div>
- <button type="submit" class="btn btn-default">Search</button>
- </form>
- </div><!-- /.navbar-collapse -->
- </div><!-- /.container -->
- </nav>
-
-
-
-
- <!-- Main content. -->
- <div class="container">
-
-
-<div class="row">
- <div class="col-sm-10 col-sm-offset-1">
- <h1>Zipping Elements in a DataSet</h1>
-
-
-
-<p>In certain algorithms, one may need to assign unique identifiers to data set elements.
-This document shows how <a href="https://github.com/apache/flink/blob/master//flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java">DataSetUtils</a> can be used for that purpose.</p>
-
-<ul id="markdown-toc">
- <li><a href="#zip-with-a-dense-index" id="markdown-toc-zip-with-a-dense-index">Zip with a Dense Index</a></li>
-</ul>
-
-<h3 id="zip-with-a-dense-index">Zip with a Dense Index</h3>
-<p>For assigning consecutive labels to the elements, the <code>zipWithIndex</code> method should be called. It receives a data set as input and returns a new data set of unique id, initial value tuples.
-For example, the following code:</p>
-
-<div class="codetabs">
- <div data-lang="java">
-
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">ExecutionEnvironment</span> <span class="n">env</span> <span class="o">=</span> <span class="n">ExecutionEnvironment</span><span class="o">.</span><span class="na">getExecutionEnvironment</span><span class="o">();</span>
-<span class="n">env</span><span class="o">.</span><span class="na">setParallelism</span><span class="o">(</span><span class="mi">1</span><span class="o">);</span>
-<span class="n">DataSet</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">in</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">fromElements</span><span class="o">(</span><span class="s">"A"</span><span class="o">,</span> <span class="s">"B"</span><span class="o">,</span> <span class="s">"C"</span><span class="o">,</span> <span class="s">"D"</span><span class="o">,</span> <span class="s">"E"</span><span class="o">,</span> <span class="s">"F"</span><span class="o">);</span>
-
-<span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">String</span><span class="o">>></span> <span class="n">result</span> <span class="o">=</span> <span class="n">DataSetUtils</span><span class="o">.</span><span class="na">zipWithIndex</span><span class="o">(</span><span class="n">in</span><span class="o">);</span>
-
-<span class="n">result</span><span class="o">.</span><span class="na">writeAsCsv</span><span class="o">(</span><span class="n">resultPath</span><span class="o">,</span> <span class="s">"\n"</span><span class="o">,</span> <span class="s">","</span><span class="o">);</span>
-<span class="n">env</span><span class="o">.</span><span class="na">execute</span><span class="o">();</span></code></pre></div>
-
- </div>
-
- <div data-lang="scala">
-
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">import</span> <span class="nn">org.apache.flink.api.scala._</span>
-
-<span class="k">val</span> <span class="n">env</span><span class="k">:</span> <span class="kt">ExecutionEnvironment</span> <span class="o">=</span> <span class="nc">ExecutionEnvironment</span><span class="o">.</span><span class="n">getExecutionEnvironment</span>
-<span class="n">env</span><span class="o">.</span><span class="n">setParallelism</span><span class="o">(</span><span class="mi">1</span><span class="o">)</span>
-<span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">String</span><span class="o">]</span> <span class="k">=</span> <span class="n">env</span><span class="o">.</span><span class="n">fromElements</span><span class="o">(</span><span class="s">"A"</span><span class="o">,</span> <span class="s">"B"</span><span class="o">,</span> <span class="s">"C"</span><span class="o">,</span> <span class="s">"D"</span><span class="o">,</span> <span class="s">"E"</span><span class="o">,</span> <span class="s">"F"</span><span class="o">)</span>
-
-<span class="k">val</span> <span class="n">result</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[(</span><span class="kt">Long</span>, <span class="kt">String</span><span class="o">)]</span> <span class="k">=</span> <span class="n">input</span><span class="o">.</span><span class="n">zipWithIndex</span>
-
-<span class="n">result</span><span class="o">.</span><span class="n">writeAsCsv</span><span class="o">(</span><span class="n">resultPath</span><span class="o">,</span> <span class="s">"\n"</span><span class="o">,</span> <span class="s">","</span><span class="o">)</span>
-<span class="n">env</span><span class="o">.</span><span class="n">execute</span><span class="o">()</span></code></pre></div>
-
- </div>
-
-</div>
-
-<p>will yield the tuples: (0,A), (1,B), (2,C), (3,D), (4,E), (5,F)</p>
-
-<p><a href="#top">Back to top</a></p>
-
- </div>
-
- <div class="col-sm-10 col-sm-offset-1">
- <!-- Disqus thread and some vertical offset -->
- <div style="margin-top: 75px; margin-bottom: 50px" id="disqus_thread"></div>
- </div>
-</div>
-
- </div><!-- /.container -->
-
- <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
- <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
- <!-- 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="http://flink.apache.org/docs/master/page/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>
-
- <!-- Disqus -->
- <script type="text/javascript">
- var disqus_shortname = 'stratosphere-eu';
- (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>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/build_docs.sh
----------------------------------------------------------------------
diff --git a/content/docs/master/build_docs.sh b/content/docs/master/build_docs.sh
deleted file mode 100755
index b65f7c9..0000000
--- a/content/docs/master/build_docs.sh
+++ /dev/null
@@ -1,64 +0,0 @@
-#!/usr/bin/env bash
-################################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-################################################################################
-
-
-HAS_JEKYLL=true
-
-command -v jekyll > /dev/null
-if [ $? -ne 0 ]; then
- echo -n "ERROR: Could not find jekyll. "
- echo "Please install with 'gem install jekyll' (see http://jekyllrb.com)."
-
- HAS_JEKYLL=false
-fi
-
-command -v redcarpet > /dev/null
-if [ $? -ne 0 ]; then
- echo -n "WARN: Could not find redcarpet. "
- echo -n "Please install with 'sudo gem install redcarpet' (see https://github.com/vmg/redcarpet). "
- echo "Redcarpet is needed for Markdown parsing and table of contents generation."
-fi
-
-command -v pygmentize > /dev/null
-if [ $? -ne 0 ]; then
- echo -n "WARN: Could not find pygments. "
- echo -n "Please install with 'sudo easy_install Pygments' (requires Python; see http://pygments.org). "
- echo "Pygments is needed for syntax highlighting of the code examples."
-fi
-
-DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
-
-DOCS_SRC=${DIR}
-DOCS_DST=${DOCS_SRC}/target
-
-# default jekyll command is to just build site
-JEKYLL_CMD="build"
-
-# if -p flag is provided, serve site on localhost
-while getopts ":p" opt; do
- case $opt in
- p)
- JEKYLL_CMD="serve --baseurl "" --watch"
- ;;
- esac
-done
-
-if $HAS_JEKYLL; then
- jekyll ${JEKYLL_CMD} --source ${DOCS_SRC} --destination ${DOCS_DST}
-fi
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/faq.html
----------------------------------------------------------------------
diff --git a/content/docs/master/faq.html b/content/docs/master/faq.html
deleted file mode 100644
index c4c5803..0000000
--- a/content/docs/master/faq.html
+++ /dev/null
@@ -1,606 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-<!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 0.10-SNAPSHOT Documentation: Frequently Asked Questions (FAQ)</title>
-
- <link rel="shortcut icon" href="http://flink.apache.org/docs/master/page/favicon.ico" type="image/x-icon">
- <link rel="icon" href="http://flink.apache.org/docs/master/page/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="http://flink.apache.org/docs/master/page/css/flink.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/syntax.css">
- <link rel="stylesheet" href="http://flink.apache.org/docs/master/page/css/codetabs.css">
-
- <!-- 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="http://flink.apache.org"><img alt="Apache Flink" src="http://flink.apache.org/docs/master/page/img/navbar-brand-logo.jpg"></a>
- </div>
- </div><!-- /.navbar-header -->
-
- <!-- The navigation links. -->
- <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
- <ul class="nav navbar-nav">
- <li><a href="http://flink.apache.org/docs/master/index.html">Overview<span class="hidden-sm hidden-xs"> 0.10</span></a></li>
-
- <!-- Setup -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/setup" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Setup <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/setup/building.html">Get Flink 0.10-SNAPSHOT</a></li>
-
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Deployment</strong></li>
- <li><a href="http://flink.apache.org/docs/master/setup/local_setup.html" class="active">Local</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/cluster_setup.html">Cluster (Standalone)</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/yarn_setup.html">YARN</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/gce_setup.html">GCloud</a></li>
- <li><a href="http://flink.apache.org/docs/master/setup/flink_on_tez.html">Flink on Tez <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="http://flink.apache.org/docs/master/setup/config.html">Configuration</a></li>
- </ul>
- </li>
-
- <!-- Programming Guides -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/apis" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Programming Guides <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/apis/programming_guide.html"><strong>Batch: DataSet API</strong></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/streaming_guide.html"><strong>Streaming: DataStream API</strong> <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/python.html">Python API <span class="badge">Beta</span></a></li>
-
- <li class="divider"></li>
- <li><a href="scala_shell.html">Interactive Scala Shell</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/dataset_transformations.html">Dataset Transformations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/best_practices.html">Best Practices</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/example_connectors.html">Connectors</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/examples.html">Examples</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/local_execution.html">Local Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cluster_execution.html">Cluster Execution</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/cli.html">Command Line Interface</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/web_client.html">Web Client</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/iterations.html">Iterations</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/java8.html">Java 8</a></li>
- <li><a href="http://flink.apache.org/docs/master/apis/hadoop_compatibility.html">Hadoop Compatability <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Libraries -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/libs" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Libraries <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li><a href="http://flink.apache.org/docs/master/libs/spargel_guide.html">Graphs: Spargel</a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/gelly_guide.html">Graphs: Gelly <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/ml/">Machine Learning <span class="badge">Beta</span></a></li>
- <li><a href="http://flink.apache.org/docs/master/libs/table.html">Relational: Table <span class="badge">Beta</span></a></li>
- </ul>
- </li>
-
- <!-- Internals -->
- <li class="dropdown">
- <a href="http://flink.apache.org/docs/master/internals" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Internals <span class="caret"></span></a>
- <ul class="dropdown-menu" role="menu">
- <li role="presentation" class="dropdown-header"><strong>Contribute</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/how_to_contribute.html">How to Contribute</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/coding_guidelines.html">Coding Guidelines</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/ide_setup.html">IDE Setup</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/logging.html">Logging</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header"><strong>Internals</strong></li>
- <li><a href="http://flink.apache.org/docs/master/internals/general_arch.html">Architecture & Process Model</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/types_serialization.html">Type Extraction & Serialization</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/job_scheduling.html">Jobs & Scheduling</a></li>
- <li><a href="http://flink.apache.org/docs/master/internals/add_operator.html">How-To: Add an Operator</a></li>
- </ul>
- </li>
- </ul>
- <form class="navbar-form navbar-right hidden-sm hidden-md" role="search" action="http://flink.apache.org/docs/master/search-results.html">
- <div class="form-group">
- <input type="text" class="form-control" name="q" placeholder="Search all pages">
- </div>
- <button type="submit" class="btn btn-default">Search</button>
- </form>
- </div><!-- /.navbar-collapse -->
- </div><!-- /.container -->
- </nav>
-
-
-
-
- <!-- Main content. -->
- <div class="container">
-
-
-<div class="row">
- <div class="col-sm-10 col-sm-offset-1">
- <h1>Frequently Asked Questions (FAQ)</h1>
-
-
-
-<ul id="markdown-toc">
- <li><a href="#general" id="markdown-toc-general">General</a> <ul>
- <li><a href="#is-flink-a-hadoop-project" id="markdown-toc-is-flink-a-hadoop-project">Is Flink a Hadoop Project?</a></li>
- <li><a href="#do-i-have-to-install-apache-hadoop-to-use-flink" id="markdown-toc-do-i-have-to-install-apache-hadoop-to-use-flink">Do I have to install Apache Hadoop to use Flink?</a></li>
- </ul>
- </li>
- <li><a href="#usage" id="markdown-toc-usage">Usage</a> <ul>
- <li><a href="#how-do-i-assess-the-progress-of-a-flink-program" id="markdown-toc-how-do-i-assess-the-progress-of-a-flink-program">How do I assess the progress of a Flink program?</a></li>
- <li><a href="#how-can-i-figure-out-why-a-program-failed" id="markdown-toc-how-can-i-figure-out-why-a-program-failed">How can I figure out why a program failed?</a></li>
- <li><a href="#how-do-i-debug-flink-programs" id="markdown-toc-how-do-i-debug-flink-programs">How do I debug Flink programs?</a></li>
- <li><a href="#what-is-the-parallelism-how-do-i-set-it" id="markdown-toc-what-is-the-parallelism-how-do-i-set-it">What is the parallelism? How do I set it?</a></li>
- </ul>
- </li>
- <li><a href="#errors" id="markdown-toc-errors">Errors</a> <ul>
- <li><a href="#why-am-i-getting-a-nonserializableexception-" id="markdown-toc-why-am-i-getting-a-nonserializableexception-">Why am I getting a “NonSerializableException” ?</a></li>
- <li><a href="#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters" id="markdown-toc-in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters">In Scala API, I get an error about implicit values and evidence parameters</a></li>
- <li><a href="#i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this" id="markdown-toc-i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this">I get an error message saying that not enough buffers are available. How do I fix this?</a></li>
- <li><a href="#my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause" id="markdown-toc-my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause">My job fails early with a java.io.EOFException. What could be the cause?</a></li>
- <li><a href="#in-eclipse-i-get-compilation-errors-in-the-scala-projects" id="markdown-toc-in-eclipse-i-get-compilation-errors-in-the-scala-projects">In Eclipse, I get compilation errors in the Scala projects</a></li>
- <li><a href="#my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types" id="markdown-toc-my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types">My program does not compute the correct result. Why are my custom key types</a></li>
- <li><a href="#i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong" id="markdown-toc-i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong">I get a java.lang.InstantiationException for my data type, what is wrong?</a></li>
- <li><a href="#i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do" id="markdown-toc-i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do">I can’t stop Flink with the provided stop-scripts. What can I do?</a></li>
- <li><a href="#i-got-an-outofmemoryexception-what-can-i-do" id="markdown-toc-i-got-an-outofmemoryexception-what-can-i-do">I got an OutOfMemoryException. What can I do?</a></li>
- <li><a href="#why-do-the-taskmanager-log-files-become-so-huge" id="markdown-toc-why-do-the-taskmanager-log-files-become-so-huge">Why do the TaskManager log files become so huge?</a></li>
- </ul>
- </li>
- <li><a href="#yarn-deployment" id="markdown-toc-yarn-deployment">YARN Deployment</a> <ul>
- <li><a href="#the-yarn-session-runs-only-for-a-few-seconds" id="markdown-toc-the-yarn-session-runs-only-for-a-few-seconds">The YARN session runs only for a few seconds</a></li>
- <li><a href="#the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup" id="markdown-toc-the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup">The YARN session crashes with a HDFS permission exception during startup</a></li>
- </ul>
- </li>
- <li><a href="#features" id="markdown-toc-features">Features</a> <ul>
- <li><a href="#what-kind-of-fault-tolerance-does-flink-provide" id="markdown-toc-what-kind-of-fault-tolerance-does-flink-provide">What kind of fault-tolerance does Flink provide?</a></li>
- <li><a href="#are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported" id="markdown-toc-are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported">Are Hadoop-like utilities, such as Counters and the DistributedCache supported?</a></li>
- </ul>
- </li>
-</ul>
-
-<h2 id="general">General</h2>
-
-<h3 id="is-flink-a-hadoop-project">Is Flink a Hadoop Project?</h3>
-
-<p>Flink is a data processing system and an alternative to Hadoop’s
-MapReduce component. It comes with its own runtime, rather than building on top
-of MapReduce. As such, it can work completely independently of the Hadoop
-ecosystem. However, Flink can also access Hadoop’s distributed file
-system (HDFS) to read and write data, and Hadoop’s next-generation resource
-manager (YARN) to provision cluster resources. Since most Flink users are
-using Hadoop HDFS to store their data, we ship already the required libraries to
-access HDFS.</p>
-
-<h3 id="do-i-have-to-install-apache-hadoop-to-use-flink">Do I have to install Apache Hadoop to use Flink?</h3>
-
-<p>No. Flink can run without a Hadoop installation. However, a very common
-setup is to use Flink to analyze data stored in the Hadoop Distributed
-File System (HDFS). To make these setups work out of the box, we bundle the
-Hadoop client libraries with Flink by default.</p>
-
-<p>Additionally, we provide a special YARN Enabled download of Flink for
-users with an existing Hadoop YARN cluster. <a href="http://hadoop.apache.org/docs/r2.2.0/hadoop-yarn/hadoop-yarn-site/YARN.html">Apache Hadoop
-YARN</a>
-is Hadoop’s cluster resource manager that allows to use
-different execution engines next to each other on a cluster.</p>
-
-<h2 id="usage">Usage</h2>
-
-<h3 id="how-do-i-assess-the-progress-of-a-flink-program">How do I assess the progress of a Flink program?</h3>
-
-<p>There are a multiple of ways to track the progress of a Flink program:</p>
-
-<ul>
- <li>The JobManager (the master of the distributed system) starts a web interface
-to observe program execution. In runs on port 8081 by default (configured in
-<code>conf/flink-config.yml</code>).</li>
- <li>When you start a program from the command line, it will print the status
-changes of all operators as the program progresses through the operations.</li>
- <li>All status changes are also logged to the JobManager’s log file.</li>
-</ul>
-
-<h3 id="how-can-i-figure-out-why-a-program-failed">How can I figure out why a program failed?</h3>
-
-<ul>
- <li>The JobManager web frontend (by default on port 8081) displays the exceptions
-of failed tasks.</li>
- <li>If you run the program from the command-line, task exceptions are printed to
-the standard error stream and shown on the console.</li>
- <li>Both the command line and the web interface allow you to figure out which
-parallel task first failed and caused the other tasks to cancel the execution.</li>
- <li>Failing tasks and the corresponding exceptions are reported in the log files
-of the master and the worker where the exception occurred
-(<code>log/flink-<user>-jobmanager-<host>.log</code> and
-<code>log/flink-<user>-taskmanager-<host>.log</code>).</li>
-</ul>
-
-<h3 id="how-do-i-debug-flink-programs">How do I debug Flink programs?</h3>
-
-<ul>
- <li>When you start a program locally with the <a href="local_execution.html">LocalExecutor</a>,
-you can place breakpoints in your functions and debug them like normal
-Java/Scala programs.</li>
- <li>The <a href="programming_guide.html#accumulators--counters">Accumulators</a> are very helpful in
-tracking the behavior of the parallel execution. They allow you to gather
-information inside the program’s operations and show them after the program
-execution.</li>
-</ul>
-
-<h3 id="what-is-the-parallelism-how-do-i-set-it">What is the parallelism? How do I set it?</h3>
-
-<p>In Flink programs, the parallelism determines how operations are split into
-individual tasks which are assigned to task slots. Each node in a cluster has at
-least one task slot. The total number of task slots is the number of all task slots
-on all machines. If the parallelism is set to <code>N</code>, Flink tries to divide an
-operation into <code>N</code> parallel tasks which can be computed concurrently using the
-available task slots. The number of task slots should be equal to the
-parallelism to ensure that all tasks can be computed in a task slot concurrently.</p>
-
-<p><strong>Note</strong>: Not all operations can be divided into multiple tasks. For example, a
-<code>GroupReduce</code> operation without a grouping has to be performed with a
-parallelism of 1 because the entire group needs to be present at exactly one
-node to perform the reduce operation. Flink will determine whether the
-parallelism has to be 1 and set it accordingly.</p>
-
-<p>The parallelism can be set in numerous ways to ensure a fine-grained control
-over the execution of a Flink program. See
-the <a href="setup/config.html#common-options">Configuration guide</a> for detailed instructions on how to
-set the parallelism. Also check out <a href="setup/config.html#configuring-taskmanager-processing-slots">this figure</a> detailing
-how the processing slots and parallelism are related to each other.</p>
-
-<h2 id="errors">Errors</h2>
-
-<h3 id="why-am-i-getting-a-nonserializableexception-">Why am I getting a “NonSerializableException” ?</h3>
-
-<p>All functions in Flink must be serializable, as defined by <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html">java.io.Serializable</a>.
-Since all function interfaces are serializable, the exception means that one
-of the fields used in your function is not serializable.</p>
-
-<p>In particular, if your function is an inner class, or anonymous inner class,
-it contains a hidden reference to the enclosing class (usually called <code>this$0</code>, if you look
-at the function in the debugger). If the enclosing class is not serializable, this is probably
-the source of the error. Solutions are to</p>
-
-<ul>
- <li>make the function a standalone class, or a static inner class (no more reference to the enclosing class)</li>
- <li>make the enclosing class serializable</li>
- <li>use a Java 8 lambda function.</li>
-</ul>
-
-<h3 id="in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters">In Scala API, I get an error about implicit values and evidence parameters</h3>
-
-<p>It means that the implicit value for the type information could not be provided.
-Make sure that you have an <code>import org.apache.flink.api.scala._</code> statement in your code.</p>
-
-<p>If you are using flink operations inside functions or classes that take
-generic parameters a TypeInformation must be available for that parameter.
-This can be achieved by using a context bound:</p>
-
-<div class="highlight"><pre><code class="language-scala"><span class="k">def</span> <span class="n">myFunction</span><span class="o">[</span><span class="kt">T:</span> <span class="kt">TypeInformation</span><span class="o">](</span><span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">T</span><span class="o">])</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">Seq</span><span class="o">[</span><span class="kt">T</span><span class="o">]]</span> <span class="k">=</span> <span class="o">{</span>
- <span class="n">input</span><span class="o">.</span><span class="n">reduceGroup</span><span class="o">(</span> <span class="n">i</span> <span class="k">=></span> <span class="n">i</span><span class="o">.</span><span class="n">toSeq</span> <span class="o">)</span>
-<span class="o">}</span></code></pre></div>
-
-<p>See <a href="internal_types_serialization.html">Type Extraction and Serialization</a> for
-an in-depth discussion of how Flink handles types.</p>
-
-<h3 id="i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this">I get an error message saying that not enough buffers are available. How do I fix this?</h3>
-
-<p>If you run Flink in a massively parallel setting (100+ parallel threads),
-you need to adapt the number of network buffers via the config parameter
-<code>taskmanager.network.numberOfBuffers</code>.
-As a rule-of-thumb, the number of buffers should be at least
-<code>4 * numberOfNodes * numberOfTasksPerNode^2</code>. See
-<a href="setup/config.html">Configuration Reference</a> for details.</p>
-
-<h3 id="my-job-fails-early-with-a-javaioeofexception-what-could-be-the-cause">My job fails early with a java.io.EOFException. What could be the cause?</h3>
-
-<p>The most common case for these exception is when Flink is set up with the
-wrong HDFS version. Because different HDFS versions are often not compatible
-with each other, the connection between the filesystem master and the client
-breaks.</p>
-
-<div class="highlight"><pre><code class="language-bash">Call to <host:port> failed on <span class="nb">local </span>exception: java.io.EOFException
- at org.apache.hadoop.ipc.Client.wrapException<span class="o">(</span>Client.java:775<span class="o">)</span>
- at org.apache.hadoop.ipc.Client.call<span class="o">(</span>Client.java:743<span class="o">)</span>
- at org.apache.hadoop.ipc.RPC<span class="nv">$Invoker</span>.invoke<span class="o">(</span>RPC.java:220<span class="o">)</span>
- at <span class="nv">$Proxy0</span>.getProtocolVersion<span class="o">(</span>Unknown Source<span class="o">)</span>
- at org.apache.hadoop.ipc.RPC.getProxy<span class="o">(</span>RPC.java:359<span class="o">)</span>
- at org.apache.hadoop.hdfs.DFSClient.createRPCNamenode<span class="o">(</span>DFSClient.java:106<span class="o">)</span>
- at org.apache.hadoop.hdfs.DFSClient.<init><span class="o">(</span>DFSClient.java:207<span class="o">)</span>
- at org.apache.hadoop.hdfs.DFSClient.<init><span class="o">(</span>DFSClient.java:170<span class="o">)</span>
- at org.apache.hadoop.hdfs.DistributedFileSystem.initialize<span class="o">(</span>DistributedFileSystem.java:82<span class="o">)</span>
- at org.apache.flinkruntime.fs.hdfs.DistributedFileSystem.initialize<span class="o">(</span>DistributedFileSystem.java:276</code></pre></div>
-
-<p>Please refer to the <a href="http://flink.apache.org/docs/master/downloads.html#maven">download page</a> and
-the <a href="https://github.com/apache/flink/blob/master/README.md">build instructions</a>
-for details on how to set up Flink for different Hadoop and HDFS versions.</p>
-
-<h3 id="in-eclipse-i-get-compilation-errors-in-the-scala-projects">In Eclipse, I get compilation errors in the Scala projects</h3>
-
-<p>Flink uses a new feature of the Scala compiler (called “quasiquotes”) that have not yet been properly
-integrated with the Eclipse Scala plugin. In order to make this feature available in Eclipse, you
-need to manually configure the <em>flink-scala</em> project to use a <em>compiler plugin</em>:</p>
-
-<ul>
- <li>Right click on <em>flink-scala</em> and choose “Properties”</li>
- <li>Select “Scala Compiler” and click on the “Advanced” tab. (If you do not have that, you probably have not set up Eclipse for Scala properly.)</li>
- <li>Check the box “Use Project Settings”</li>
- <li>In the field “Xplugin”, put the path “/home/<user-name>/.m2/repository/org/scalamacros/paradise_2.10.4/2.0.1/paradise_2.10.4-2.0.1.jar"</user-name></li>
- <li>NOTE: You have to build Flink with Maven on the command line first, to make sure the plugin is downloaded.</li>
-</ul>
-
-<h3 id="my-program-does-not-compute-the-correct-result-why-are-my-custom-key-types">My program does not compute the correct result. Why are my custom key types</h3>
-<p>are not grouped/joined correctly?</p>
-
-<p>Keys must correctly implement the methods <code>java.lang.Object#hashCode()</code>,
-<code>java.lang.Object#equals(Object o)</code>, and <code>java.util.Comparable#compareTo(...)</code>.
-These methods are always backed with default implementations which are usually
-inadequate. Therefore, all keys must override <code>hashCode()</code> and <code>equals(Object o)</code>.</p>
-
-<h3 id="i-get-a-javalanginstantiationexception-for-my-data-type-what-is-wrong">I get a java.lang.InstantiationException for my data type, what is wrong?</h3>
-
-<p>All data type classes must be public and have a public nullary constructor
-(constructor with no arguments). Further more, the classes must not be abstract
-or interfaces. If the classes are internal classes, they must be public and
-static.</p>
-
-<h3 id="i-cant-stop-flink-with-the-provided-stop-scripts-what-can-i-do">I can’t stop Flink with the provided stop-scripts. What can I do?</h3>
-
-<p>Stopping the processes sometimes takes a few seconds, because the shutdown may
-do some cleanup work.</p>
-
-<p>In some error cases it happens that the JobManager or TaskManager cannot be
-stopped with the provided stop-scripts (<code>bin/stop-local.sh</code> or <code>bin/stop-
-cluster.sh</code>). You can kill their processes on Linux/Mac as follows:</p>
-
-<ul>
- <li>Determine the process id (pid) of the JobManager / TaskManager process. You
-can use the <code>jps</code> command on Linux(if you have OpenJDK installed) or command
-<code>ps -ef | grep java</code> to find all Java processes.</li>
- <li>Kill the process with <code>kill -9 <pid></code>, where <code>pid</code> is the process id of the
-affected JobManager or TaskManager process.</li>
-</ul>
-
-<p>On Windows, the TaskManager shows a table of all processes and allows you to
-destroy a process by right its entry.</p>
-
-<h3 id="i-got-an-outofmemoryexception-what-can-i-do">I got an OutOfMemoryException. What can I do?</h3>
-
-<p>These exceptions occur usually when the functions in the program consume a lot
-of memory by collection large numbers of objects, for example in lists or maps.
-The OutOfMemoryExceptions in Java are kind of tricky. The exception is not
-necessarily thrown by the component that allocated most of the memory but by the
-component that tried to requested the latest bit of memory that could not be
-provided.</p>
-
-<p>There are two ways to go about this:</p>
-
-<ol>
- <li>
- <p>See whether you can use less memory inside the functions. For example, use
-arrays of primitive types instead of object types.</p>
- </li>
- <li>
- <p>Reduce the memory that Flink reserves for its own processing. The
-TaskManager reserves a certain portion of the available memory for sorting,
-hashing, caching, network buffering, etc. That part of the memory is unavailable
-to the user-defined functions. By reserving it, the system can guarantee to not
-run out of memory on large inputs, but to plan with the available memory and
-destage operations to disk, if necessary. By default, the system reserves around
-70% of the memory. If you frequently run applications that need more memory in
-the user-defined functions, you can reduce that value using the configuration
-entries <code>taskmanager.memory.fraction</code> or <code>taskmanager.memory.size</code>. See the
-<a href="setup/config.html">Configuration Reference</a> for details. This will leave more memory to JVM heap,
-but may cause data processing tasks to go to disk more often.</p>
- </li>
-</ol>
-
-<h3 id="why-do-the-taskmanager-log-files-become-so-huge">Why do the TaskManager log files become so huge?</h3>
-
-<p>Check the logging behavior of your jobs. Emitting logging per or tuple may be
-helpful to debug jobs in small setups with tiny data sets, it becomes very
-inefficient and disk space consuming if used for large input data.</p>
-
-<h2 id="yarn-deployment">YARN Deployment</h2>
-
-<h3 id="the-yarn-session-runs-only-for-a-few-seconds">The YARN session runs only for a few seconds</h3>
-
-<p>The <code>./bin/yarn-session.sh</code> script is intended to run while the YARN-session is
-open. In some error cases however, the script immediately stops running. The
-output looks like this:</p>
-
-<div class="highlight"><pre><code>07:34:27,004 INFO org.apache.hadoop.yarn.client.api.impl.YarnClientImpl - Submitted application application_1395604279745_273123 to ResourceManager at jobtracker-host
-Flink JobManager is now running on worker1:6123
-JobManager Web Interface: http://jobtracker-host:54311/proxy/application_1295604279745_273123/
-07:34:51,528 INFO org.apache.flinkyarn.Client - Application application_1295604279745_273123 finished with state FINISHED at 1398152089553
-07:34:51,529 INFO org.apache.flinkyarn.Client - Killing the Flink-YARN application.
-07:34:51,529 INFO org.apache.hadoop.yarn.client.api.impl.YarnClientImpl - Killing application application_1295604279745_273123
-07:34:51,534 INFO org.apache.flinkyarn.Client - Deleting files in hdfs://user/marcus/.flink/application_1295604279745_273123
-07:34:51,559 INFO org.apache.flinkyarn.Client - YARN Client is shutting down
-</code></pre></div>
-
-<p>The problem here is that the Application Master (AM) is stopping and the YARN client assumes that the application has finished.</p>
-
-<p>There are three possible reasons for that behavior:</p>
-
-<ul>
- <li>
- <p>The ApplicationMaster exited with an exception. To debug that error, have a
-look in the logfiles of the container. The <code>yarn-site.xml</code> file contains the
-configured path. The key for the path is <code>yarn.nodemanager.log-dirs</code>, the
-default value is <code>${yarn.log.dir}/userlogs</code>.</p>
- </li>
- <li>
- <p>YARN has killed the container that runs the ApplicationMaster. This case
-happens when the AM used too much memory or other resources beyond YARN’s
-limits. In this case, you’ll find error messages in the nodemanager logs on
-the host.</p>
- </li>
- <li>
- <p>The operating system has shut down the JVM of the AM. This can happen if the
-YARN configuration is wrong and more memory than physically available is
-configured. Execute <code>dmesg</code> on the machine where the AM was running to see if
-this happened. You see messages from Linux’ <a href="http://linux-mm.org/OOM_Killer">OOM killer</a>.</p>
- </li>
-</ul>
-
-<h3 id="the-yarn-session-crashes-with-a-hdfs-permission-exception-during-startup">The YARN session crashes with a HDFS permission exception during startup</h3>
-
-<p>While starting the YARN session, you are receiving an exception like this:</p>
-
-<div class="highlight"><pre><code>Exception in thread "main" org.apache.hadoop.security.AccessControlException: Permission denied: user=robert, access=WRITE, inode="/user/robert":hdfs:supergroup:drwxr-xr-x
- at org.apache.hadoop.hdfs.server.namenode.FSPermissionChecker.check(FSPermissionChecker.java:234)
- at org.apache.hadoop.hdfs.server.namenode.FSPermissionChecker.check(FSPermissionChecker.java:214)
- at org.apache.hadoop.hdfs.server.namenode.FSPermissionChecker.checkPermission(FSPermissionChecker.java:158)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkPermission(FSNamesystem.java:5193)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkPermission(FSNamesystem.java:5175)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkAncestorAccess(FSNamesystem.java:5149)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.startFileInternal(FSNamesystem.java:2090)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.startFileInt(FSNamesystem.java:2043)
- at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.startFile(FSNamesystem.java:1996)
- at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.create(NameNodeRpcServer.java:491)
- at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.create(ClientNamenodeProtocolServerSideTranslatorPB.java:301)
- at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java:59570)
- at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
- at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
- at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2053)
- at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2049)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:396)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1491)
- at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2047)
-
- at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
- at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
- at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
- at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
- at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106)
- at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73)
- at org.apache.hadoop.hdfs.DFSOutputStream.newStreamForCreate(DFSOutputStream.java:1393)
- at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1382)
- at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1307)
- at org.apache.hadoop.hdfs.DistributedFileSystem$6.doCall(DistributedFileSystem.java:384)
- at org.apache.hadoop.hdfs.DistributedFileSystem$6.doCall(DistributedFileSystem.java:380)
- at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
- at org.apache.hadoop.hdfs.DistributedFileSystem.create(DistributedFileSystem.java:380)
- at org.apache.hadoop.hdfs.DistributedFileSystem.create(DistributedFileSystem.java:324)
- at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:905)
- at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:886)
- at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:783)
- at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:365)
- at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:338)
- at org.apache.hadoop.fs.FileSystem.copyFromLocalFile(FileSystem.java:2021)
- at org.apache.hadoop.fs.FileSystem.copyFromLocalFile(FileSystem.java:1989)
- at org.apache.hadoop.fs.FileSystem.copyFromLocalFile(FileSystem.java:1954)
- at org.apache.flinkyarn.Utils.setupLocalResource(Utils.java:176)
- at org.apache.flinkyarn.Client.run(Client.java:362)
- at org.apache.flinkyarn.Client.main(Client.java:568)
-</code></pre></div>
-
-<p>The reason for this error is, that the home directory of the user <strong>in HDFS</strong>
-has the wrong permissions. The user (in this case <code>robert</code>) can not create
-directories in his own home directory.</p>
-
-<p>Flink creates a <code>.flink/</code> directory in the users home directory
-where it stores the Flink jar and configuration file.</p>
-
-<h2 id="features">Features</h2>
-
-<h3 id="what-kind-of-fault-tolerance-does-flink-provide">What kind of fault-tolerance does Flink provide?</h3>
-
-<p>Flink can restart failed jobs. Mid-query fault tolerance will go into the
-open source project in the next versions.</p>
-
-<h3 id="are-hadoop-like-utilities-such-as-counters-and-the-distributedcache-supported">Are Hadoop-like utilities, such as Counters and the DistributedCache supported?</h3>
-
-<p><a href="programming_guide.html#accumulators--counters">Flink’s Accumulators</a> work very similar like
-[Hadoop’s counters, but are more powerful.</p>
-
-<p>Flink has a <a href="https://github.com/apache/flink/blob/master//flink-core/src/main/java/org/apache/flink/api/common/cache/DistributedCache.java">Distributed Cache</a> that is deeply integrated with the APIs. Please refer to the <a href="https://github.com/apache/flink/blob/master//flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java#L561">JavaDocs</a> for details on how to use it.</p>
-
-<p>In order to make data sets available on all tasks, we encourage you to use <a href="programming_guide.html#broadcast-variables">Broadcast Variables</a> instead. They are more efficient and easier to use than the distributed cache.</p>
-
-
- </div>
-
- <div class="col-sm-10 col-sm-offset-1">
- <!-- Disqus thread and some vertical offset -->
- <div style="margin-top: 75px; margin-bottom: 50px" id="disqus_thread"></div>
- </div>
-</div>
-
- </div><!-- /.container -->
-
- <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
- <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
- <!-- 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="http://flink.apache.org/docs/master/page/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>
-
- <!-- Disqus -->
- <script type="text/javascript">
- var disqus_shortname = 'stratosphere-eu';
- (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>
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/fig/LICENSE.txt
----------------------------------------------------------------------
diff --git a/content/docs/master/fig/LICENSE.txt b/content/docs/master/fig/LICENSE.txt
deleted file mode 100644
index 35b8673..0000000
--- a/content/docs/master/fig/LICENSE.txt
+++ /dev/null
@@ -1,17 +0,0 @@
-All image files in the folder and its subfolders are
-licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/flink-web/blob/f0ac0cdb/content/docs/master/fig/overview-stack-0.9.png
----------------------------------------------------------------------
diff --git a/content/docs/master/fig/overview-stack-0.9.png b/content/docs/master/fig/overview-stack-0.9.png
deleted file mode 100644
index 70b775a..0000000
Binary files a/content/docs/master/fig/overview-stack-0.9.png and /dev/null differ