chore: adapt lorry for oceanbase replication change into one component (

#7838) (cherry picked from commit e35b229)
apecloud · Jul 19, 2024 · 99aea73 · 99aea73
1 parent 9ce76de
commit 99aea73
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/pkg/lorry/dcs/k8s.go b/pkg/lorry/dcs/k8s.go
@@ -42,7 +42,6 @@ import (
 
 	appsv1alpha1 "github.com/apecloud/kubeblocks/apis/apps/v1alpha1"
 	"github.com/apecloud/kubeblocks/pkg/constant"
-	"github.com/apecloud/kubeblocks/pkg/lorry/engines/models"
 	k8s "github.com/apecloud/kubeblocks/pkg/lorry/util/kubernetes"
 	viper "github.com/apecloud/kubeblocks/pkg/viperx"
 )
@@ -101,14 +100,14 @@ func NewKubernetesStore() (*KubernetesStore, error) {
 		return nil, errors.New("KB_NAMESPACE must be set")
 	}
 
-	characterType := viper.GetString(constant.KBEnvCharacterType)
-	if viper.IsSet(constant.KBEnvBuiltinHandler) {
-		characterType = viper.GetString(constant.KBEnvBuiltinHandler)
-	}
 	isLeaderClusterWide := false
-	if characterType == string(models.Oceanbase) {
-		isLeaderClusterWide = true
-	}
+	// characterType := viper.GetString(constant.KBEnvCharacterType)
+	// if viper.IsSet(constant.KBEnvBuiltinHandler) {
+	// 	characterType = viper.GetString(constant.KBEnvBuiltinHandler)
+	// }
+	// if characterType == string(models.Oceanbase) {
+	// 	isLeaderClusterWide = true
+	// }
 
 	store := &KubernetesStore{
 		ctx:                 ctx,