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 <ankurgoe...@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