diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/glogue/Glogue.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/glogue/Glogue.java index b89e7c18293a..3c587cb2ddbc 100644 --- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/glogue/Glogue.java +++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/glogue/Glogue.java @@ -94,7 +94,10 @@ private Glogue create(GlogueSchema schema, int maxPatternSize) { } // compute pattern cardinality this.glogueCardinalityEstimation = new GlogueBasicCardinalityEstimationImpl(this, schema); - logger.debug("GlogueGraph\n" + this.toString()); + logger.info( + "GlogueGraph is created, with {} vertices and {} edges", + this.glogueGraph.vertexSet().size(), + this.glogueGraph.edgeSet().size()); return this; } diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/schema/GlogueSchema.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/schema/GlogueSchema.java index 1d7e09c495f0..86f7af48144c 100644 --- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/schema/GlogueSchema.java +++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/rel/metadata/schema/GlogueSchema.java @@ -80,10 +80,15 @@ public GlogueSchema(GraphSchema graphSchema) { edgeTypeCardinality.put(edgeType, 1.0); } } - logger.debug("GlogueSchema created with default cardinality 1.0: {}", this); + logger.info("GlogueSchema created with default cardinality 1.0: {}", this); } public GlogueSchema(GraphSchema graphSchema, GraphStatistics statistics) { + logger.info( + "Creating GlogueSchema with statistics, vertex count: {}, edge count: {}", + statistics.getVertexCount(), + statistics.getEdgeCount()); + schemaGraph = new DirectedPseudograph(EdgeTypeId.class); vertexTypeCardinality = new HashMap(); edgeTypeCardinality = new HashMap(); @@ -120,7 +125,7 @@ public GlogueSchema(GraphSchema graphSchema, GraphStatistics statistics) { } } } - logger.debug("GlogueSchema created with statistics: {}", this); + logger.info("GlogueSchema created with statistics: {}", this); } public static GlogueSchema fromMeta(IrMetaStats irMeta) { diff --git a/interactive_engine/executor/store/groot/src/db/graph/store.rs b/interactive_engine/executor/store/groot/src/db/graph/store.rs index fe9d0f8776af..ae338c762f86 100644 --- a/interactive_engine/executor/store/groot/src/db/graph/store.rs +++ b/interactive_engine/executor/store/groot/src/db/graph/store.rs @@ -1092,6 +1092,10 @@ impl GraphStore { let edge_labels_statistics = self.get_edge_statistics(si)?; let vertex_count = vertex_labels_statistics.values().sum(); let edge_count = edge_labels_statistics.values().sum(); + info!( + "get_statistics in groot store partition, vertex_count {}, edge_count {}", + vertex_count, edge_count + ); Ok(GraphPartitionStatistics::new( si, vertex_count, diff --git a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/coordinator/SchemaManager.java b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/coordinator/SchemaManager.java index b42dc7ce3126..10df3475c00f 100644 --- a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/coordinator/SchemaManager.java +++ b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/coordinator/SchemaManager.java @@ -130,8 +130,9 @@ private void syncStatistics() { Map statisticsMap = graphDefFetcher.fetchStatistics(); Statistics statistics = aggregateStatistics(statisticsMap); this.graphStatistics.set(statistics); + logger.info("Fetched statistics from groot store to groot coordinator successfully"); } catch (Exception e) { - logger.error("Fetch statistics failed", e); + logger.error("Fetched statistics from groot store to groot coordinator failed", e); } sendStatisticsToFrontend(); } @@ -142,7 +143,7 @@ private void sendStatisticsToFrontend() { for (int i = 0; i < frontendCount; ++i) { try { frontendSnapshotClients.getClient(i).syncStatistics(statistics); - logger.debug("Sent statistics to frontend#{}", i); + logger.info("Sent statistics from groot coordinator to frontend#{}", i); } catch (Exception e) { logger.error("Failed to sync statistics to frontend", e); } diff --git a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/SnapshotCache.java b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/SnapshotCache.java index 4f4a0254ea83..2909a631645b 100644 --- a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/SnapshotCache.java +++ b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/SnapshotCache.java @@ -136,6 +136,10 @@ public SnapshotWithSchema getSnapshotWithSchema() { } public void setGraphStatisticsRef(GraphStatistics statistics) { + logger.info( + "update graph statistics in frontend cache, vertex num: {}, edge num: {}", + statistics.getVertexCount(), + statistics.getEdgeCount()); this.graphStatisticsRef.set(statistics); }