diff --git a/pkg/vm/engine/tae/catalog/table.go b/pkg/vm/engine/tae/catalog/table.go index ebc39d8db143..0d7e0bd169e3 100644 --- a/pkg/vm/engine/tae/catalog/table.go +++ b/pkg/vm/engine/tae/catalog/table.go @@ -532,8 +532,11 @@ func (entry *TableEntry) ApplyCommit() (err error) { if entry.isColumnChangedInSchema() { entry.FreezeAppend() } + entry.RLock() + schema := entry.GetLatestNodeLocked().BaseNode.Schema + entry.RUnlock() // update the shortcut to the lastest schema - entry.TableNode.schema.Store(entry.GetLatestNodeLocked().BaseNode.Schema) + entry.TableNode.schema.Store(schema) return }