From 4dda34d376d4b22d75e4e64663e7f78cf3cd0b12 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Isma=C3=ABl=20Mej=C3=ADa?= Date: Wed, 29 Jun 2016 23:00:02 +0200 Subject: [PATCH 1/2] [BEAM-392] Update flink dependency to the most recent stable version --- runners/flink/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runners/flink/pom.xml b/runners/flink/pom.xml index bea639e7bf73..653fe2cbeed2 100644 --- a/runners/flink/pom.xml +++ b/runners/flink/pom.xml @@ -39,7 +39,7 @@ UTF-8 UTF-8 - 1.0.0 + 1.0.3 From 93913d2d85ee8eecbf6f56f734abba82a7611773 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Isma=C3=ABl=20Mej=C3=ADa?= Date: Wed, 29 Jun 2016 23:12:06 +0200 Subject: [PATCH 2/2] [BEAM-392] Rename missing references to FlinkPipelineRunner --- .../java/org/apache/beam/examples/MinimalWordCount.java | 6 +++--- .../org/apache/beam/examples/MinimalWordCountJava8.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java b/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java index 2c6760914abf..9f6d61a246e8 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java +++ b/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java @@ -67,17 +67,17 @@ public static void main(String[] args) { // In order to run your pipeline, you need to make following runner specific changes: // // CHANGE 1/3: Select a Beam runner, such as BlockingDataflowRunner - // or FlinkPipelineRunner. + // or FlinkRunner. // CHANGE 2/3: Specify runner-required options. // For BlockingDataflowRunner, set project and temp location as follows: // DataflowPipelineOptions dataflowOptions = options.as(DataflowPipelineOptions.class); // dataflowOptions.setRunner(BlockingDataflowRunner.class); // dataflowOptions.setProject("SET_YOUR_PROJECT_ID_HERE"); // dataflowOptions.setTempLocation("gs://SET_YOUR_BUCKET_NAME_HERE/AND_TEMP_DIRECTORY"); - // For FlinkPipelineRunner, set the runner as follows. See {@code FlinkPipelineOptions} + // For FlinkRunner, set the runner as follows. See {@code FlinkPipelineOptions} // for more details. // options.as(FlinkPipelineOptions.class) - // .setRunner(FlinkPipelineRunner.class); + // .setRunner(FlinkRunner.class); // Create the Pipeline object with the options we defined above. Pipeline p = Pipeline.create(options); diff --git a/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java b/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java index 6362b962ea32..ff8ca552b57c 100644 --- a/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java +++ b/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java @@ -42,17 +42,17 @@ public static void main(String[] args) { // In order to run your pipeline, you need to make following runner specific changes: // // CHANGE 1/3: Select a Beam runner, such as BlockingDataflowRunner - // or FlinkPipelineRunner. + // or FlinkRunner. // CHANGE 2/3: Specify runner-required options. // For BlockingDataflowRunner, set project and temp location as follows: // DataflowPipelineOptions dataflowOptions = options.as(DataflowPipelineOptions.class); // dataflowOptions.setRunner(BlockingDataflowRunner.class); // dataflowOptions.setProject("SET_YOUR_PROJECT_ID_HERE"); // dataflowOptions.setTempLocation("gs://SET_YOUR_BUCKET_NAME_HERE/AND_TEMP_DIRECTORY"); - // For FlinkPipelineRunner, set the runner as follows. See {@code FlinkPipelineOptions} + // For FlinkRunner, set the runner as follows. See {@code FlinkPipelineOptions} // for more details. // options.as(FlinkPipelineOptions.class) - // .setRunner(FlinkPipelineRunner.class); + // .setRunner(FlinkRunner.class); Pipeline p = Pipeline.create(options);