[beam] branch master updated: Fixing bug in flink job server creation

[mx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new fb23c7f  Fixing bug in flink job server creation
fb23c7f is described below

commit fb23c7f2eacee5374cfd85a58d5d6746e18fabc7
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Wed Sep 5 18:44:30 2018 -0700

    Fixing bug in flink job server creation
---
 .../main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java
index 13f48c5..0f567f6 100644
--- a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java
+++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java
@@ -130,7 +130,7 @@ public class FlinkJobServerDriver implements Runnable {
     this.configuration = configuration;
     this.executor = executor;
     this.jobServerFactory = jobServerFactory;
-    this.artifactServerFactory = jobServerFactory;
+    this.artifactServerFactory = artifactServerFactory;
   }
 
   @Override