Fix TestParallelShortCircuitRead.

Change-Id: I72a2b5e59c3bb906253b2ea64f91f7ae6bdef1d7
This commit is contained in:
Siyao Meng 2021-08-19 22:42:42 -07:00
parent 2216695e08
commit cfab28a0ee

View File

@ -17,15 +17,13 @@
*/ */
package org.apache.hadoop.hdfs; package org.apache.hadoop.hdfs;
import static org.hamcrest.CoreMatchers.equalTo;
import java.io.File; import java.io.File;
import org.apache.hadoop.hdfs.client.HdfsClientConfigKeys; import org.apache.hadoop.hdfs.client.HdfsClientConfigKeys;
import org.apache.hadoop.net.unix.DomainSocket; import org.apache.hadoop.net.unix.DomainSocket;
import org.apache.hadoop.net.unix.TemporarySocketDirectory; import org.apache.hadoop.net.unix.TemporarySocketDirectory;
import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assumptions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
@ -49,7 +47,7 @@ static public void setupCluster() throws Exception {
@BeforeEach @BeforeEach
public void before() { public void before() {
Assumptions.assumeThat(DomainSocket.getLoadingFailureReason(), equalTo(null)); Assertions.assertNull(DomainSocket.getLoadingFailureReason());
} }
@AfterAll @AfterAll