Repository: beam
Updated Branches:
  refs/heads/master 947fa68a5 -> 047338eeb


[BEAM-2187] Fix build break in SparkRuntimeContextTest


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/56a83c73
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/56a83c73
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/56a83c73

Branch: refs/heads/master
Commit: 56a83c73b9b7ab0760c421cf154caff16953500a
Parents: 947fa68
Author: Luke Cwik <[email protected]>
Authored: Fri May 5 15:09:26 2017 -0700
Committer: Luke Cwik <[email protected]>
Committed: Fri May 5 15:09:26 2017 -0700

----------------------------------------------------------------------
 .../beam/runners/spark/translation/SparkRuntimeContextTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/56a83c73/runners/spark/src/test/java/org/apache/beam/runners/spark/translation/SparkRuntimeContextTest.java
----------------------------------------------------------------------
diff --git 
a/runners/spark/src/test/java/org/apache/beam/runners/spark/translation/SparkRuntimeContextTest.java
 
b/runners/spark/src/test/java/org/apache/beam/runners/spark/translation/SparkRuntimeContextTest.java
index 372d46f..e8f578a 100644
--- 
a/runners/spark/src/test/java/org/apache/beam/runners/spark/translation/SparkRuntimeContextTest.java
+++ 
b/runners/spark/src/test/java/org/apache/beam/runners/spark/translation/SparkRuntimeContextTest.java
@@ -105,7 +105,7 @@ public class SparkRuntimeContextTest {
         .as(JacksonIncompatibleOptions.class);
     options.setRunner(CrashingRunner.class);
     Pipeline p = Pipeline.create(options);
-    SparkRuntimeContext context = new SparkRuntimeContext(p);
+    SparkRuntimeContext context = new SparkRuntimeContext(p, options);
 
     ByteArrayOutputStream baos = new ByteArrayOutputStream();
     try (ObjectOutputStream outputStream = new ObjectOutputStream(baos)) {

Reply via email to