From d25c4053b8f56d21b5280c9ffd8efcc56e08fdd6 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Fri, 14 Nov 2025 12:05:38 +0800 Subject: [PATCH] fix: [cp26]store database event if the key is invalid (#45348) (#45530) See also: #45136, #45124 pr: #45348 Signed-off-by: yangxuan --- internal/rootcoord/meta_table.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/rootcoord/meta_table.go b/internal/rootcoord/meta_table.go index f4f48cb2e1..aa47872b86 100644 --- a/internal/rootcoord/meta_table.go +++ b/internal/rootcoord/meta_table.go @@ -377,12 +377,12 @@ func (mt *MetaTable) CreateDatabase(ctx context.Context, db *model.Database, ts func (mt *MetaTable) createDatabasePrivate(ctx context.Context, db *model.Database, ts typeutil.Timestamp) error { dbName := db.Name - if err := mt.catalog.CreateDatabase(ctx, db, ts); err != nil { + if err := hookutil.CreateEZByDBProperties(db.Properties); err != nil { return err } - // Call back cipher plugin when creating database succeeded - if err := hookutil.CreateEZByDBProperties(db.Properties); err != nil { + if err := mt.catalog.CreateDatabase(ctx, db, ts); err != nil { + hookutil.RemoveEZByDBProperties(db.Properties) // ignore the error since create database failed return err }