You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/04/06 22:35:56 UTC
samza git commit: SAMZA-1192: Fixed TestJoinOperator test failure on
JDK 1.8.0_05
Repository: samza
Updated Branches:
refs/heads/master ab7930502 -> d6bd2d707
SAMZA-1192: Fixed TestJoinOperator test failure on JDK 1.8.0_05
Author: Prateek Maheshwari <pm...@linkedin.com>
Reviewers: Jacob Maes <jm...@linkedin.com>
Closes #115 from prateekm/join-test-fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d6bd2d70
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d6bd2d70
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d6bd2d70
Branch: refs/heads/master
Commit: d6bd2d7072b02a4efee3ac90c7389579abbf4dc1
Parents: ab79305
Author: Prateek Maheshwari <pm...@linkedin.com>
Authored: Thu Apr 6 15:35:39 2017 -0700
Committer: Jacob Maes <jm...@linkedin.com>
Committed: Thu Apr 6 15:35:39 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/samza/operators/TestJoinOperator.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/d6bd2d70/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 acc8588..1180179 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
@@ -240,7 +240,7 @@ public class TestJoinOperator {
return sot;
}
- private class TestStreamApplication implements StreamApplication {
+ private static class TestStreamApplication implements StreamApplication {
@Override
public void init(StreamGraph graph, Config config) {
MessageStream<FirstStreamIME> inStream =
@@ -257,7 +257,7 @@ public class TestJoinOperator {
}
}
- private class TestJoinFunction implements JoinFunction<Integer, FirstStreamIME, SecondStreamIME, Integer> {
+ private static class TestJoinFunction implements JoinFunction<Integer, FirstStreamIME, SecondStreamIME, Integer> {
@Override
public Integer apply(FirstStreamIME message, SecondStreamIME otherMessage) {
return (Integer) message.getMessage() + (Integer) otherMessage.getMessage();
@@ -274,13 +274,13 @@ public class TestJoinOperator {
}
}
- private class FirstStreamIME extends IncomingMessageEnvelope {
+ private static class FirstStreamIME extends IncomingMessageEnvelope {
FirstStreamIME(Integer key, Integer message) {
super(new SystemStreamPartition("insystem", "instream", new Partition(0)), "1", key, message);
}
}
- private class SecondStreamIME extends IncomingMessageEnvelope {
+ private static class SecondStreamIME extends IncomingMessageEnvelope {
SecondStreamIME(Integer key, Integer message) {
super(new SystemStreamPartition("insystem2", "instream2", new Partition(0)), "1", key, message);
}