Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -281,6 +281,7 @@ public static boolean isReadOnly(OMRequest omRequest) {
case GetObjectTagging:
case GetQuotaRepairStatus:
case StartQuotaRepair:
case FinalizeUpgrade:
return true;
case CreateVolume:
case SetVolumeProperty:
Expand Down Expand Up @@ -314,7 +315,6 @@ public static boolean isReadOnly(OMRequest omRequest) {
// As protobuf currently doesn't support deprecating enum fields
// TODO: Remove once migrated to proto3 and mark fields in proto
// as deprecated
case FinalizeUpgrade:
case Prepare:
case CancelPrepare:
case DeleteOpenKeys:
Expand Down Expand Up @@ -396,6 +396,7 @@ public static boolean shouldSendToFollower(OMRequest omRequest) {
case GetKeyInfo:
case GetSnapshotInfo:
case GetObjectTagging:
case FinalizeUpgrade:
return true;
case CreateVolume:
case SetVolumeProperty:
Expand Down Expand Up @@ -429,7 +430,6 @@ public static boolean shouldSendToFollower(OMRequest omRequest) {
// As protobuf currently doesn't support deprecating enum fields
// TODO: Remove once migrated to proto3 and mark fields in proto
// as deprecated
case FinalizeUpgrade:
case Prepare:
case CancelPrepare:
case DeleteOpenKeys:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ Test Setup Run Keyword if '${SECURITY_ENABLED}' == 'true' Kinit t
*** Test Cases ***
Check OM Finalized
[Tags] om finalized
Skip OM cannot finalize now/yet
${result} = Execute env
Log ${result}
Pass Execution If '%{OZONE_UPGRADE_FROM}' == '1.1.0' OM finalization not supported in version %{OZONE_UPGRADE_FROM}
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@
import org.apache.hadoop.ozone.om.protocol.OzoneManagerProtocol;
import org.apache.hadoop.ozone.upgrade.UpgradeFinalization;
import org.apache.ozone.test.LambdaTestUtils;
import org.apache.ozone.test.tag.Unhealthy;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.MethodOrderer;
Expand Down Expand Up @@ -70,6 +71,7 @@
*/
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@Unhealthy("OM cannot finalize now/yet")
class TestOMBucketLayoutUpgrade {

private static final int PRE_UPGRADE = 100;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
import org.apache.hadoop.ozone.om.protocol.OzoneManagerProtocol;
import org.apache.hadoop.ozone.om.ratis.OzoneManagerStateMachine;
import org.apache.hadoop.ozone.upgrade.UpgradeFinalization.StatusAndMessages;
import org.apache.ozone.test.tag.Unhealthy;
import org.apache.ratis.util.LifeCycle;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeEach;
Expand All @@ -50,6 +51,7 @@
* Tests for OM upgrade finalization.
* TODO: can be merged into class with other OM tests with per-method cluster
*/
@Unhealthy("OM cannot finalize now until it can poll the SCM for the trigger")
class TestOMUpgradeFinalization {
static {
AuditLogTestUtils.enableAuditLog();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,7 @@
import org.apache.hadoop.ozone.upgrade.UpgradeFinalization;
import org.apache.ozone.test.GenericTestUtils;
import org.apache.ozone.test.LambdaTestUtils.VoidCallable;
import org.apache.ozone.test.tag.Unhealthy;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
Expand All @@ -60,6 +61,7 @@
* and that users not belonging to a tenant are directed to the default S3
* volume.
*/
@Unhealthy("OM cannot finalize now/yet")
public class TestMultiTenantVolume {
private static MiniOzoneCluster cluster;
private static String s3VolumeName;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -161,6 +161,7 @@
import org.apache.ozone.rocksdiff.RocksDBCheckpointDiffer;
import org.apache.ozone.test.GenericTestUtils;
import org.apache.ozone.test.tag.Slow;
import org.apache.ozone.test.tag.Unhealthy;
import org.apache.ratis.util.function.UncheckedAutoCloseableSupplier;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Test;
Expand All @@ -171,6 +172,7 @@
* Abstract class to test OmSnapshot.
*/
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@Unhealthy("no trigger for finalization now/yet, all implementations try finalizing")
public abstract class TestOmSnapshot {
static {
Logger.getLogger(ManagedRocksObjectUtils.class).setLevel(Level.DEBUG);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,6 @@ private static void init() {
CMD_AUDIT_ACTION_MAP.put(Type.SetBucketProperty, OMAction.UPDATE_BUCKET);
CMD_AUDIT_ACTION_MAP.put(Type.Prepare, OMAction.UPGRADE_PREPARE);
CMD_AUDIT_ACTION_MAP.put(Type.CancelPrepare, OMAction.UPGRADE_CANCEL);
CMD_AUDIT_ACTION_MAP.put(Type.FinalizeUpgrade, OMAction.UPGRADE_FINALIZE);
CMD_AUDIT_ACTION_MAP.put(Type.GetObjectTagging, OMAction.GET_OBJECT_TAGGING);
CMD_AUDIT_ACTION_MAP.put(Type.PutObjectTagging, OMAction.PUT_OBJECT_TAGGING);
CMD_AUDIT_ACTION_MAP.put(Type.DeleteObjectTagging, OMAction.DELETE_OBJECT_TAGGING);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,6 @@
import org.apache.hadoop.ozone.om.request.snapshot.OMSnapshotRenameRequest;
import org.apache.hadoop.ozone.om.request.snapshot.OMSnapshotSetPropertyRequest;
import org.apache.hadoop.ozone.om.request.upgrade.OMCancelPrepareRequest;
import org.apache.hadoop.ozone.om.request.upgrade.OMFinalizeUpgradeRequest;
import org.apache.hadoop.ozone.om.request.upgrade.OMPrepareRequest;
import org.apache.hadoop.ozone.om.request.util.OMEchoRPCWriteRequest;
import org.apache.hadoop.ozone.om.request.volume.OMQuotaRepairRequest;
Expand Down Expand Up @@ -183,8 +182,6 @@ public static OMClientRequest createClientRequest(OMRequest omRequest,
return new OMRenewDelegationTokenRequest(omRequest);
case GetS3Secret:
return new S3GetSecretRequest(omRequest);
case FinalizeUpgrade:
return new OMFinalizeUpgradeRequest(omRequest);
case Prepare:
return new OMPrepareRequest(omRequest);
case CancelPrepare:
Expand Down
Loading