File tree Expand file tree Collapse file tree 2 files changed +15
-0
lines changed
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a
commit/staging/integration Expand file tree Collapse file tree 2 files changed +15
-0
lines changed Original file line number Diff line number Diff line change 36
36
37
37
import static org .apache .hadoop .fs .s3a .Constants .PREFETCH_BLOCK_SIZE_KEY ;
38
38
import static org .apache .hadoop .fs .s3a .Constants .PREFETCH_ENABLED_KEY ;
39
+ import static org .apache .hadoop .fs .s3a .S3ATestUtils .skipIfAnalyticsAcceleratorEnabled ;
39
40
import static org .apache .hadoop .fs .statistics .IOStatisticAssertions .assertThatStatisticMaximum ;
40
41
import static org .apache .hadoop .fs .statistics .IOStatisticAssertions .verifyStatisticCounterValue ;
41
42
import static org .apache .hadoop .fs .statistics .IOStatisticAssertions .verifyStatisticGaugeValue ;
@@ -75,6 +76,12 @@ public ITestS3APrefetchingInputStream() {
75
76
private static final int INTERVAL_MILLIS = 500 ;
76
77
private static final int BLOCK_SIZE = S_1K * 10 ;
77
78
79
+ @ Override
80
+ public void setup () throws Exception {
81
+ super .setup ();
82
+ skipIfAnalyticsAcceleratorEnabled (this .createConfiguration ());
83
+ }
84
+
78
85
@ Override
79
86
public Configuration createConfiguration () {
80
87
Configuration conf = super .createConfiguration ();
Original file line number Diff line number Diff line change 32
32
import org .apache .hadoop .mapreduce .TaskAttemptContext ;
33
33
34
34
import static org .apache .hadoop .fs .contract .ContractTestUtils .skip ;
35
+ import static org .apache .hadoop .fs .s3a .S3ATestUtils .skipIfAnalyticsAcceleratorEnabled ;
35
36
36
37
/** ITest of the low level protocol methods. */
37
38
public class ITestPartitionedCommitProtocol extends ITestStagingCommitProtocol {
38
39
40
+
41
+ @ Override
42
+ public void setup () throws Exception {
43
+ super .setup ();
44
+ skipIfAnalyticsAcceleratorEnabled (getConfiguration ());
45
+ }
46
+
39
47
@ Override
40
48
protected String suitename () {
41
49
return "ITestPartitionedCommitProtocol" ;
You can’t perform that action at this time.
0 commit comments