fix e2e test error

Signed-off-by: Xianhui.Lin <[email protected]> fix Signed-off-by: Xianhui.Lin <[email protected]> fix Signed-off-by: Xianhui.Lin <[email protected]>
milvus-io · Jan 20, 2025 · 4c218cb · 4c218cb
1 parent 65034d7
commit 4c218cb
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 4 deletions.
diff --git a/go.sum b/go.sum
@@ -630,8 +630,6 @@ github.com/milvus-io/cgosymbolizer v0.0.0-20240722103217-b7dee0e50119 h1:9VXijWu
 github.com/milvus-io/cgosymbolizer v0.0.0-20240722103217-b7dee0e50119/go.mod h1:DvXTE/K/RtHehxU8/GtDs4vFtfw64jJ3PaCnFri8CRg=
 github.com/milvus-io/gorocksdb v0.0.0-20220624081344-8c5f4212846b h1:TfeY0NxYxZzUfIfYe5qYDBzt4ZYRqzUjTR6CvUzjat8=
 github.com/milvus-io/gorocksdb v0.0.0-20220624081344-8c5f4212846b/go.mod h1:iwW+9cWfIzzDseEBCCeDSN5SD16Tidvy8cwQ7ZY8Qj4=
-github.com/milvus-io/milvus-proto/go-api/v2 v2.5.0-beta.0.20250107132849-4099923438e6 h1:IUHMoxffuI2xbtMJJE/XK7kKzavZnN5sMiheIKTDVt8=
-github.com/milvus-io/milvus-proto/go-api/v2 v2.5.0-beta.0.20250107132849-4099923438e6/go.mod h1:/6UT4zZl6awVeXLeE7UGDWZvXj3IWkRsh3mqsn0DiAs=
 github.com/milvus-io/milvus-proto/go-api/v2 v2.5.5-0.20250117031653-5377f6d19da2 h1:PBb2s4yFMiZApXoV41AyUbMcAuIhTjI1sz8rMyxTcoM=
 github.com/milvus-io/milvus-proto/go-api/v2 v2.5.5-0.20250117031653-5377f6d19da2/go.mod h1:/6UT4zZl6awVeXLeE7UGDWZvXj3IWkRsh3mqsn0DiAs=
 github.com/milvus-io/pulsar-client-go v0.12.1 h1:O2JZp1tsYiO7C0MQ4hrUY/aJXnn2Gry6hpm7UodghmE=

diff --git a/internal/metastore/model/collection.go b/internal/metastore/model/collection.go
@@ -75,6 +75,7 @@ func (c *Collection) ShallowClone() *Collection {
 		State:                c.State,
 		EnableDynamicField:   c.EnableDynamicField,
 		Functions:            c.Functions,
+		UpdateTimestamp:      c.UpdateTimestamp,
 	}
 }
 

diff --git a/internal/proxy/task_insert.go b/internal/proxy/task_insert.go
@@ -148,7 +148,7 @@ func (it *insertTask) PreExecute(ctx context.Context) error {
 	if it.schemaTimestamp != 0 {
 		if it.schemaTimestamp != colInfo.updateTimestamp {
 			err := merr.WrapErrCollectionSchemaMisMatch(collectionName)
-			log.Ctx(ctx).Warn("collection schema mismatch", zap.String("collectionName", collectionName), zap.Error(err))
+			log.Ctx(ctx).Info("collection schema mismatch", zap.String("collectionName", collectionName), zap.Error(err))
 			return err
 		}
 	}

diff --git a/internal/proxy/task_upsert.go b/internal/proxy/task_upsert.go
@@ -315,7 +315,7 @@ func (it *upsertTask) PreExecute(ctx context.Context) error {
 	if it.schemaTimestamp != 0 {
 		if it.schemaTimestamp != colInfo.updateTimestamp {
 			err := merr.WrapErrCollectionSchemaMisMatch(collectionName)
-			log.Warn("collection schema mismatch", zap.String("collectionName", collectionName), zap.Error(err))
+			log.Info("collection schema mismatch", zap.String("collectionName", collectionName), zap.Error(err))
 			return err
 		}
 	}