Repository: hive Updated Branches: refs/heads/master 29e4f3be4 -> 92dd70739
HIVE-19698: TestAMReporter#testMultipleAM is flaky (Jesus Camacho Rodriguez, reviewed by Prasanth Jayachandran) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8d24b86d Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8d24b86d Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8d24b86d Branch: refs/heads/master Commit: 8d24b86de6d661817d00b1de0a91be382afa7c2f Parents: 29e4f3b Author: Jesus Camacho Rodriguez <jcama...@apache.org> Authored: Thu May 24 10:53:47 2018 -0700 Committer: Jesus Camacho Rodriguez <jcama...@apache.org> Committed: Thu May 24 10:53:47 2018 -0700 ---------------------------------------------------------------------- .../hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/8d24b86d/llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java ---------------------------------------------------------------------- diff --git a/llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java b/llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java index 19f8048..068aad4 100644 --- a/llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java +++ b/llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestAMReporter.java @@ -25,8 +25,10 @@ import org.apache.hadoop.hive.llap.daemon.impl.AMReporter; import org.apache.hadoop.hive.llap.daemon.impl.QueryIdentifier; import org.apache.hadoop.hive.llap.protocol.LlapTaskUmbilicalProtocol; import org.apache.hadoop.io.Text; +import org.apache.hive.common.util.RetryTestRunner; import org.apache.tez.dag.records.TezTaskAttemptID; import org.junit.Test; +import org.junit.runner.RunWith; import org.mockito.invocation.InvocationOnMock; import org.mockito.stubbing.Answer; @@ -44,6 +46,7 @@ import static org.mockito.Mockito.doAnswer; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; +@RunWith(RetryTestRunner.class) public class TestAMReporter { @Test(timeout = 5000) public void testMultipleAM() throws InterruptedException {
