diff --git a/hadoop-project/pom.xml b/hadoop-project/pom.xml index b07c91e7868eb..2ec8d2d1ceb82 100644 --- a/hadoop-project/pom.xml +++ b/hadoop-project/pom.xml @@ -206,7 +206,7 @@ 1.12.720 2.29.52 3.1.1 - 0.0.4 + 1.0.0 1.0.1 2.7.1 1.11.2 diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAnalyticsAcceleratorStreamReading.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAnalyticsAcceleratorStreamReading.java index 0ed0457e7573e..9a0afdf651315 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAnalyticsAcceleratorStreamReading.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAnalyticsAcceleratorStreamReading.java @@ -38,7 +38,6 @@ import software.amazon.s3.analyticsaccelerator.S3SeekableInputStreamConfiguration; import software.amazon.s3.analyticsaccelerator.common.ConnectorConfiguration; -import software.amazon.s3.analyticsaccelerator.util.PrefetchMode; import static org.apache.hadoop.fs.Options.OpenFileOptions.FS_OPTION_OPENFILE_READ_POLICY; import static org.apache.hadoop.fs.Options.OpenFileOptions.FS_OPTION_OPENFILE_READ_POLICY_PARQUET; @@ -64,8 +63,6 @@ public class ITestS3AAnalyticsAcceleratorStreamReading extends AbstractS3ATestBase { private static final String PHYSICAL_IO_PREFIX = "physicalio"; - private static final String LOGICAL_IO_PREFIX = "logicalio"; - private Path externalTestFile; @@ -176,35 +173,6 @@ public void testMultiRowGroupParquet() throws Throwable { verifyStatisticCounterValue(ioStats, STREAM_READ_ANALYTICS_OPENED, 1); } - @Test - public void testConnectorFrameworkConfigurable() { - describe("Verify S3 connector framework reads configuration"); - - Configuration conf = new Configuration(getConfiguration()); - - //Disable Predictive Prefetching - conf.set(ANALYTICS_ACCELERATOR_CONFIGURATION_PREFIX + - "." + LOGICAL_IO_PREFIX + ".prefetching.mode", "all"); - - //Set Blobstore Capacity - conf.setInt(ANALYTICS_ACCELERATOR_CONFIGURATION_PREFIX + - "." + PHYSICAL_IO_PREFIX + ".blobstore.capacity", 1); - - ConnectorConfiguration connectorConfiguration = - new ConnectorConfiguration(conf, ANALYTICS_ACCELERATOR_CONFIGURATION_PREFIX); - - S3SeekableInputStreamConfiguration configuration = - S3SeekableInputStreamConfiguration.fromConfiguration(connectorConfiguration); - - Assertions.assertThat(configuration.getLogicalIOConfiguration().getPrefetchingMode()) - .as("AnalyticsStream configuration is not set to expected value") - .isSameAs(PrefetchMode.ALL); - - Assertions.assertThat(configuration.getPhysicalIOConfiguration().getBlobStoreCapacity()) - .as("AnalyticsStream configuration is not set to expected value") - .isEqualTo(1); - } - @Test public void testInvalidConfigurationThrows() throws Exception { describe("Verify S3 connector framework throws with invalid configuration");