Repository: samza Updated Branches: refs/heads/master 5910ea669 -> 5f7b25027
Fix an import issue on TestJoinOperator Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5f7b2502 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/5f7b2502 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/5f7b2502 Branch: refs/heads/master Commit: 5f7b250278f2a1a91b75438a2e80cb70a8347040 Parents: 5910ea6 Author: vjagadish1989 <jvenk...@linkedin.com> Authored: Tue Mar 14 14:00:19 2017 -0700 Committer: vjagadish1989 <jvenk...@linkedin.com> Committed: Tue Mar 14 14:00:19 2017 -0700 ---------------------------------------------------------------------- .../test/java/org/apache/samza/operators/TestJoinOperator.java | 5 ++++- .../java/org/apache/samza/operators/TestMessageStreamImpl.java | 1 + 2 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/5f7b2502/samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java ---------------------------------------------------------------------- diff --git a/samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java b/samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java index ecd01e7..fe2f181 100644 --- a/samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java +++ b/samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java @@ -23,6 +23,7 @@ import org.apache.samza.Partition; import org.apache.samza.config.Config; import org.apache.samza.operators.data.MessageEnvelope; import org.apache.samza.operators.functions.JoinFunction; +import org.apache.samza.runtime.ApplicationRunner; import org.apache.samza.system.IncomingMessageEnvelope; import org.apache.samza.system.StreamSpec; import org.apache.samza.system.SystemStreamPartition; @@ -50,6 +51,8 @@ public class TestJoinOperator { private StreamOperatorTask sot; private List<Integer> output = new ArrayList<>(); + private final ApplicationRunner runner = mock(ApplicationRunner.class); + @Before public void setup() throws Exception { @@ -62,7 +65,7 @@ public class TestJoinOperator { Config config = mock(Config.class); StreamGraphBuilder sgb = new TestStreamGraphBuilder(); - sot = new StreamOperatorTask(sgb); + sot = new StreamOperatorTask(sgb, runner); sot.init(config, taskContext); } http://git-wip-us.apache.org/repos/asf/samza/blob/5f7b2502/samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java ---------------------------------------------------------------------- diff --git a/samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java b/samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java index 1d8afd4..8a2dd95 100644 --- a/samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java +++ b/samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java @@ -18,6 +18,7 @@ */ package org.apache.samza.operators; +import java.time.Duration; import java.util.ArrayList; import java.util.Collection; import java.util.HashMap;
