Revert "HDFS-13388. RequestHedgingProxyProvider calls multiple configured NNs all the time. Contributed by Jinglun."
This reverts commit 7e692425d538454abf69b07f6e8fd686a1171ac8. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/20472bdf Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/20472bdf Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/20472bdf Branch: refs/heads/YARN-8200 Commit: 20472bdfd2e8f084e106a8c732498e1601018d0c Parents: f055a53 Author: Inigo Goiri <inigo...@apache.org> Authored: Thu Apr 12 08:44:17 2018 -0700 Committer: Inigo Goiri <inigo...@apache.org> Committed: Thu Apr 12 08:44:17 2018 -0700 ---------------------------------------------------------------------- .../ha/RequestHedgingProxyProvider.java | 3 -- .../ha/TestRequestHedgingProxyProvider.java | 34 -------------------- 2 files changed, 37 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/20472bdf/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/RequestHedgingProxyProvider.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/RequestHedgingProxyProvider.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/RequestHedgingProxyProvider.java index f34adce..010e9e5 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/RequestHedgingProxyProvider.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/RequestHedgingProxyProvider.java @@ -78,9 +78,6 @@ public class RequestHedgingProxyProvider<T> extends public Object invoke(Object proxy, final Method method, final Object[] args) throws Throwable { - if (currentUsedProxy != null) { - return method.invoke(currentUsedProxy.proxy, args); - } Map<Future<Object>, ProxyInfo<T>> proxyMap = new HashMap<>(); int numAttempts = 0; http://git-wip-us.apache.org/repos/asf/hadoop/blob/20472bdf/hadoop-hdfs-project/hadoop-hdfs-client/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestRequestHedgingProxyProvider.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestRequestHedgingProxyProvider.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestRequestHedgingProxyProvider.java index a8a5c6e..65fbbf8 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestRequestHedgingProxyProvider.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestRequestHedgingProxyProvider.java @@ -42,13 +42,10 @@ import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; import org.junit.Test; -import static org.junit.Assert.assertEquals; import org.mockito.Matchers; import org.mockito.Mockito; import org.mockito.invocation.InvocationOnMock; import org.mockito.stubbing.Answer; -import static org.mockito.Mockito.when; -import static org.mockito.Mockito.mock; import com.google.common.collect.Lists; @@ -102,37 +99,6 @@ public class TestRequestHedgingProxyProvider { } @Test - public void testRequestNNAfterOneSuccess() throws Exception { - final AtomicInteger count = new AtomicInteger(0); - final ClientProtocol goodMock = mock(ClientProtocol.class); - when(goodMock.getStats()).thenAnswer(new Answer<long[]>() { - @Override - public long[] answer(InvocationOnMock invocation) throws Throwable { - count.incrementAndGet(); - Thread.sleep(1000); - return new long[]{1}; - } - }); - final ClientProtocol badMock = mock(ClientProtocol.class); - when(badMock.getStats()).thenAnswer(new Answer<long[]>() { - @Override - public long[] answer(InvocationOnMock invocation) throws Throwable { - count.incrementAndGet(); - throw new IOException("Bad mock !!"); - } - }); - - RequestHedgingProxyProvider<ClientProtocol> provider = - new RequestHedgingProxyProvider<>(conf, nnUri, ClientProtocol.class, - createFactory(badMock, goodMock, goodMock, badMock)); - ClientProtocol proxy = provider.getProxy().proxy; - proxy.getStats(); - assertEquals(2, count.get()); - proxy.getStats(); - assertEquals(3, count.get()); - } - - @Test public void testHedgingWhenOneIsSlow() throws Exception { final ClientProtocol goodMock = Mockito.mock(ClientProtocol.class); Mockito.when(goodMock.getStats()).thenAnswer(new Answer<long[]>() { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
