You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2018/09/21 21:02:59 UTC
git commit: updated refs/heads/trunk to 843cd6e
Repository: giraph
Updated Branches:
refs/heads/trunk 7f6a33d94 -> 843cd6eea
fix-tests
closes #86
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/843cd6ee
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/843cd6ee
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/843cd6ee
Branch: refs/heads/trunk
Commit: 843cd6eea60431ae527164f8fe9b0e054c7f9157
Parents: 7f6a33d
Author: Maja Kabiljo <ma...@fb.com>
Authored: Fri Sep 21 14:02:42 2018 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Fri Sep 21 14:02:42 2018 -0700
----------------------------------------------------------------------
.../test/java/org/apache/giraph/comm/RequestFailureTest.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/843cd6ee/giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java b/giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java
index 37f0c4b..5dea065 100644
--- a/giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java
+++ b/giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java
@@ -34,6 +34,7 @@ import org.apache.giraph.utils.MockUtils;
import org.apache.giraph.utils.PairList;
import org.apache.giraph.worker.WorkerInfo;
import org.apache.hadoop.io.IntWritable;
+import org.apache.hadoop.mapreduce.Counter;
import org.apache.hadoop.mapreduce.Mapper.Context;
import org.junit.Before;
import org.junit.Test;
@@ -45,6 +46,7 @@ import java.io.IOException;
import static org.junit.Assert.assertEquals;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
+import static org.mockito.Mockito.any;
/**
* Test all the netty failure scenarios
@@ -72,6 +74,9 @@ public class RequestFailureTest {
context = mock(Context.class);
when(context.getConfiguration()).thenReturn(conf);
+ Counter counter = mock(Counter.class);
+ when(context.getCounter(any(String.class), any(String.class))).thenReturn(
+ counter);
}
private WritableRequest getRequest() {