This is an automated email from the ASF dual-hosted git repository.
stevel pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git.
from 712d9be HDFS-16502. Reconfigure Block Invalidate limit (#4064)
new e06ed88 HADOOP-18162. hadoop-common support for MAPREDUCE-7341
Manifest Committer
new 1cc83f0 MAPREDUCE-7341. Add an intermediate manifest committer for
Azure and GCS
new 3238bda HADOOP-18163. hadoop-azure support for the Manifest Committer
of MAPREDUCE-7341
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../hadoop/fs/statistics/StoreStatisticNames.java | 6 +
.../fs/statistics/impl/IOStatisticsBinding.java | 29 +-
.../fs/statistics/impl/IOStatisticsStore.java | 11 +
.../impl/PairedDurationTrackerFactory.java | 5 +
.../statistics/impl/StatisticDurationTracker.java | 7 +
.../org/apache/hadoop/util/JsonSerialization.java | 5 +-
.../java/org/apache/hadoop/util/RateLimiting.java | 52 +
.../apache/hadoop/util/RateLimitingFactory.java | 102 ++
.../functional/CloseableTaskPoolSubmitter.java | 74 +
.../apache/hadoop/util/functional/TaskPool.java | 613 +++++++
.../hadoop/util/functional/TestTaskPool.java | 585 +++++++
.../hadoop-mapreduce-client-core/pom.xml | 7 +-
.../lib/output/PathOutputCommitterFactory.java | 10 +-
.../committer/manifest/ManifestCommitter.java | 761 +++++++++
.../manifest/ManifestCommitterConfig.java | 375 ++++
.../manifest/ManifestCommitterConstants.java | 240 +++
.../manifest/ManifestCommitterFactory.java | 57 +
.../manifest/ManifestCommitterStatisticNames.java | 264 +++
.../manifest/files/AbstractManifestData.java | 137 ++
.../committer/manifest/files/DiagnosticKeys.java | 44 +
.../output/committer/manifest/files/DirEntry.java | 202 +++
.../committer/manifest/files/EntryStatus.java | 87 +
.../output/committer/manifest/files/FileEntry.java | 189 ++
.../committer/manifest/files/ManifestPrinter.java | 144 ++
.../manifest/files/ManifestSuccessData.java | 493 ++++++
.../committer/manifest/files/TaskManifest.java | 365 ++++
.../committer/manifest/files/package-info.java | 41 +
.../manifest/impl/AuditingIntegration.java | 94 +
.../committer/manifest/impl/InternalConstants.java | 130 ++
.../manifest/impl/ManifestCommitterSupport.java | 374 ++++
.../manifest/impl/ManifestStoreOperations.java | 291 ++++
.../ManifestStoreOperationsThroughFileSystem.java | 187 ++
.../manifest/impl/OutputValidationException.java | 40 +
.../committer/manifest/impl/package-info.java | 30 +
.../output/committer/manifest/package-info.java | 34 +
.../committer/manifest/stages/AbortTaskStage.java | 63 +
.../manifest/stages/AbstractJobOrTaskStage.java | 942 ++++++++++
.../committer/manifest/stages/CleanupJobStage.java | 511 ++++++
.../committer/manifest/stages/CommitJobStage.java | 245 +++
.../committer/manifest/stages/CommitTaskStage.java | 115 ++
.../stages/CreateOutputDirectoriesStage.java | 423 +++++
.../committer/manifest/stages/JobOrTaskStage.java | 33 +
.../manifest/stages/LoadManifestsStage.java | 293 ++++
.../manifest/stages/RenameFilesStage.java | 173 ++
.../manifest/stages/SaveSuccessFileStage.java | 79 +
.../manifest/stages/SaveTaskManifestStage.java | 81 +
.../committer/manifest/stages/SetupJobStage.java | 63 +
.../committer/manifest/stages/SetupTaskStage.java | 54 +
.../committer/manifest/stages/StageConfig.java | 556 ++++++
.../manifest/stages/StageEventCallbacks.java | 37 +
.../stages/TaskAttemptScanDirectoryStage.java | 214 +++
.../manifest/stages/ValidateRenamedFilesStage.java | 200 +++
.../committer/manifest/stages/package-info.java | 30 +
.../src/main/resources/mapred-default.xml | 19 +
.../src/site/markdown/manifest_committer.md | 605 +++++++
.../markdown/manifest_committer_architecture.md | 335 ++++
.../site/markdown/manifest_committer_protocol.md | 617 +++++++
.../manifest/AbstractManifestCommitterTest.java | 1085 ++++++++++++
.../committer/manifest/CommitterTestBinding.java | 152 ++
.../manifest/ManifestCommitterTestSupport.java | 420 +++++
.../committer/manifest/StubStoreOperations.java | 109 ++
.../committer/manifest/TaggedFileStatus.java | 54 +
.../committer/manifest/TestCleanupStage.java | 142 ++
.../committer/manifest/TestCommitTaskStage.java | 126 ++
.../manifest/TestCreateOutputDirectoriesStage.java | 307 ++++
.../manifest/TestJobThroughManifestCommitter.java | 601 +++++++
.../committer/manifest/TestLoadManifestsStage.java | 141 ++
.../manifest/TestManifestCommitProtocol.java | 1801 ++++++++++++++++++++
.../committer/manifest/TestRenameStageFailure.java | 379 ++++
.../committer/manifest/TestTaskManifestFileIO.java | 185 ++
.../committer/manifest/TextOutputForTests.java | 136 ++
.../committer/manifest/ThreadLeakTracker.java | 83 +
.../impl/UnreliableManifestStoreOperations.java | 380 +++++
.../output/committer/manifest/package-info.java | 29 +
.../src/test/resources/contract/localfs.xml | 138 ++
.../src/test/resources/core-site.xml | 33 +
hadoop-project/pom.xml | 7 +
hadoop-tools/hadoop-azure/pom.xml | 81 +-
.../src/config/checkstyle-suppressions.xml | 3 +
.../hadoop/fs/azurebfs/AbfsConfiguration.java | 9 +
.../hadoop/fs/azurebfs/AzureBlobFileSystem.java | 201 ++-
.../fs/azurebfs/AzureBlobFileSystemStore.java | 34 +-
.../commit/AbfsManifestStoreOperations.java | 130 ++
.../commit/AzureManifestCommitterFactory.java | 58 +
.../azurebfs/commit/ResilientCommitByRename.java | 101 ++
.../hadoop/fs/azurebfs/commit/package-info.java | 28 +
.../fs/azurebfs/constants/ConfigurationKeys.java | 3 +
.../constants/FileSystemConfigurations.java | 5 +
.../hadoop/fs/azurebfs/services/AbfsClient.java | 99 +-
.../fs/azurebfs/services/SimpleKeyProvider.java | 10 +-
.../fs/azurebfs/AbstractAbfsIntegrationTest.java | 11 +-
.../fs/azurebfs/ITestAbfsReadWriteAndSeek.java | 13 +-
.../ITestAzureBlobFileSystemDelegationSAS.java | 5 +-
.../fs/azurebfs/ITestCustomerProvidedKey.java | 3 +-
.../fs/azurebfs/commit/AbfsCommitTestHelper.java | 49 +
.../azurebfs/commit/AbstractAbfsClusterITest.java | 260 +++
.../fs/azurebfs/commit/ITestAbfsCleanupStage.java | 54 +
.../azurebfs/commit/ITestAbfsCommitTaskStage.java | 54 +
.../ITestAbfsCreateOutputDirectoriesStage.java | 54 +
.../ITestAbfsJobThroughManifestCommitter.java | 101 ++
.../commit/ITestAbfsLoadManifestsStage.java | 55 +
.../commit/ITestAbfsManifestCommitProtocol.java | 62 +
.../commit/ITestAbfsManifestStoreOperations.java | 175 ++
.../commit/ITestAbfsRenameStageFailure.java | 69 +
.../commit/ITestAbfsTaskManifestFileIO.java | 54 +
.../fs/azurebfs/commit/ITestAbfsTerasort.java | 353 ++++
.../hadoop/fs/azurebfs/commit/package-info.java | 24 +
.../azurebfs/contract/AbfsFileSystemContract.java | 2 +-
.../hadoop-azure/src/test/resources/core-site.xml | 25 +
109 files changed, 20174 insertions(+), 92 deletions(-)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/RateLimiting.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/RateLimitingFactory.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/CloseableTaskPoolSubmitter.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/TaskPool.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/functional/TestTaskPool.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitter.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitterConfig.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitterConstants.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitterFactory.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitterStatisticNames.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/AbstractManifestData.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/DiagnosticKeys.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/DirEntry.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/EntryStatus.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/FileEntry.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/ManifestPrinter.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/ManifestSuccessData.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/TaskManifest.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/files/package-info.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/AuditingIntegration.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/InternalConstants.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/ManifestCommitterSupport.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/ManifestStoreOperations.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/ManifestStoreOperationsThroughFileSystem.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/OutputValidationException.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/package-info.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/package-info.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/AbortTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/AbstractJobOrTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/CleanupJobStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/CommitJobStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/CommitTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/CreateOutputDirectoriesStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/JobOrTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/LoadManifestsStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/RenameFilesStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/SaveSuccessFileStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/SaveTaskManifestStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/SetupJobStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/SetupTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/StageConfig.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/StageEventCallbacks.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/TaskAttemptScanDirectoryStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/ValidateRenamedFilesStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/package-info.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/site/markdown/manifest_committer.md
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/site/markdown/manifest_committer_architecture.md
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/site/markdown/manifest_committer_protocol.md
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/AbstractManifestCommitterTest.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/CommitterTestBinding.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ManifestCommitterTestSupport.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/StubStoreOperations.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TaggedFileStatus.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestCleanupStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestCommitTaskStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestCreateOutputDirectoriesStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestJobThroughManifestCommitter.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestLoadManifestsStage.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestManifestCommitProtocol.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestRenameStageFailure.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestTaskManifestFileIO.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TextOutputForTests.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/ThreadLeakTracker.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/UnreliableManifestStoreOperations.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/package-info.java
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/resources/contract/localfs.xml
create mode 100644
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/resources/core-site.xml
create mode 100644
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/commit/AbfsManifestStoreOperations.java
create mode 100644
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/commit/AzureManifestCommitterFactory.java
create mode 100644
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/commit/ResilientCommitByRename.java
create mode 100644
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/commit/package-info.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/AbfsCommitTestHelper.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/AbstractAbfsClusterITest.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsCleanupStage.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsCommitTaskStage.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsCreateOutputDirectoriesStage.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsJobThroughManifestCommitter.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsLoadManifestsStage.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsManifestCommitProtocol.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsManifestStoreOperations.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsRenameStageFailure.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsTaskManifestFileIO.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/ITestAbfsTerasort.java
create mode 100644
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/commit/package-info.java
create mode 100644 hadoop-tools/hadoop-azure/src/test/resources/core-site.xml
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]