|
18 | 18 |
|
19 | 19 | package org.apache.hadoop.fs.contract.s3a; |
20 | 20 |
|
21 | | -import org.apache.hadoop.conf.Configuration; |
22 | | -import org.apache.hadoop.fs.StorageStatistics; |
23 | | -import org.apache.hadoop.tools.contract.AbstractContractDistCpTest; |
24 | | - |
25 | 21 | import static org.apache.hadoop.fs.contract.ContractTestUtils.skip; |
26 | | -import static org.apache.hadoop.fs.s3a.Constants.FAST_UPLOAD_BUFFER; |
27 | | -import static org.apache.hadoop.fs.s3a.Constants.FAST_UPLOAD_BUFFER_DISK; |
28 | | -import static org.apache.hadoop.fs.s3a.Constants.MULTIPART_MIN_SIZE; |
29 | | -import static org.apache.hadoop.fs.s3a.Constants.MULTIPART_SIZE; |
| 22 | +import static org.apache.hadoop.fs.s3a.Constants.*; |
30 | 23 | import static org.apache.hadoop.fs.s3a.S3ATestConstants.SCALE_TEST_TIMEOUT_MILLIS; |
31 | 24 | import static org.apache.hadoop.fs.s3a.S3ATestUtils.maybeEnableS3Guard; |
32 | 25 |
|
| 26 | +import org.apache.hadoop.conf.Configuration; |
| 27 | +import org.apache.hadoop.fs.StorageStatistics; |
| 28 | +import org.apache.hadoop.tools.contract.AbstractContractDistCpTest; |
| 29 | + |
33 | 30 | /** |
34 | 31 | * Contract test suite covering S3A integration with DistCp. |
35 | 32 | * Uses the block output stream, buffered to disk. This is the |
@@ -72,8 +69,9 @@ protected S3AContract createContract(Configuration conf) { |
72 | 69 | public void testDistCpWithIterator() throws Exception { |
73 | 70 | final long renames = getRenameOperationCount(); |
74 | 71 | super.testDistCpWithIterator(); |
75 | | - assertEquals("Expected no renames for a direct write distcp", 0L, |
76 | | - getRenameOperationCount() - renames); |
| 72 | + assertEquals("Expected no renames for a direct write distcp", |
| 73 | + getRenameOperationCount(), |
| 74 | + renames); |
77 | 75 | } |
78 | 76 |
|
79 | 77 | @Override |
|
0 commit comments