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 st...@apache.org on 2022/05/30 16:50:39 UTC
[hadoop] 05/05: fixes compilation errors in tests
This is an automated email from the ASF dual-hosted git repository.
stevel pushed a commit to branch feature-HADOOP-18028-s3a-prefetch
in repository https://gitbox.apache.org/repos/asf/hadoop.git
commit b75b72b8e203e447b60c3f7e1305aed5cff48d2c
Author: Ahmar Suhail <ah...@amazon.co.uk>
AuthorDate: Thu May 19 13:17:26 2022 +0100
fixes compilation errors in tests
---
.../src/test/java/org/apache/hadoop/fs/s3a/read/Fakes.java | 11 +++++++----
.../test/java/org/apache/hadoop/fs/s3a/read/MockS3File.java | 7 +++++++
2 files changed, 14 insertions(+), 4 deletions(-)
diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/Fakes.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/Fakes.java
index 1b02c495bc4..f394119df80 100644
--- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/Fakes.java
+++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/Fakes.java
@@ -27,6 +27,7 @@ import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.Map;
import java.util.Random;
+import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
@@ -56,6 +57,7 @@ import org.apache.hadoop.fs.s3a.statistics.impl.CountingChangeTracker;
import org.apache.hadoop.fs.s3a.statistics.impl.EmptyS3AStatisticsContext;
import org.apache.hadoop.io.retry.RetryPolicies;
import org.apache.hadoop.io.retry.RetryPolicy;
+import org.apache.hadoop.util.functional.CallableRaisingIOE;
/**
* Provides 'fake' implementations of S3InputStream variants.
@@ -128,10 +130,6 @@ public final class Fakes {
statistics,
statisticsContext,
fileStatus,
- S3AInputPolicy.Random, // seekPolicy
- CHANGE_POLICY,
- 1L, // readAheadRange
- NoopSpan.INSTANCE, // auditSpan
futurePool,
prefetchBlockSize,
prefetchBlockCount);
@@ -181,6 +179,11 @@ public final class Fakes {
return object;
}
+ @Override
+ public <T> CompletableFuture<T> submit(CallableRaisingIOE<T> operation) {
+ return null;
+ }
+
@Override
public GetObjectRequest newGetRequest(String key) {
return new GetObjectRequest(bucket, key);
diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/MockS3File.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/MockS3File.java
index 91523026e9a..b265eea931d 100644
--- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/MockS3File.java
+++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/read/MockS3File.java
@@ -22,6 +22,7 @@ package org.apache.hadoop.fs.s3a.read;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
+import java.util.concurrent.CompletableFuture;
import com.amazonaws.services.s3.model.GetObjectRequest;
import com.amazonaws.services.s3.model.S3Object;
@@ -29,6 +30,7 @@ import com.amazonaws.services.s3.model.S3Object;
import org.apache.hadoop.fs.common.Validate;
import org.apache.hadoop.fs.s3a.S3AInputStream;
import org.apache.hadoop.fs.s3a.statistics.impl.EmptyS3AStatisticsContext;
+import org.apache.hadoop.util.functional.CallableRaisingIOE;
/**
* A mock s3 file with some fault injection.
@@ -92,6 +94,11 @@ class MockS3File extends S3File {
return null;
}
+ @Override
+ public <T> CompletableFuture<T> submit(CallableRaisingIOE<T> operation) {
+ return null;
+ }
+
@Override
public GetObjectRequest newGetRequest(String key) {
return new GetObjectRequest(bucketName, key);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org