This is an automated email from the ASF dual-hosted git repository.
captainzmc pushed a change to branch HDDS-4454
in repository https://gitbox.apache.org/repos/asf/ozone.git.
omit e8af582 HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984)
omit 6aa63b7 [Ozone-Streaming] HDDS-6139. Fix incorrect computation of
totalAckDataLength. (#2978)
omit 51b8e9f HDDS-6130. [Ozone-Streaming] When releaseBuffers will get
“Couldn 't find the required future” (#2939)
omit 811f879 HDDS-6039. Define a minimum packet size during streaming
writes. (#2883)
omit f42c10a HDDS-5851. [Ozone-Streaming] Define a PutBlock/maxBuffer
fixed boundary for streaming writes. (#2866)
omit b64e696 HDDS-5743. [Ozone-Streaming] Add option to write files via
streaming api in ofs and o3fs. (#2770)
omit b8d31f2 HDDS-5879. [Ozone-Streaming] OzoneBucket add the
createMultipartStreamKey method (#2760)
omit 8d13099 HDDS-5961. [Ozone-Streaming] update the usage space of
Containers in the stream write (#2833)
omit 731b28e HDDS-5987. [Ozone-Streaming] Add XceiverClientRatis stream
config (#2841)
omit 9be29ee HDDS-5763. Provide an Executor for each LocalStream in
ContainerStateMachine (#2782)
omit 7b57844 HDDS-5895. [Ozone-Streaming] Make
raft.server.data-stream.client.pool.size configurable (#2766)
omit 9a33e34 HDDS-5674.[Ozone-Streaming] Handle client retries on
exception (#2701)
omit 51f6457 HDDS-5849. [Ozone-Streaming]Write exceptions occur after
checksum is enabled (#2729)
omit c51065e HDDS-5486. [Ozone-Streaming] Streaming supports writing in
Pipline mode (#2682)
omit a6ba9bd HDDS-5742. Avoid unnecessary Bytebuffer conversions (#2673)
omit 128bccb HDDS-5705. [Ozone-Streaming] Change ByteBufStreamOutput to
ByteBufferStreamOutput (#2603)
omit 61aa979 HDDS-5599. [Ozone-Streaming]drop BufferPool and ChunkBuffer
to avoid buffer copying (#2557)
omit f83b71c HDDS-5488. [Ozone-Streaming] Add a new
BlockOutputStream/KeyOutputStream to support streaming api (#2495)
omit 4de1725 HDDS-5480. [Ozone-Streaming] Client and server should support
stream setup. (#2452)
omit 14350a5 HDDS-5481. Fix stream() and link() method in
ContainerStateMachine. (#2451)
omit b432117 HDDS-5452. Add link method to ContainerStateMachine for Ratis
streaming (#2422)
omit 4c27943 HDDS-5366. [Ozone-Streaming] Implement stream method to
ContainerStateMachine. (#2358). Contributed by mingchao zhao
add 05773af HDDS-6135. SCM Container DB bootstrap on Recon startup for
SCM HA. (#2972)
add 66aadb0 HDDS-6109. Preserve the underlying exception raised in client
lib. (#2989)
add bd91ab9 HDDS-3408. Rename ChunkLayOutVersion to
ContainerLayoutVersion. (#2983)
add 18f1461 HDDS-6203. CleanUp incomplete gz files during Container move
(#3000)
add 2af225d HDDS-6216. Move OMOpenKeysDeleteRequest to package
om.request.key (#3011)
add ada4a3b HDDS-6191. Intermittent failure in TestDeleteWithSlowFollower
(#3015)
add 6180d21 HDDS-6128. CLI tool that downloads all the block replicas and
creates a manifest file (#2987)
add 3a16ebe HDDS-6177. Extend container info command to include replica
details (#2995)
add 5823f56 HDDS-6211. [Docs] Image styling on deployed site does not
replicate local builds. (#3007)
add d3b1a06 HDDS-6219. Switch to RATIS ReplicationType from STAND_ALONE
in our tests. (#3014)
add dc13410 HDDS-6192. feature/Observability.md translated to Chinese
(#2994)
add dc6f279 HDDS-6205. Add CLI command to display the latest Replication
Manager report (#3013)
add 11605e1 HDDS-6227. Test helpers should observe naming conditions
(#3020)
add 634d666 HDDS-6239. ozonesecure-mr failing with No URLs in mirrorlist
(#3029)
add 5d496f2 HDDS-6201. Fix NPE for DataScanner with scanned container
deleted by others. (#3005)
add 9186e6b HDDS-5529. For any IOexception from @Replicated method we
should throw it (#2788)
add 1804e22 HDDS-6181. Change SCMHAInvocationHandler#invokeRatis()
logging to TRACE (#2992)
add e47b6f0 HDDS-6206. Application errors must not flood system log
(#3001)
add f757d99 HDDS-6245. Add BucketLayout logging to Audit Logs (#3040)
add aafc21a HDDS-6238 Reduce memory requirements for list keys. (#3032)
add 7cee0ea HDDS-2919. Intermittent failure in TestRDBStore (#3028)
add 5a35cab HDDS-6253. Unnecessary duplicate smoketest after defaulting
to FSO (#3036)
add 5b1dbeb HDDS-6204. Cleanup handling malformed authorization header
(#2999)
add b32e135 HDDS-6169. Selective checks: skip junit tests on ozone-runner
image update (#2974)
add 14fa87c HDDS-6270. Use a dedicated file instead of /etc/passwd for
xcompat acceptance test (#3050)
add 5c3aa01 HDDS-6273. Amend doc SecuringTDE.md (#3047)
add c5fb612 HDDS-6140. Selective checks: skip unit check for
integration-test changes (#2948)
add 11f4c9b HDDS-6215. Recon get limited delta updates from OM (#3009)
add 40d0a40 HDDS-6226. Run tests for selective CI checks in CI (#3019)
add 86a771d HDDS-6247. Avoid logging stack trace for user input problems
(#3039)
new f158e36 HDDS-5366. [Ozone-Streaming] Implement stream method to
ContainerStateMachine. (#2358). Contributed by mingchao zhao
new a22a25b HDDS-5452. Add link method to ContainerStateMachine for Ratis
streaming (#2422)
new 44ea00b HDDS-5481. Fix stream() and link() method in
ContainerStateMachine. (#2451)
new 923c843 HDDS-5480. [Ozone-Streaming] Client and server should support
stream setup. (#2452)
new fd879f0 HDDS-5488. [Ozone-Streaming] Add a new
BlockOutputStream/KeyOutputStream to support streaming api (#2495)
new ed97ac4 HDDS-5599. [Ozone-Streaming]drop BufferPool and ChunkBuffer
to avoid buffer copying (#2557)
new 8e30bfd HDDS-5705. [Ozone-Streaming] Change ByteBufStreamOutput to
ByteBufferStreamOutput (#2603)
new 6eaabb3 HDDS-5742. Avoid unnecessary Bytebuffer conversions (#2673)
new e221851 HDDS-5486. [Ozone-Streaming] Streaming supports writing in
Pipline mode (#2682)
new 177438f HDDS-5849. [Ozone-Streaming]Write exceptions occur after
checksum is enabled (#2729)
new 5b190ea HDDS-5674.[Ozone-Streaming] Handle client retries on
exception (#2701)
new 286d04a HDDS-5895. [Ozone-Streaming] Make
raft.server.data-stream.client.pool.size configurable (#2766)
new a4ade67 HDDS-5763. Provide an Executor for each LocalStream in
ContainerStateMachine (#2782)
new 129cb2c HDDS-5987. [Ozone-Streaming] Add XceiverClientRatis stream
config (#2841)
new a25e50c HDDS-5961. [Ozone-Streaming] update the usage space of
Containers in the stream write (#2833)
new 27c395a HDDS-5879. [Ozone-Streaming] OzoneBucket add the
createMultipartStreamKey method (#2760)
new 3a9d7dc HDDS-5743. [Ozone-Streaming] Add option to write files via
streaming api in ofs and o3fs. (#2770)
new fd5af78 HDDS-5851. [Ozone-Streaming] Define a PutBlock/maxBuffer
fixed boundary for streaming writes. (#2866)
new e4c0c0f HDDS-6039. Define a minimum packet size during streaming
writes. (#2883)
new 5202efa HDDS-6130. [Ozone-Streaming] When releaseBuffers will get
“Couldn 't find the required future” (#2939)
new 3c9ecb8 [Ozone-Streaming] HDDS-6139. Fix incorrect computation of
totalAckDataLength. (#2978)
new dba70bb HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e8af582)
\
N -- N -- N refs/heads/HDDS-4454 (dba70bb)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 22 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:
.github/workflows/post-commit.yml | 6 +
.gitignore | 3 +-
dev-support/ci/selective_ci_checks.bats | 24 +-
dev-support/ci/selective_ci_checks.sh | 21 +-
.../hadoop/hdds/scm/storage/BlockOutputStream.java | 4 +-
.../hadoop/hdds/conf/OzoneConfiguration.java | 4 +-
.../org/apache/hadoop/hdds/scm/ScmConfigKeys.java | 4 +-
.../apache/hadoop/hdds/scm/client/ScmClient.java | 20 +
.../hdds/scm/container/ContainerReplicaInfo.java | 129 ++++
.../scm/container/ReplicationManagerReport.java | 95 ++-
.../protocol/StorageContainerLocationProtocol.java | 18 +
.../java/org/apache/hadoop/ozone/OzoneConsts.java | 1 +
.../org/apache/hadoop/ozone/audit/SCMAction.java | 3 +-
.../common/src/main/resources/ozone-default.xml | 22 +-
.../scm/container/TestContainerReplicaInfo.java | 59 ++
.../container/TestReplicationManagerReport.java | 49 ++
.../hadoop/hdds/scm/container}/package-info.java | 5 +-
...TestUpgradeUtils.java => UpgradeTestUtils.java} | 4 +-
.../common/helpers/DatanodeVersionFile.java | 8 +-
.../ozone/container/common/impl/ContainerData.java | 19 +-
.../container/common/impl/ContainerDataYaml.java | 11 +-
...OutVersion.java => ContainerLayoutVersion.java} | 34 +-
.../container/keyvalue/KeyValueContainerCheck.java | 10 +-
.../container/keyvalue/KeyValueContainerData.java | 8 +-
.../ozone/container/keyvalue/KeyValueHandler.java | 6 +-
.../keyvalue/impl/ChunkManagerDispatcher.java | 18 +-
.../keyvalue/impl/FilePerBlockStrategy.java | 4 +-
.../keyvalue/impl/FilePerChunkStrategy.java | 4 +-
.../container/ozoneimpl/ContainerController.java | 14 +-
.../replication/GrpcReplicationClient.java | 15 +-
.../ozone/container/common/ContainerTestUtils.java | 4 +-
.../container/common/TestBlockDeletingService.java | 13 +-
...ersion.java => TestContainerLayoutVersion.java} | 12 +-
.../common/TestKeyValueContainerData.java | 10 +-
.../common/impl/TestContainerDataYaml.java | 16 +-
.../impl/TestContainerDeletionChoosingPolicy.java | 8 +-
.../common/impl/TestContainerPersistence.java | 8 +-
.../container/common/impl/TestContainerSet.java | 8 +-
.../container/common/impl/TestHddsDispatcher.java | 8 +-
.../TestCloseContainerCommandHandler.java | 10 +-
.../common/volume/TestStorageVolumeChecker.java | 8 +-
...tTestInfo.java => ContainerLayoutTestInfo.java} | 24 +-
.../keyvalue/TestKeyValueBlockIterator.java | 10 +-
.../container/keyvalue/TestKeyValueContainer.java | 16 +-
.../keyvalue/TestKeyValueContainerCheck.java | 9 +-
.../TestKeyValueContainerMarkUnhealthy.java | 8 +-
.../container/keyvalue/TestKeyValueHandler.java | 8 +-
.../container/keyvalue/TestTarContainerPacker.java | 8 +-
.../keyvalue/impl/AbstractTestChunkManager.java | 8 +-
.../keyvalue/impl/TestBlockManagerImpl.java | 10 +-
.../keyvalue/impl/TestChunkManagerDummyImpl.java | 6 +-
.../keyvalue/impl/TestFilePerBlockStrategy.java | 6 +-
.../keyvalue/impl/TestFilePerChunkStrategy.java | 12 +-
.../container/ozoneimpl/TestContainerReader.java | 8 +-
.../container/ozoneimpl/TestOzoneContainer.java | 10 +-
.../replication/TestReplicationSupervisor.java | 10 +-
.../upgrade/TestDataNodeStartupSlvLessThanMlv.java | 4 +-
hadoop-hdds/docs/content/feature/Observability.md | 2 +-
.../{Observability.md => Observability.zh.md} | 63 +-
hadoop-hdds/docs/content/security/SecuringTDE.md | 48 +-
.../docs/content/security/SecuringTDE.zh.md | 4 +-
.../themes/ozonedoc/layouts/shortcodes/image.html | 2 +-
...inerLocationProtocolClientSideTranslatorPB.java | 38 ++
.../apache/hadoop/hdds/utils/db/TestRDBStore.java | 36 --
.../src/main/proto/ScmAdminProtocol.proto | 23 +
.../interface-client/src/main/proto/hdds.proto | 25 +
.../hdds/scm/container/ReplicationManager.java | 5 +
.../hadoop/hdds/scm/ha/SCMHAInvocationHandler.java | 5 +-
.../hadoop/hdds/scm/ha/SCMRatisServerImpl.java | 3 +-
.../scm/pipeline/PipelineStateManagerImpl.java | 7 +-
...inerLocationProtocolServerSideTranslatorPB.java | 33 +
.../hdds/scm/server/SCMClientProtocolServer.java | 32 +
.../org/apache/hadoop/hdds/scm/HddsTestUtils.java | 692 +++++++++++++++++++-
.../java/org/apache/hadoop/hdds/scm/TestUtils.java | 699 ---------------------
.../hadoop/hdds/scm/block/TestBlockManager.java | 18 +-
.../hadoop/hdds/scm/block/TestDeletedBlockLog.java | 4 +-
.../command/TestCommandStatusReportHandler.java | 4 +-
.../hadoop/hdds/scm/container/MockNodeManager.java | 6 +-
.../container/TestCloseContainerEventHandler.java | 4 +-
.../scm/container/TestContainerReportHandler.java | 4 +-
.../TestIncrementalContainerReportHandler.java | 4 +-
.../hdds/scm/container/TestReplicationManager.java | 4 +-
.../scm/container/TestUnknownContainerReport.java | 2 +-
.../algorithms/TestContainerPlacementFactory.java | 12 +-
.../TestSCMContainerPlacementCapacity.java | 12 +-
.../TestSCMContainerPlacementRackAware.java | 22 +-
.../TestSCMContainerPlacementRandom.java | 16 +-
.../hdds/scm/crl/TestCRLStatusReportHandler.java | 4 +-
.../hdds/scm/node/TestContainerPlacement.java | 6 +-
.../hadoop/hdds/scm/node/TestDeadNodeHandler.java | 43 +-
.../hdds/scm/node/TestNodeDecommissionManager.java | 4 +-
.../hdds/scm/node/TestNodeReportHandler.java | 10 +-
.../hadoop/hdds/scm/node/TestSCMNodeManager.java | 68 +-
.../hdds/scm/node/TestSCMNodeStorageStatMap.java | 15 +-
.../hadoop/hdds/scm/node/TestStatisticsUpdate.java | 16 +-
.../hdds/scm/pipeline/TestPipelineManagerImpl.java | 11 +-
.../scm/server/TestSCMBlockProtocolServer.java | 4 +-
.../TestSCMHAUnfinalizedStateValidationAction.java | 4 +-
.../scm/upgrade/TestScmStartupSlvLessThanMlv.java | 4 +-
.../ozone/container/common/TestEndPoint.java | 23 +-
.../hadoop/ozone/scm/node/TestSCMNodeMetrics.java | 11 +-
hadoop-hdds/tools/pom.xml | 9 +
.../hdds/scm/cli/ContainerOperationClient.java | 28 +
.../hdds/scm/cli/container/ContainerCommands.java | 3 +-
.../hdds/scm/cli/container/InfoSubcommand.java | 61 +-
.../hdds/scm/cli/container/ReportSubcommand.java | 116 ++++
.../hdds/scm/cli/container/TestInfoSubCommand.java | 249 ++++++++
.../scm/cli/container/TestReportSubCommand.java | 159 +++++
.../ozone/client/protocol/ClientProtocol.java | 17 +
.../apache/hadoop/ozone/client/rpc/RpcClient.java | 63 ++
.../hadoop/ozone/om/helpers/OmBucketInfo.java | 1 +
hadoop-ozone/dev-support/checks/bats.sh | 8 +-
.../dist/src/main/compose/ozone-ha/docker-config | 4 +
hadoop-ozone/dist/src/main/compose/ozone/test.sh | 6 -
.../dist/src/main/compose/ozonesecure-mr/test.sh | 4 +-
.../src/main/smoketest/compatibility/read.robot | 9 +-
.../{kinit.robot => compatibility/setup.robot} | 16 +-
.../src/main/smoketest/compatibility/write.robot | 7 +-
.../hdds/scm/pipeline/TestPipelineClose.java | 4 +-
.../apache/hadoop/ozone/MiniOzoneClusterImpl.java | 6 +-
.../hadoop/ozone/MiniOzoneHAClusterImpl.java | 6 +-
.../java/org/apache/hadoop/ozone/TestDataUtil.java | 2 +-
.../hadoop/ozone/TestSecureOzoneCluster.java | 22 +-
.../hadoop/ozone/TestStorageContainerManager.java | 8 +-
.../rpc/TestContainerStateMachineFailures.java | 159 ++++-
.../client/rpc/TestDeleteWithSlowFollower.java | 11 +-
.../client/rpc/TestOzoneAtRestEncryption.java | 12 +-
.../rpc/TestOzoneClientMultipartUploadWithFSO.java | 46 +-
.../client/rpc/TestOzoneRpcClientAbstract.java | 93 +--
.../hadoop/ozone/client/rpc/TestReadRetries.java | 4 +-
.../ozone/client/rpc/TestSecureOzoneRpcClient.java | 6 +-
.../client/rpc/read/TestChunkInputStream.java | 4 +-
.../ozone/client/rpc/read/TestInputStreamBase.java | 15 +-
.../ozone/client/rpc/read/TestKeyInputStream.java | 4 +-
.../apache/hadoop/ozone/container/TestHelper.java | 7 +-
.../commandhandler/TestCloseContainerHandler.java | 4 +-
.../commandhandler/TestDeleteContainerHandler.java | 3 +-
.../container/metrics/TestContainerMetrics.java | 3 +-
.../container/server/TestContainerServer.java | 3 +-
.../server/TestSecureContainerServer.java | 3 +-
.../hadoop/ozone/dn/scrubber/TestDataScrubber.java | 7 +-
.../TestDatanodeHddsVolumeFailureDetection.java | 7 +-
.../freon/TestHadoopDirTreeGeneratorWithFSO.java | 4 +-
.../ozone/om/TestContainerReportWithKeys.java | 2 +-
.../apache/hadoop/ozone/om/TestKeyManagerImpl.java | 26 +-
.../org/apache/hadoop/ozone/om/TestKeyPurging.java | 2 +-
.../hadoop/ozone/om/TestObjectStoreWithFSO.java | 8 +-
.../org/apache/hadoop/ozone/om/TestOmLDBCli.java | 4 +-
.../ozone/om/TestOmStartupSlvLessThanMlv.java | 4 +-
.../apache/hadoop/ozone/om/TestOzoneManagerHA.java | 4 +-
.../hadoop/ozone/om/TestOzoneManagerPrepare.java | 2 +-
.../hadoop/ozone/om/TestRecursiveAclWithFSO.java | 4 +-
.../om/ratis/TestOzoneManagerRatisRequest.java | 4 +-
.../hadoop/ozone/recon/TestReconScmHASnapshot.java | 70 +++
.../hadoop/ozone/recon/TestReconScmSnapshot.java | 133 ++++
.../ozone/recon/TestReconWithOzoneManager.java | 4 +-
.../ozone/recon/TestReconWithOzoneManagerFSO.java | 6 +-
.../hadoop/ozone/scm/TestFailoverWithSCMHA.java | 2 +-
.../ozone/scm/TestStorageContainerManagerHA.java | 4 +-
.../hadoop/ozone/shell/TestNSSummaryAdmin.java | 4 +-
.../hadoop/ozone/om/codec/TestOmKeyInfoCodec.java | 4 +-
.../ozone/om/codec/TestRepeatedOmKeyInfoCodec.java | 4 +-
.../ozone/om/helpers/TestInstanceHelper.java | 68 --
.../hadoop/ozone/om/helpers/TestOmPrefixInfo.java | 39 +-
.../hadoop/ozone/om/OmMetadataManagerImpl.java | 16 +-
.../key/OMOpenKeysDeleteRequest.java | 4 +-
.../hadoop/ozone/om/TestBucketManagerImpl.java | 6 +-
.../hadoop/ozone/om/TestKeyDeletingService.java | 7 +-
.../apache/hadoop/ozone/om/TestKeyManagerUnit.java | 16 +-
.../hadoop/ozone/om/TestOmMetadataManager.java | 36 +-
.../apache/hadoop/ozone/om/TestTrashService.java | 6 +-
...TestOzoneManagerDoubleBufferWithOMResponse.java | 8 +-
...OMRequestUtils.java => OMRequestTestUtils.java} | 10 +-
.../request/TestOMClientRequestWithUserInfo.java | 2 +-
.../request/bucket/TestOMBucketCreateRequest.java | 8 +-
.../bucket/TestOMBucketCreateRequestWithFSO.java | 4 +-
.../request/bucket/TestOMBucketDeleteRequest.java | 6 +-
.../bucket/TestOMBucketSetPropertyRequest.java | 8 +-
.../bucket/acl/TestOMBucketAddAclRequest.java | 12 +-
.../bucket/acl/TestOMBucketRemoveAclRequest.java | 14 +-
.../bucket/acl/TestOMBucketSetAclRequest.java | 12 +-
.../request/file/TestOMDirectoryCreateRequest.java | 22 +-
.../file/TestOMDirectoryCreateRequestWithFSO.java | 48 +-
.../om/request/file/TestOMFileCreateRequest.java | 30 +-
.../file/TestOMFileCreateRequestWithFSO.java | 22 +-
.../om/request/key/TestOMAllocateBlockRequest.java | 12 +-
.../key/TestOMAllocateBlockRequestWithFSO.java | 10 +-
.../ozone/om/request/key/TestOMKeyAclRequest.java | 10 +-
.../om/request/key/TestOMKeyAclRequestWithFSO.java | 8 +-
.../om/request/key/TestOMKeyCommitRequest.java | 12 +-
.../request/key/TestOMKeyCommitRequestWithFSO.java | 8 +-
.../om/request/key/TestOMKeyCreateRequest.java | 8 +-
.../request/key/TestOMKeyCreateRequestWithFSO.java | 6 +-
.../om/request/key/TestOMKeyDeleteRequest.java | 10 +-
.../request/key/TestOMKeyDeleteRequestWithFSO.java | 10 +-
.../key/TestOMKeyPurgeRequestAndResponse.java | 8 +-
.../om/request/key/TestOMKeyRenameRequest.java | 15 +-
.../om/request/key/TestOMKeysDeleteRequest.java | 6 +-
.../om/request/key/TestOMKeysRenameRequest.java | 6 +-
.../request/key/TestOMOpenKeysDeleteRequest.java | 11 +-
.../om/request/key/TestOMPrefixAclRequest.java | 6 +-
.../TestS3InitiateMultipartUploadRequest.java | 6 +-
...estS3InitiateMultipartUploadRequestWithFSO.java | 4 +-
.../s3/multipart/TestS3MultipartRequest.java | 12 +-
.../TestS3MultipartUploadAbortRequest.java | 8 +-
.../TestS3MultipartUploadAbortRequestWithFSO.java | 4 +-
.../TestS3MultipartUploadCommitPartRequest.java | 12 +-
...tS3MultipartUploadCommitPartRequestWithFSO.java | 10 +-
.../TestS3MultipartUploadCompleteRequest.java | 12 +-
...estS3MultipartUploadCompleteRequestWithFSO.java | 8 +-
.../upgrade/TestOMCancelPrepareRequest.java | 2 +-
.../request/volume/TestOMVolumeCreateRequest.java | 4 +-
.../request/volume/TestOMVolumeDeleteRequest.java | 12 +-
.../volume/TestOMVolumeSetOwnerRequest.java | 22 +-
.../volume/TestOMVolumeSetQuotaRequest.java | 22 +-
.../volume/acl/TestOMVolumeAddAclRequest.java | 12 +-
.../volume/acl/TestOMVolumeRemoveAclRequest.java | 14 +-
.../volume/acl/TestOMVolumeSetAclRequest.java | 12 +-
.../file/TestOMDirectoryCreateResponse.java | 4 +-
.../file/TestOMDirectoryCreateResponseWithFSO.java | 4 +-
.../file/TestOMFileCreateResponseWithFSO.java | 4 +-
.../response/key/TestOMAllocateBlockResponse.java | 4 +-
.../key/TestOMAllocateBlockResponseWithFSO.java | 4 +-
.../om/response/key/TestOMKeyCommitResponse.java | 6 +-
.../key/TestOMKeyCommitResponseWithFSO.java | 8 +-
.../key/TestOMKeyCreateResponseWithFSO.java | 4 +-
.../om/response/key/TestOMKeyDeleteResponse.java | 4 +-
.../key/TestOMKeyDeleteResponseWithFSO.java | 12 +-
.../om/response/key/TestOMKeyRenameResponse.java | 14 +-
.../ozone/om/response/key/TestOMKeyResponse.java | 4 +-
.../om/response/key/TestOMKeysDeleteResponse.java | 4 +-
.../om/response/key/TestOMKeysRenameResponse.java | 8 +-
.../response/key/TestOMOpenKeysDeleteResponse.java | 8 +-
...S3MultipartUploadCommitPartResponseWithFSO.java | 10 +-
...stS3MultipartUploadCompleteResponseWithFSO.java | 18 +-
.../security/acl/TestOzoneNativeAuthorizer.java | 6 +-
.../hadoop/ozone/security/acl/TestParentAcl.java | 6 +-
.../hadoop/ozone/security/acl/TestVolumeOwner.java | 6 +-
.../hadoop/ozone/recon/ReconServerConfigKeys.java | 7 +
.../hadoop/ozone/recon/scm/ReconNodeManager.java | 6 +
.../spi/impl/OzoneManagerServiceProviderImpl.java | 49 +-
.../impl/StorageContainerServiceProviderImpl.java | 48 +-
.../impl/TestOzoneManagerServiceProviderImpl.java | 86 ++-
.../hadoop/ozone/s3/OzoneClientProducer.java | 17 +-
.../hadoop/ozone/s3/endpoint/BucketEndpoint.java | 15 +-
.../hadoop/ozone/s3/endpoint/ObjectEndpoint.java | 37 +-
.../hadoop/ozone/s3/exception/S3ErrorTable.java | 12 +-
.../hadoop/ozone/client/OzoneBucketStub.java | 2 +-
.../hadoop/ozone/s3/TestOzoneClientProducer.java | 39 +-
.../hadoop/ozone/s3/endpoint/TestObjectHead.java | 2 +-
.../apache/hadoop/ozone/debug/ChunkKeyHandler.java | 6 +-
.../apache/hadoop/ozone/debug/ReadReplicas.java | 247 ++++++++
.../hadoop/ozone/freon/ChunkManagerDiskWrite.java | 8 +-
.../containergenerator/GeneratorDatanode.java | 6 +-
254 files changed, 3955 insertions(+), 1926 deletions(-)
create mode 100644
hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/container/ContainerReplicaInfo.java
rename hadoop-hdds/{server-scm =>
common}/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManagerReport.java
(65%)
create mode 100644
hadoop-hdds/common/src/test/java/org/apache/hadoop/hdds/scm/container/TestContainerReplicaInfo.java
rename hadoop-hdds/{server-scm =>
common}/src/test/java/org/apache/hadoop/hdds/scm/container/TestReplicationManagerReport.java
(67%)
copy hadoop-hdds/{server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha =>
common/src/test/java/org/apache/hadoop/hdds/scm/container}/package-info.java
(89%)
rename
hadoop-hdds/common/src/test/java/org/apache/hadoop/ozone/upgrade/{TestUpgradeUtils.java
=> UpgradeTestUtils.java} (95%)
rename
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/{ChunkLayOutVersion.java
=> ContainerLayoutVersion.java} (77%)
rename
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/{TestChunkLayOutVersion.java
=> TestContainerLayoutVersion.java} (73%)
rename
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/{ChunkLayoutTestInfo.java
=> ContainerLayoutTestInfo.java} (84%)
copy hadoop-hdds/docs/content/feature/{Observability.md =>
Observability.zh.md} (65%)
delete mode 100644
hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/TestUtils.java
create mode 100644
hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/container/ReportSubcommand.java
create mode 100644
hadoop-hdds/tools/src/test/java/org/apache/hadoop/hdds/scm/cli/container/TestInfoSubCommand.java
create mode 100644
hadoop-hdds/tools/src/test/java/org/apache/hadoop/hdds/scm/cli/container/TestReportSubCommand.java
copy hadoop-ozone/dist/src/main/smoketest/{kinit.robot =>
compatibility/setup.robot} (75%)
create mode 100644
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/recon/TestReconScmHASnapshot.java
create mode 100644
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/recon/TestReconScmSnapshot.java
delete mode 100644
hadoop-ozone/interface-storage/src/test/java/org/apache/hadoop/ozone/om/helpers/TestInstanceHelper.java
rename
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/{response
=> request}/key/OMOpenKeysDeleteRequest.java (98%)
rename
hadoop-ozone/ozone-manager/src/test/java/org/apache/hadoop/ozone/om/request/{TestOMRequestUtils.java
=> OMRequestTestUtils.java} (99%)
create mode 100644
hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/ReadReplicas.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
