You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/04/08 15:22:59 UTC
flink git commit: [doc] Fix typos and formatting in Flink on Tez doc
Repository: flink
Updated Branches:
refs/heads/master b56688453 -> 41ab43604
[doc] Fix typos and formatting in Flink on Tez doc
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/41ab4360
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/41ab4360
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/41ab4360
Branch: refs/heads/master
Commit: 41ab43604199f31b6a4256cdf23c549481cca9e8
Parents: b566884
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Apr 8 15:21:46 2015 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Apr 8 15:22:31 2015 +0200
----------------------------------------------------------------------
docs/flink_on_tez_guide.md | 27 ++++++++++++++-------------
1 file changed, 14 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/41ab4360/docs/flink_on_tez_guide.md
----------------------------------------------------------------------
diff --git a/docs/flink_on_tez_guide.md b/docs/flink_on_tez_guide.md
index 08aed28..5cc1e31 100644
--- a/docs/flink_on_tez_guide.md
+++ b/docs/flink_on_tez_guide.md
@@ -30,7 +30,7 @@ under the License.
You can run Flink using Tez as an execution environment. Flink on Tez
is currently included in *flink-staging* in alpha. All classes are
-localted in the *org.apache.flink.tez* package.
+located in the *org.apache.flink.tez* package.
## Why Flink on Tez
@@ -55,7 +55,7 @@ remote execution on YARN.
## Local execution
The `LocalTezEnvironment` can be used run programs using the local
-mode provided by Tez. This is for example WordCount using Tez local mode.
+mode provided by Tez. This example shows how WordCount can be run using the Tez local mode.
It is identical to a normal Flink WordCount, except that the `LocalTezEnvironment` is used.
To run in local Tez mode, you can simply run a Flink on Tez program
from your IDE (e.g., right click and run).
@@ -65,7 +65,7 @@ public class WordCountExample {
public static void main(String[] args) throws Exception {
final LocalTezEnvironment env = LocalTezEnvironment.create();
- DataSet<String> text = env.fromElements(
+ DataSet<String> text = env.fromElements(
"Who's there?",
"I think I hear them. Stand, ho! Who's there?");
@@ -113,14 +113,15 @@ public class WordCountExample {
- Edit the tez-site.xml configuration file, adding an entry that points to the
location of the file. E.g., assuming that the file is in the directory `/apps/`,
- add the following entry to tez-site.xml
- ~~~<property>
- <name>tez.aux.uris</name>
- <value>${fs.default.name}/apps/flink-tez-x.y.z-flink-fat-jar.jar</value>
- </property>
- ~~~
+ add the following entry to tez-site.xml:
+ {% highlight xml %}
+<property>
+ <name>tez.aux.uris</name>
+ <value>${fs.default.name}/apps/flink-tez-x.y.z-flink-fat-jar.jar</value>
+</property>
+ {% endhighlight %}
-- At this point, you should be able to run the pre-packaged examples, e.g., run WordCount as:
+- At this point, you should be able to run the pre-packaged examples, e.g., run WordCount:
{% highlight bash %}
$ hadoop jar /path/to/flink-tez-x.y.z-flink-fat-jar.jar wc hdfs:/path/to/text hdfs:/path/to/output
{% endhighlight %}
@@ -130,7 +131,7 @@ public class WordCountExample {
Application packaging is currently a bit different than in Flink standalone mode.
Flink programs that run on Tez need to be packaged in a "fat jar"
- file that contain the Flink client and executed via the `hadoop jar` command.
+ file that contain the Flink client. This jar can then be executed via the `hadoop jar` command.
An easy way to do that is to use the provided `flink-tez-quickstart` maven archetype.
Create a new project as
@@ -193,7 +194,7 @@ Application packaging is currently a bit different than in Flink standalone mode
{% endhighlight %}
The project contains an example called `YarnJob.java` that provides the skeleton
- for a Flink-on-Tez job. Programs execution is done currently via Hadoop's `ProgramDriver`,
+ for a Flink-on-Tez job. Program execution is currently done using Hadoop's `ProgramDriver`,
see the `Driver.java` class for an example. Create the fat jar using
`mvn -DskipTests clean package`. The resulting jar will be located in the `target/` directory.
You can now execute a job as follows:
@@ -210,7 +211,7 @@ $ hadoop jar flink-on-tez/target/flink-on-tez-0.1-flink-fat-jar.jar yarnjob [com
public static void main(String[] args) throws Exception {
final RemoteTezEnvironment env = RemoteTezEnvironment.create();
- DataSet<String> text = env.fromElements(
+ DataSet<String> text = env.fromElements(
"Who's there?",
"I think I hear them. Stand, ho! Who's there?");