You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by su...@apache.org on 2021/06/13 17:37:39 UTC
[hadoop] branch trunk updated: HADOOP-17645 Fix test failures in
org.apache.hadoop.fs.azure.ITestOutputStreamSemantics. (#2926)
This is an automated email from the ASF dual-hosted git repository.
surendralilhore pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5970c63 HADOOP-17645 Fix test failures in org.apache.hadoop.fs.azure.ITestOutputStreamSemantics. (#2926)
5970c63 is described below
commit 5970c632d4057386db1d48c2920979802ab40cae
Author: Anoop Sam John <an...@gmail.com>
AuthorDate: Sun Jun 13 23:07:10 2021 +0530
HADOOP-17645 Fix test failures in org.apache.hadoop.fs.azure.ITestOutputStreamSemantics. (#2926)
---
.../hadoop/fs/azure/ITestOutputStreamSemantics.java | 19 +++++++++----------
1 file changed, 9 insertions(+), 10 deletions(-)
diff --git a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/ITestOutputStreamSemantics.java b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/ITestOutputStreamSemantics.java
index 835b82c..f516f30 100644
--- a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/ITestOutputStreamSemantics.java
+++ b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/ITestOutputStreamSemantics.java
@@ -37,7 +37,6 @@ import org.hamcrest.core.IsEqual;
import org.hamcrest.core.IsNot;
import org.junit.Test;
-import static org.apache.hadoop.fs.contract.ContractTestUtils.assertCapabilities;
import static org.apache.hadoop.fs.contract.ContractTestUtils.assertHasStreamCapabilities;
import static org.apache.hadoop.fs.contract.ContractTestUtils.assertLacksStreamCapabilities;
@@ -191,14 +190,13 @@ public class ITestOutputStreamSemantics extends AbstractWasbTestBase {
public void testPageBlobCapabilities() throws IOException {
Path path = getBlobPathWithTestName(PAGE_BLOB_DIR);
try (FSDataOutputStream stream = fs.create(path)) {
- assertCapabilities(stream,
- new String[]{
- StreamCapabilities.HFLUSH,
- StreamCapabilities.HSYNC,
- StreamCapabilities.DROPBEHIND,
- StreamCapabilities.READAHEAD,
- StreamCapabilities.UNBUFFER},
- null);
+ assertHasStreamCapabilities(stream,
+ StreamCapabilities.HFLUSH,
+ StreamCapabilities.HSYNC);
+ assertLacksStreamCapabilities(stream,
+ StreamCapabilities.DROPBEHIND,
+ StreamCapabilities.READAHEAD,
+ StreamCapabilities.UNBUFFER);
stream.write(getRandomBytes());
}
}
@@ -386,7 +384,8 @@ public class ITestOutputStreamSemantics extends AbstractWasbTestBase {
try (FSDataOutputStream stream = fs.create(path)) {
assertHasStreamCapabilities(stream,
StreamCapabilities.HFLUSH,
- StreamCapabilities.HSYNC,
+ StreamCapabilities.HSYNC);
+ assertLacksStreamCapabilities(stream,
StreamCapabilities.DROPBEHIND,
StreamCapabilities.READAHEAD,
StreamCapabilities.UNBUFFER);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org