From 0ae29f74e8a2df01a9738081443e04bf27cd2bb0 Mon Sep 17 00:00:00 2001 From: Fokko Driesprong Date: Tue, 14 Mar 2017 10:36:03 -0700 Subject: [PATCH] Update link to Flink 1.2 In the process of setting up a Flink runner, the documentation still refers to Flink 1.1 instead of the more recent 1.2. --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 1de9bf0..b25a11f 100644 --- a/README.md +++ b/README.md @@ -28,7 +28,7 @@ This example can be used with conference talks and self-study. The base of the e 1. Create the `output` directory. 1. To run on a JVM-local cluster: `mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.tutorial.game.solution.Exercise1 -Dexec.args='--runner=FlinkRunner --flinkMaster=[local]' -Pflink-runner` 1. To run on an out-of-process local cluster (note that the steps below should also work on a real cluster if you have one running): - 1. [Start a local Flink cluster](https://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/setup_quickstart.html#start-a-local-flink-cluster). + 1. [Start a local Flink cluster](https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.html#start-a-local-flink-cluster). 1. Navigate to the WebUI (typically [http://localhost:8081](http://localhost:8081)), click [JobManager](http://localhost:8081/#/jobmanager/config), and note the value of `jobmanager.rpc.port`. The default is probably 6123. 1. Run `mvn package -Pflink-runner` to generate a JAR file. Note the location of the generated JAR (probably `./target/BeamTutorial-bundled-flink.jar`) 1. Run `mvn -X -e compile exec:java -Dexec.mainClass=org.apache.beam.examples.tutorial.game.solution.Exercise1 -Dexec.args='--runner=FlinkRunner --flinkMaster=localhost:6123 --filesToStage=./target/BeamTutorial-bundled-flink.jar' -Pflink-runner`, replacing the defaults for port and JAR file if they differ.