From 0de3c02c1820425af23b7c806f83c5a7d78567a2 Mon Sep 17 00:00:00 2001 From: Xiaoli Zhou Date: Thu, 22 Aug 2024 14:16:21 +0800 Subject: [PATCH] fix(interactive): Fix Bugs in Dynamic Schema Fetching (#4176) --- .../common/ir/meta/fetcher/DynamicIrMetaFetcher.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/fetcher/DynamicIrMetaFetcher.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/fetcher/DynamicIrMetaFetcher.java index ed7b5260ed07..599fb4fcbe0c 100644 --- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/fetcher/DynamicIrMetaFetcher.java +++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/fetcher/DynamicIrMetaFetcher.java @@ -74,10 +74,13 @@ private synchronized void syncMeta() { "schema from remote: {}", (meta == null) ? null : meta.getSchema().schemaJson()); GraphStatistics curStats; - // if the graph id is changed, we need to update the statistics + // if the graph id or schema version is changed, we need to update the statistics if (this.currentState == null || !this.currentState.getGraphId().equals(meta.getGraphId()) - || this.currentState.getSnapshotId().getId() != meta.getSnapshotId().getId()) { + || !this.currentState + .getSchema() + .getVersion() + .equals(meta.getSchema().getVersion())) { this.statsState = StatsState.INITIALIZED; curStats = null; } else {