mukund-thakur commented on code in PR #3662:
URL: https://github.com/apache/hadoop/pull/3662#discussion_r1003823510
##########
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAzureBlobFileSystemE2E.java:
##########
@@ -229,4 +238,43 @@ private void testWriteOneByteToFile(Path testFilePath)
throws Exception {
FileStatus fileStatus = fs.getFileStatus(testFilePath);
assertEquals(1, fileStatus.getLen());
}
+
+ @Test
+ public void testHttpConnectionTimeout() throws Exception {
+ // Not seeing connection failures while testing with 1 ms connection
+ // timeout itself and on repeated TPCDS runs when cluster
+ // and account are in same region, 10 ms is seen stable.
+ // 500 ms is seen stable for cross region.
+ testHttpTimeouts(TEST_STABLE_DEFAULT_CONNECTION_TIMEOUT_MS,
+ TEST_STABLE_DEFAULT_READ_TIMEOUT_MS);
+ }
+
+ @Test(expected = InvalidAbfsRestOperationException.class)
+ public void testHttpReadTimeout() throws Exception {
+ // Small read timeout is bound to make the request fail.
+ testHttpTimeouts(TEST_STABLE_DEFAULT_CONNECTION_TIMEOUT_MS,
Review Comment:
We can use intercept here
https://github.com/apache/hadoop/blob/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/test/LambdaTestUtils.java#L380
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
