This is an automated email from the ASF dual-hosted git repository.
dineshc pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/master by this push:
new f046ebf HDDS-3602. Fix KeyInputStream by adding a timeout exception.
(#931)
f046ebf is described below
commit f046ebf206c031f68649461d8288ea5216fa3300
Author: Mukul Kumar Singh <[email protected]>
AuthorDate: Mon May 18 07:54:52 2020 +0530
HDDS-3602. Fix KeyInputStream by adding a timeout exception. (#931)
---
.../apache/hadoop/ozone/client/rpc/TestKeyInputStream.java | 14 +++++---------
1 file changed, 5 insertions(+), 9 deletions(-)
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestKeyInputStream.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestKeyInputStream.java
index f48a7b1..d8c4b3b 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestKeyInputStream.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestKeyInputStream.java
@@ -36,6 +36,8 @@ import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
+import org.junit.Rule;
+import org.junit.rules.Timeout;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
@@ -101,6 +103,9 @@ public class TestKeyInputStream {
objectStore.getVolume(volumeName).createBucket(bucketName);
}
+ @Rule
+ public Timeout timeout = new Timeout(300_000);
+
/**
* Shutdown MiniDFSCluster.
*/
@@ -115,18 +120,9 @@ public class TestKeyInputStream {
return UUID.randomUUID().toString();
}
- private OzoneOutputStream createKey(String keyName, ReplicationType type,
- long size) throws Exception {
- return TestHelper
- .createKey(keyName, type, size, objectStore, volumeName, bucketName);
- }
-
@Test
public void testSeekRandomly() throws Exception {
- XceiverClientMetrics metrics = XceiverClientManager
- .getXceiverClientMetrics();
-
String keyName = getKeyName();
OzoneOutputStream key = TestHelper.createKey(keyName,
ReplicationType.RATIS, 0, objectStore, volumeName, bucketName);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
