|
@@ -264,13 +264,8 @@ public abstract class AbstractContractCreateTest extends
|
|
|
describe("verify a written to file is visible after the stream is closed");
|
|
|
Path path = path("testCreatedFileIsEventuallyVisible");
|
|
|
FileSystem fs = getFileSystem();
|
|
|
- try(
|
|
|
- FSDataOutputStream out = fs.create(path,
|
|
|
- false,
|
|
|
- 4096,
|
|
|
- (short) 1,
|
|
|
- 1024)
|
|
|
- ) {
|
|
|
+ try(FSDataOutputStream out = fs.create(path, false, 4096, (short) 1,
|
|
|
+ 1024)) {
|
|
|
out.write(0x01);
|
|
|
out.close();
|
|
|
getFileStatusEventually(fs, path, CREATE_TIMEOUT);
|
|
@@ -568,14 +563,14 @@ public abstract class AbstractContractCreateTest extends
|
|
|
in.close();
|
|
|
|
|
|
} catch (FileNotFoundException e) {
|
|
|
- // that's OK if it's an object store, but not if its a real
|
|
|
- // FS
|
|
|
- if (!isSupported(IS_BLOBSTORE)) {
|
|
|
+ // that's OK if it's an object store or some file systems that newly created files
|
|
|
+ // are not immediately visible, but not if its a real FS
|
|
|
+ if (!isSupported(IS_BLOBSTORE) && !isSupported(CREATE_VISIBILITY_DELAYED)) {
|
|
|
throw e;
|
|
|
} else {
|
|
|
LOG.warn(
|
|
|
- "Output file was not created; this is an object store with different"
|
|
|
- + " visibility semantics");
|
|
|
+ "Output file was not created; this is an object store or "
|
|
|
+ + "a file system with different visibility semantics");
|
|
|
}
|
|
|
}
|
|
|
}
|