diff --git a/Makefile b/Makefile
index dd6afda905..82d08957fe 100644
--- a/Makefile
+++ b/Makefile
@@ -14,7 +14,7 @@ endif
SHELL = /usr/bin/env bash -o pipefail
.SHELLFLAGS = -ec
-VERSION ?= 26.6.0-bandwidth.6
+VERSION ?= 26.6.0-bandwidth.7
# mariadb-operator
IMG_NAME ?= ghcr.io/mariadb-operator/mariadb-operator
diff --git a/docs/docker.md b/docs/docker.md
index 81eac0c5c5..0023f09295 100644
--- a/docs/docker.md
+++ b/docs/docker.md
@@ -36,7 +36,7 @@
| MariaDB Operator |
- ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.6 |
+ ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.7 |
amd64 arm64 |
diff --git a/examples/manifests/mariadb_replication.yaml b/examples/manifests/mariadb_replication.yaml
index 7379a817ae..9eb55d8eb1 100644
--- a/examples/manifests/mariadb_replication.yaml
+++ b/examples/manifests/mariadb_replication.yaml
@@ -66,10 +66,10 @@ spec:
# syncBinlog: 1
# Init container that cooperates with mariadb-operator.
# initContainer:
- # image: ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.6
+ # image: ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.7
# Agent sidecar that cooperates with mariadb-operator.
# agent:
- # image: ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.6
+ # image: ghcr.io/mariadb-operator/mariadb-operator:26.6.0-bandwidth.7
service:
type: LoadBalancer
diff --git a/internal/controller/mariadb_controller_external_repl_init.go b/internal/controller/mariadb_controller_external_repl_init.go
index 70f55f605c..31d43de08e 100644
--- a/internal/controller/mariadb_controller_external_repl_init.go
+++ b/internal/controller/mariadb_controller_external_repl_init.go
@@ -380,12 +380,16 @@ func getBinlogExpireLogsDuration(emdb *mariadbv1alpha1.ExternalMariaDB, ctx cont
isRDS := false
// Check if it is an RDS instance
- if user_exist, err := external_client.UserExists(ctx, "rdsadmin", "localhost"); err != nil && user_exist {
- if table_exists, err := external_client.TableExists(ctx, "mysql", "rds_configuration"); err != nil && table_exists {
+ if user_exist, err := external_client.UserExists(ctx, "rdsadmin", "localhost"); err == nil && user_exist {
+ if table_exists, err := external_client.TableExists(ctx, "mysql", "rds_configuration"); err == nil && table_exists {
logger.Info("RDS config found")
isRDS = true
}
- logger.Info("AWS user detected")
+ logger.Info("RDS user detected")
+ } else {
+ if err != nil {
+ logger.Info("Error querying external server for RDS discovery", "error", err)
+ }
}
if isRDS {