This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a change to branch HDDS-4454
in repository https://gitbox.apache.org/repos/asf/ozone.git
omit 56f7976035 HDDS-6592. [Ozone-Streaming] Fix
ContainerStateMachine#applyTransaction assert error (#3315)
omit 165158cc61 HDDS-5666. Add option to createKey via streaming api in
Freon (#2574)
omit 1ee1a9e62f HDDS-6500. [Ozone-Streaming] Buffer the PutBlockRequest at
the end of the stream. (#3229)
omit 8995a692c2 HDDS-6137. [Ozone-Streaming] Refactor KeyDataStreamOutput.
(#3195)
omit a53f57199d HDDS-5798. [Ozone-Streaming] Setup TlsConf parameters.
(#3207)
omit 1b559fe471 HDDS-6461. Update Ratis version to 2.3.0-da5d868-SNAPSHOT.
(#3205)
omit 4ada8072ff HDDS-6388. [Ozone-Streaming] Streaming write support both
pipeline model and star model (#3145)
omit fac96466c8 HDDS-6355. [Ozone-Streaming] Fix CheckStyle problem (#3119)
omit 7a6ed81645 HDDS-6229. [Ozone-Streaming] Data Channel abstraction on
datanode (#3023)
omit 07d88767bd HDDS-6282. Fix BlockDataStreamOutput#doFlushIfNeeded NPE
(#3060)
omit 5932655dcc HDDS-5487. [Ozone-Streaming] BlockDataStreamOutput support
FlushDelay. (#3002)
omit ed6a76185c HDDS-6298. Add XceiverServerRatis stream config (#3070)
omit 60fedb00f0 HDDS-6138.[Ozone-Streaming] Define a limit on the size of
the retry bufferList. (#2946)
omit c7e4ad51a8 HDDS-6281. Update ratis version to 2.3.0-94db58b-SNAPSHOT
version (#3059)
omit 239ed3eae3 HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984)
omit 159985138a HDDS-6139. [Ozone-Streaming] Fix incorrect computation of
totalAckDataLength. (#2978)
omit 35ae290054 HDDS-6130. [Ozone-Streaming] When releaseBuffers will get
“Couldn 't find the required future” (#2939)
omit 40cf7e9fe7 HDDS-6039. Define a minimum packet size during streaming
writes. (#2883)
omit de79a783b5 HDDS-5851. [Ozone-Streaming] Define a PutBlock/maxBuffer
fixed boundary for streaming writes. (#2866)
omit 6608f39c7a HDDS-5743. [Ozone-Streaming] Add option to write files via
streaming api in ofs and o3fs. (#2770)
omit be48e28991 HDDS-5879. [Ozone-Streaming] OzoneBucket add the
createMultipartStreamKey method (#2760)
omit 628a7a4010 HDDS-5961. [Ozone-Streaming] update the usage space of
Containers in the stream write (#2833)
omit 9c71a2522a HDDS-5987. [Ozone-Streaming] Add XceiverClientRatis stream
config (#2841)
omit 888f948e8c HDDS-5763. Provide an Executor for each LocalStream in
ContainerStateMachine (#2782)
omit d6b3b5c8f0 HDDS-5895. [Ozone-Streaming] Make
raft.server.data-stream.client.pool.size configurable (#2766)
omit 47bcdf7d3f HDDS-5674.[Ozone-Streaming] Handle client retries on
exception (#2701)
omit 532d9a34a3 HDDS-5849. [Ozone-Streaming]Write exceptions occur after
checksum is enabled (#2729)
omit c210ad42e4 HDDS-5486. [Ozone-Streaming] Streaming supports writing in
Pipline mode (#2682)
omit 170c2d929e HDDS-5742. Avoid unnecessary Bytebuffer conversions (#2673)
omit 6c1f954481 HDDS-5705. [Ozone-Streaming] Change ByteBufStreamOutput to
ByteBufferStreamOutput (#2603)
omit ebae76879e HDDS-5599. [Ozone-Streaming]drop BufferPool and
ChunkBuffer to avoid buffer copying (#2557)
omit 5f2d2e973c HDDS-5488. [Ozone-Streaming] Add a new
BlockOutputStream/KeyOutputStream to support streaming api (#2495)
omit 354cc3e3a1 HDDS-5480. [Ozone-Streaming] Client and server should
support stream setup. (#2452)
omit c6a242e815 HDDS-5481. Fix stream() and link() method in
ContainerStateMachine. (#2451)
omit 7921b79095 HDDS-5452. Add link method to ContainerStateMachine for
Ratis streaming (#2422)
omit 2f128b9ac4 HDDS-5366. [Ozone-Streaming] Implement stream method to
ContainerStateMachine. (#2358). Contributed by mingchao zhao
add 3b66583c6f HDDS-6560. Add general Grafana dashboard (#3285)
add a6afe188fd HDDS-6630. Explicitly remove node after being chosen (#3332)
add 4046150447 HDDS-6730. Migrate tests in hdds-tools to JUnit5 (#3402)
add f131de5f99 HDDS-5919. In kubernetes OM HA has circular dependency on
service availability (#3185)
add 340f5661e4 HDDS-6731. Migrate simple tests in hdds-server-framework to
JUnit5 (#3412)
add 690b3cd338 HDDS-6748. Intermittent timeout in
TestECBlockReconstructedInputStream#testReadDataWithUnbuffer (#3416)
add ed470082e6 HDDS-6742. Audit operation category mismatch (#3407)
add 71b4feb0ba HDDS-6657. Improve Ozone integrated Ranger configuration
instructions (#3365)
add fb0917328b HDDS-6749. SCM includes itself as peer in addSCM request
(#3413)
add 5ba03daab7 HDDS-6750. Migrate simple tests in hdds-server-scm to
JUnit5 (#3417)
add 44cf924f4d HDDS-6660: EC: Add the DN side Reconstruction Handler
class. (#3399)
add e169d71467 HDDS-6737. Migrate parameterized tests in
hdds-server-framework to JUnit5 (#3414)
add a26ad30f6b HDDS-6596. EC: Support ListBlock from CoordinatorDN (#3410)
add f328aa033b HDDS-6491. Support FSO keys in getExpiredOpenKeys (#3226)
add 1067d353c0 HDDS-6650. S3MultipartUpload support update bucket
usedNamespace. (#3404)
add d5e2b758f0 HDDS-6738. Migrate tests with rules in
hdds-server-framework to JUnit5 (#3415)
add 78a018814c HDDS-6744. EC: ReplicationManager - create
ContainerReplicaPendingOps class and integrate with ContainerManager (#3425)
add d6ece18f28 HDDS-6097. Upgrade to Ratis 2.3.0, gRPC 1.44.0, Netty
4.1.74 (#3433)
add 6cf05906ef HDDS-6777. Upgrade JUnit 5 to 5.8.2 (#3437)
add a6994b2d87 HDDS-6787. Bump gson to 2.8.9 (#3441)
add 2b8c4b7324 HDDS-6779. Register metricSink after initialization in S3
Gateway (#3436)
add fee0de9dd4 HDDS-6784. Missing close() for two RocksDB table iterators
(#3440)
add 51ee649a15 HDDS-6778. Bump Guava to 31.1 (#3435)
add be1180f4b1 HDDS-6786. Bad value for metric NumBytesCommittedCount in
testContainerStateMachineMetrics (#3443)
add ddb1fe24ab HDDS-6756. NPE raised by RpcClient if ServiceInfo
certificates empty (#3428)
add c01fc7907a HDDS-6674. Create compat acceptance split (#3369)
add 4f35293124 HDDS-6765. Get snapshot of write OMLockMetrics (#3427)
add 377be9644f HDDS-6476. Support FSO in OMOpenKeysDeleteRequest and
Response (#3233)
add 77e53623ac HDDS-6648. Fix the inconsistency between
network-topology-default.xml and network-topology-default.yaml(#3350)
new 89dccf224f HDDS-5366. [Ozone-Streaming] Implement stream method to
ContainerStateMachine. (#2358). Contributed by mingchao zhao
new 9518dcf568 HDDS-5452. Add link method to ContainerStateMachine for
Ratis streaming (#2422)
new 6f9ef072bc HDDS-5481. Fix stream() and link() method in
ContainerStateMachine. (#2451)
new 968d1f1ac8 HDDS-5480. [Ozone-Streaming] Client and server should
support stream setup. (#2452)
new a4ef7a6d50 HDDS-5488. [Ozone-Streaming] Add a new
BlockOutputStream/KeyOutputStream to support streaming api (#2495)
new b19f749926 HDDS-5599. [Ozone-Streaming]drop BufferPool and
ChunkBuffer to avoid buffer copying (#2557)
new 05b1910e2a HDDS-5705. [Ozone-Streaming] Change ByteBufStreamOutput to
ByteBufferStreamOutput (#2603)
new 0309d29aae HDDS-5742. Avoid unnecessary Bytebuffer conversions (#2673)
new a96e868eb8 HDDS-5486. [Ozone-Streaming] Streaming supports writing in
Pipline mode (#2682)
new 4e6fd1f578 HDDS-5849. [Ozone-Streaming]Write exceptions occur after
checksum is enabled (#2729)
new 37f5385c87 HDDS-5674.[Ozone-Streaming] Handle client retries on
exception (#2701)
new 54cd1fe8cd HDDS-5895. [Ozone-Streaming] Make
raft.server.data-stream.client.pool.size configurable (#2766)
new 659397a1da HDDS-5763. Provide an Executor for each LocalStream in
ContainerStateMachine (#2782)
new ad9d281225 HDDS-5987. [Ozone-Streaming] Add XceiverClientRatis stream
config (#2841)
new 4871da7d8e HDDS-5961. [Ozone-Streaming] update the usage space of
Containers in the stream write (#2833)
new d159210cbb HDDS-5879. [Ozone-Streaming] OzoneBucket add the
createMultipartStreamKey method (#2760)
new 49564be02a HDDS-5743. [Ozone-Streaming] Add option to write files via
streaming api in ofs and o3fs. (#2770)
new 2ef3b47fcf HDDS-5851. [Ozone-Streaming] Define a PutBlock/maxBuffer
fixed boundary for streaming writes. (#2866)
new ad505bc02e HDDS-6039. Define a minimum packet size during streaming
writes. (#2883)
new 6cd0e89dad HDDS-6130. [Ozone-Streaming] When releaseBuffers will get
“Couldn 't find the required future” (#2939)
new b36004cca7 HDDS-6139. [Ozone-Streaming] Fix incorrect computation of
totalAckDataLength. (#2978)
new f1dba712e3 HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984)
new 6f32ef6bdc HDDS-6281. Update ratis version to 2.3.0-94db58b-SNAPSHOT
version (#3059)
new 5dce655fdf HDDS-6138.[Ozone-Streaming] Define a limit on the size of
the retry bufferList. (#2946)
new a793f3a003 HDDS-6298. Add XceiverServerRatis stream config (#3070)
new 84eb68320c HDDS-5487. [Ozone-Streaming] BlockDataStreamOutput support
FlushDelay. (#3002)
new b09515f7bb HDDS-6282. Fix BlockDataStreamOutput#doFlushIfNeeded NPE
(#3060)
new f5290d312c HDDS-6229. [Ozone-Streaming] Data Channel abstraction on
datanode (#3023)
new aace239b72 HDDS-6355. [Ozone-Streaming] Fix CheckStyle problem (#3119)
new ad5668e280 HDDS-6388. [Ozone-Streaming] Streaming write support both
pipeline model and star model (#3145)
new df4c12abf5 HDDS-6461. Update Ratis version to 2.3.0-da5d868-SNAPSHOT.
(#3205)
new a194579f9c HDDS-5798. [Ozone-Streaming] Setup TlsConf parameters.
(#3207)
new bfb9216b5e HDDS-6137. [Ozone-Streaming] Refactor KeyDataStreamOutput.
(#3195)
new f5175dbd2d HDDS-6500. [Ozone-Streaming] Buffer the PutBlockRequest at
the end of the stream. (#3229)
new 01ffcc2ccb HDDS-5666. Add option to createKey via streaming api in
Freon (#2574)
new 185a28cedf HDDS-6592. [Ozone-Streaming] Fix
ContainerStateMachine#applyTransaction assert error (#3315)
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 (56f7976035)
\
N -- N -- N refs/heads/HDDS-4454 (185a28cedf)
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 36 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 | 1 +
.../io/TestECBlockReconstructedInputStream.java | 4 +-
.../org/apache/hadoop/hdds/scm/ha/SCMHAUtils.java | 8 +-
.../hdds/scm/storage/ContainerProtocolCalls.java | 46 +
.../org/apache/hadoop/ozone/OzoneConfigKeys.java | 10 +
.../java/org/apache/hadoop/ozone/ha/ConfUtils.java | 11 -
.../apache/hadoop/ozone/util/OzoneNetUtils.java | 117 +
.../main/resources/network-topology-default.yaml | 26 +-
.../common/src/main/resources/ozone-default.xml | 21 +
.../org/apache/hadoop/hdds/scm/TestSCMHAUtils.java | 54 +
.../hadoop/hdds/scm/net/TestYamlSchemaLoader.java | 13 +
.../apache/hadoop/ozone/ha/TestOzoneNetUtils.java} | 24 +-
.../apache/hadoop/ozone/HddsDatanodeService.java | 3 +
.../common/statemachine/DatanodeStateMachine.java | 9 +
.../ReconstructECContainersCommandHandler.java | 78 +
.../server/ratis/ContainerStateMachine.java | 2 +-
.../ECReconstructionCommandInfo.java | 82 +
.../ECReconstructionCoordinatorTask.java | 52 +
.../reconstruction/ECReconstructionSupervisor.java | 72 +
.../container/ec/reconstruction}/package-info.java | 5 +-
.../commands/ReconstructECContainersCommand.java | 5 +-
.../TestECReconstructionSupervisor.java | 53 +
.../docs/content/security/SecurityWithRanger.md | 7 +
.../docs/content/security/SecurityWithRanger.zh.md | 9 +-
hadoop-hdds/framework/pom.xml | 4 +
.../SCMBlockLocationFailoverProxyProvider.java | 3 +
.../exceptions/TestSCMExceptionResultCodes.java | 19 +-
.../token/TestOzoneBlockTokenIdentifier.java | 16 +-
.../hdds/security/token/TokenVerifierTests.java | 4 +-
.../certificate/authority/TestDefaultCAServer.java | 40 +-
.../certificate/authority/TestDefaultProfile.java | 22 +-
.../client/TestCertificateClientInit.java | 73 +-
.../client/TestDefaultCertificateClient.java | 60 +-
.../x509/certificate/utils/TestCRLCodec.java | 26 +-
.../certificate/utils/TestCertificateCodec.java | 41 +-
.../certificates/TestCertificateSignRequest.java | 60 +-
.../x509/certificates/TestRootCertificate.java | 68 +-
.../security/x509/keys/TestHDDSKeyGenerator.java | 14 +-
.../hdds/security/x509/keys/TestKeyCodec.java | 49 +-
.../apache/hadoop/hdds/server/TestJsonUtils.java | 8 +-
.../apache/hadoop/hdds/server/TestServerUtils.java | 28 +-
.../hadoop/hdds/server/events/TestEventQueue.java | 28 +-
.../hdds/server/events/TestEventQueueChain.java | 2 +-
.../hdds/server/events/TestEventWatcher.java | 46 +-
.../hdds/server/http/TestBaseHttpServer.java | 8 +-
.../hadoop/hdds/server/http/TestHtmlQuoting.java | 31 +-
.../hdds/server/http/TestHttpRequestLog.java | 16 +-
.../server/http/TestHttpRequestLogAppender.java | 12 +-
.../hadoop/hdds/server/http/TestHttpServer2.java | 4 +-
.../hdds/server/http/TestProfileServlet.java | 39 +-
.../server/http/TestPrometheusMetricsSink.java | 47 +-
.../server/http/TestRatisDropwizardExports.java | 13 +-
.../hdds/server/http/TestRatisNameRewrite.java | 65 +-
.../hadoop/hdds/utils/db/TestDBConfigFromFile.java | 33 +-
.../hadoop/hdds/utils/db/TestDBStoreBuilder.java | 94 +-
.../apache/hadoop/hdds/utils/db/TestRDBStore.java | 224 +-
.../hadoop/hdds/utils/db/TestRDBStoreIterator.java | 20 +-
.../hadoop/hdds/utils/db/TestRDBTableStore.java | 129 +-
.../hdds/utils/db/TestTypedRDBTableStore.java | 78 +-
.../hadoop/hdds/utils/db/cache/TestTableCache.java | 237 +-
.../hadoop/hdds/scm/SCMCommonPlacementPolicy.java | 1 +
.../hdds/scm/container/ContainerManagerImpl.java | 16 +-
.../container/replication/ContainerReplicaOp.java | 63 +
.../replication/ContainerReplicaPendingOps.java | 227 ++
.../container/replication/ReplicationManager.java | 5 +-
.../apache/hadoop/hdds/scm/ha/HASecurityUtils.java | 2 +-
.../hadoop/hdds/scm/ha/SCMHANodeDetails.java | 12 +-
.../hadoop/hdds/scm/ha/SequenceIdGenerator.java | 15 +-
.../hdds/scm/server/SCMBlockProtocolServer.java | 4 +-
.../hdds/scm/server/SCMClientProtocolServer.java | 10 +-
.../hdds/scm/server/StorageContainerManager.java | 11 +-
.../scm/server/StorageContainerManagerStarter.java | 3 +
.../hdds/scm/TestSCMCommonPlacementPolicy.java | 75 +
.../hadoop/hdds/scm/block/TestBlockManager.java | 6 +-
.../hadoop/hdds/scm/block/TestDeletedBlockLog.java | 48 +-
.../command/TestCommandStatusReportHandler.java | 10 +-
.../container/TestCloseContainerEventHandler.java | 33 +-
.../scm/container/TestContainerActionsHandler.java | 2 +-
.../scm/container/TestContainerManagerImpl.java | 103 +-
.../scm/container/TestContainerReportHandler.java | 26 +-
.../scm/container/TestContainerStateManager.java | 18 +-
.../TestIncrementalContainerReportHandler.java | 34 +-
.../hdds/scm/container/TestReplicationManager.java | 440 ++--
.../scm/container/TestUnknownContainerReport.java | 10 +-
.../container/balancer/TestFindTargetStrategy.java | 26 +-
.../algorithms/TestContainerPlacementFactory.java | 37 +-
.../TestContainerPlacementStatusDefault.java | 8 +-
.../TestSCMContainerPlacementCapacity.java | 28 +-
.../TestSCMContainerPlacementRandom.java | 36 +-
.../TestContainerReplicaPendingOps.java | 226 ++
.../replication/TestReplicationManagerMetrics.java | 26 +-
.../states/TestContainerReplicaCount.java | 12 +-
.../states/TestECContainerReplicaCount.java | 162 +-
.../hdds/scm/ha/TestReplicationAnnotation.java | 20 +-
.../apache/hadoop/hdds/scm/ha/TestSCMContext.java | 10 +-
.../hadoop/hdds/scm/ha/TestSCMHAConfiguration.java | 74 +-
.../hadoop/hdds/scm/ha/TestSCMRatisRequest.java | 30 +-
.../hadoop/hdds/scm/ha/TestSCMRatisResponse.java | 25 +-
.../hadoop/hdds/scm/ha/TestSCMServiceManager.java | 6 +-
.../hdds/scm/ha/TestSequenceIDGenerator.java | 76 +-
.../ha/TestStatefulServiceStateManagerImpl.java | 14 +-
.../hadoop/hdds/scm/ha/io/TestBigIntegerCodec.java | 6 +-
.../hdds/scm/ha/io/TestX509CertificateCodec.java | 13 +-
.../hdds/scm/metadata/TestPipelineIDCodec.java | 6 +-
.../scm/node/TestCommandQueueReportHandler.java | 13 +-
.../hdds/scm/node/TestContainerPlacement.java | 7 +-
.../hdds/scm/node/TestDatanodeAdminMonitor.java | 15 +-
.../hadoop/hdds/scm/node/TestDeadNodeHandler.java | 38 +-
.../hdds/scm/node/TestNodeDecommissionManager.java | 10 +-
.../hdds/scm/node/TestNodeReportHandler.java | 22 +-
.../hadoop/hdds/scm/node/TestNodeStateManager.java | 25 +-
.../hadoop/hdds/scm/node/TestStatisticsUpdate.java | 28 +-
.../hdds/scm/node/states/TestNodeStateMap.java | 12 +-
.../pipeline/TestBackgroundPipelineScrubber.java | 14 +-
.../hdds/scm/pipeline/TestECPipelineProvider.java | 28 +-
.../scm/pipeline/TestPipelineActionHandler.java | 2 +-
.../hdds/scm/pipeline/TestPipelineManagerImpl.java | 181 +-
.../scm/pipeline/TestPipelineStateManagerImpl.java | 78 +-
.../hdds/scm/pipeline/TestPipelineStateMap.java | 12 +-
.../scm/pipeline/TestRatisPipelineProvider.java | 32 +-
.../scm/pipeline/TestSimplePipelineProvider.java | 44 +-
.../pipeline/TestWritableECContainerProvider.java | 18 +-
.../TestPipelineChoosePolicyFactory.java | 14 +-
.../choose/algorithms/TestLeaderChoosePolicy.java | 26 +-
.../safemode/TestHealthyPipelineSafeModeRule.java | 12 +-
.../scm/server/TestSCMBlockProtocolServer.java | 22 +-
.../hdds/scm/server/TestSCMContainerMetrics.java | 2 +-
.../server/TestSCMDatanodeHeartbeatDispatcher.java | 24 +-
.../server/TestStorageContainerManagerStarter.java | 18 +-
.../ozone/container/common/TestEndPoint.java | 84 +-
.../placement/TestContainerPlacement.java | 10 +-
.../container/placement/TestDatanodeMetrics.java | 6 +-
.../hadoop/ozone/scm/node/TestSCMNodeMetrics.java | 31 +-
.../hdds/scm/cli/container/TestInfoSubCommand.java | 38 +-
.../scm/cli/container/TestReportSubCommand.java | 20 +-
.../datanode/TestContainerBalancerSubCommand.java | 14 +-
.../cli/datanode/TestDecommissionSubCommand.java | 16 +-
.../scm/cli/datanode/TestListInfoSubcommand.java | 14 +-
.../cli/datanode/TestMaintenanceSubCommand.java | 16 +-
.../cli/datanode/TestRecommissionSubCommand.java | 14 +-
.../scm/cli/datanode/TestUsageInfoSubcommand.java | 30 +-
.../cli/pipeline/TestListPipelinesSubCommand.java | 60 +-
.../apache/hadoop/ozone/client/rpc/RpcClient.java | 9 +
.../apache/hadoop/ozone/om/lock/OMLockMetrics.java | 2 +
.../hadoop/ozone/om/lock/TestOzoneManagerLock.java | 23 +
hadoop-ozone/csi/pom.xml | 1 +
.../dashboards/Ozone - Overall Metrics.json | 2591 ++++++++++++++++++++
.../dist/src/main/compose/compatibility/test.sh | 2 +
hadoop-ozone/dist/src/main/compose/ozone/README.md | 3 +-
.../dist/src/main/compose/ozone/prometheus.yml | 11 +
hadoop-ozone/dist/src/main/compose/upgrade/test.sh | 2 +
hadoop-ozone/dist/src/main/compose/xcompat/test.sh | 2 +
hadoop-ozone/dist/src/main/license/bin/LICENSE.txt | 4 +-
hadoop-ozone/dist/src/main/license/jar-report.txt | 4 +-
.../hdds/scm/storage/TestContainerCommandsEC.java | 255 ++
.../hadoop/ozone/om/TestOzoneManagerPrepare.java | 4 +
.../src/main/proto/OmClientProtocol.proto | 2 +-
.../apache/hadoop/ozone/om/OMMetadataManager.java | 8 +-
.../org/apache/hadoop/ozone/om/KeyManager.java | 10 +-
.../org/apache/hadoop/ozone/om/KeyManagerImpl.java | 8 +-
.../hadoop/ozone/om/OmMetadataManagerImpl.java | 67 +-
.../hadoop/ozone/om/OpenKeyCleanupService.java | 3 +-
.../org/apache/hadoop/ozone/om/OzoneManager.java | 78 +-
.../hadoop/ozone/om/OzoneManagerStarter.java | 3 +
.../apache/hadoop/ozone/om/ha/OMHANodeDetails.java | 12 +-
.../om/request/key/OMOpenKeysDeleteRequest.java | 5 +-
.../S3MultipartUploadCompleteRequest.java | 15 +-
.../om/response/key/OMOpenKeysDeleteResponse.java | 14 +-
.../hadoop/ozone/om/TestOmMetadataManager.java | 107 +-
.../request/key/TestOMOpenKeysDeleteRequest.java | 267 +-
.../TestS3MultipartUploadCompleteRequest.java | 8 +
.../response/key/TestOMOpenKeysDeleteResponse.java | 50 +-
.../org/apache/hadoop/ozone/recon/ReconServer.java | 3 +
.../ozone/recon/scm/ReconContainerManager.java | 7 +-
.../scm/ReconStorageContainerManagerFacade.java | 7 +-
.../scm/AbstractReconContainerManagerTest.java | 8 +-
.../java/org/apache/hadoop/ozone/s3/Gateway.java | 5 +-
pom.xml | 20 +-
178 files changed, 6701 insertions(+), 2357 deletions(-)
create mode 100644
hadoop-hdds/common/src/main/java/org/apache/hadoop/ozone/util/OzoneNetUtils.java
create mode 100644
hadoop-hdds/common/src/test/java/org/apache/hadoop/hdds/scm/TestSCMHAUtils.java
copy
hadoop-hdds/common/src/{main/java/org/apache/hadoop/ozone/ha/package-info.java
=> test/java/org/apache/hadoop/ozone/ha/TestOzoneNetUtils.java} (57%)
create mode 100644
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/ReconstructECContainersCommandHandler.java
create mode 100644
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCommandInfo.java
create mode 100644
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinatorTask.java
create mode 100644
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionSupervisor.java
copy hadoop-hdds/{server-scm/src/test/java/org/apache/hadoop/hdds/scm =>
container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction}/package-info.java
(93%)
create mode 100644
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/ec/reconstruction/TestECReconstructionSupervisor.java
create mode 100644
hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ContainerReplicaOp.java
create mode 100644
hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ContainerReplicaPendingOps.java
create mode 100644
hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/TestSCMCommonPlacementPolicy.java
create mode 100644
hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/container/replication/TestContainerReplicaPendingOps.java
create mode 100644
hadoop-ozone/dist/src/main/compose/common/grafana/dashboards/Ozone - Overall
Metrics.json
create mode 100644
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/storage/TestContainerCommandsEC.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
