big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-17573. Fix compilation error of OBSFileSystem in trunk. (#2758)

Browse Source
This commit is contained in:
Masatake Iwasaki 2021-03-10 22:23:54 +09:00 committed by GitHub
parent 6a55baeee4
commit 7a851c7176
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-cloud-storage-project/hadoop-huaweicloud/src/main/java/org/apache/hadoop/fs/obs/OBSFileSystem.java
View File

@ -19,7 +19,6 @@
package org.apache.hadoop.fs.obs; package org.apache.hadoop.fs.obs;
import org.apache.hadoop.thirdparty.com.google.common.annotations.VisibleForTesting; import org.apache.hadoop.thirdparty.com.google.common.annotations.VisibleForTesting;
import org.apache.hadoop.thirdparty.com.google.common.util.concurrent.ListeningExecutorService;
import com.obs.services.ObsClient; import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException; import com.obs.services.exception.ObsException;
import com.obs.services.model.AccessControlList; import com.obs.services.model.AccessControlList;
@ -53,6 +52,7 @@
import java.io.IOException; import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.util.EnumSet; import java.util.EnumSet;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -169,7 +169,7 @@ public final class OBSFileSystem extends FileSystem {
/** /**
* Bounded thread pool for multipart upload. * Bounded thread pool for multipart upload.
*/ */
private ListeningExecutorService boundedMultipartUploadThreadPool; private ExecutorService boundedMultipartUploadThreadPool;
/** /**
* Bounded thread pool for copy. * Bounded thread pool for copy.