|
@@ -1005,13 +1005,17 @@ public class S3AFileSystem extends FileSystem implements StreamCapabilities,
|
|
|
String storageClassConf = getConf()
|
|
|
.getTrimmed(STORAGE_CLASS, "")
|
|
|
.toUpperCase(Locale.US);
|
|
|
- StorageClass storageClass;
|
|
|
- try {
|
|
|
- storageClass = StorageClass.fromValue(storageClassConf);
|
|
|
- } catch (IllegalArgumentException e) {
|
|
|
- LOG.warn("Unknown storage class property {}: {}; falling back to default storage class",
|
|
|
- STORAGE_CLASS, storageClassConf);
|
|
|
- storageClass = null;
|
|
|
+ StorageClass storageClass = null;
|
|
|
+ if (!storageClassConf.isEmpty()) {
|
|
|
+ try {
|
|
|
+ storageClass = StorageClass.fromValue(storageClassConf);
|
|
|
+ } catch (IllegalArgumentException e) {
|
|
|
+ LOG.warn("Unknown storage class property {}: {}; falling back to default storage class",
|
|
|
+ STORAGE_CLASS, storageClassConf);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ LOG.debug("Unset storage class property {}; falling back to default storage class",
|
|
|
+ STORAGE_CLASS);
|
|
|
}
|
|
|
|
|
|
return RequestFactoryImpl.builder()
|