You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2017/03/14 21:00:31 UTC
samza git commit: Fix an import issue on TestJoinOperator
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 <jv...@linkedin.com>
Authored: Tue Mar 14 14:00:19 2017 -0700
Committer: vjagadish1989 <jv...@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;