Skip to content
Merged
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
4 changes: 0 additions & 4 deletions api/v1alpha1/status.go
Original file line number Diff line number Diff line change
Expand Up @@ -191,8 +191,6 @@ const (
RuntimeFusesScaledIn RuntimeConditionType = "FusesScaledIn"
// RuntimeFusesScaledOut means the fuses of runtime just scaled out
RuntimeFusesScaledOut RuntimeConditionType = "FusesScaledOut"
// RuntimeWorkerDecommissioning means the runtime is draining workers ahead of a scale-down
RuntimeWorkerDecommissioning RuntimeConditionType = "WorkerDecommissioning"
)

const (
Expand All @@ -216,8 +214,6 @@ const (
RuntimeFusesScaledInReason = "Fuses scaled in"
// RuntimeFusesScaledInReason means the fuses of runtime just scaled out
RuntimeFusesScaledOutReason = "Fuses scaled out"
// RuntimeWorkerDecommissioningReason means workers are being decommissioned ahead of a scale-down
RuntimeWorkerDecommissioningReason = "Workers are being decommissioned"
)

// Condition describes the state of the cache at a certain point.
Expand Down
12 changes: 0 additions & 12 deletions pkg/ddc/alluxio/const.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ limitations under the License.

package alluxio

import "time"

const (
// NON_NATIVE_MOUNT_DATA_NAME also used in master 'statefulset.yaml' and config 'alluxio-mount.conf.yaml'
NON_NATIVE_MOUNT_DATA_NAME = "mount.info"
Expand Down Expand Up @@ -59,16 +57,6 @@ const (
defaultGracefulShutdownLimits int32 = 3
defaultCleanCacheGracePeriodSeconds int32 = 60

// defaultWorkerRPCPort is the Alluxio worker Thrift RPC port used when the
// runtime spec does not override alluxio.worker.rpc.port.
defaultWorkerRPCPort = 29999

MountConfigStorage = "ALLUXIO_MOUNT_CONFIG_STORAGE"
ConfigmapStorageName = "configmap"

// defaultWorkerDecommissionDeadline bounds how long the engine keeps
// retrying a stuck worker drain (e.g. an unhealthy master, unreplicable
// blocks) before forcing the scale-down to proceed anyway, rather than
// stalling on every reconcile indefinitely.
defaultWorkerDecommissionDeadline = 10 * time.Minute
)
86 changes: 0 additions & 86 deletions pkg/ddc/alluxio/operations/decommission.go

This file was deleted.

227 changes: 0 additions & 227 deletions pkg/ddc/alluxio/operations/decommission_test.go

This file was deleted.

Loading
Loading