From c3b708addb2af0fc4d8d5938434f824bed0afc6a Mon Sep 17 00:00:00 2001
From: hardy <2545433047@qq.com>
Date: Tue, 10 Feb 2026 15:48:46 +0800
Subject: [PATCH] feat:When the engine encounters an extremely large event, a
 warning is required.

---
 connectors/mongodb-connector/pom.xml                            | 2 +-
 .../src/main/java/io/tapdata/mongodb/MongodbConnector.java      | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/connectors/mongodb-connector/pom.xml b/connectors/mongodb-connector/pom.xml
index adf53fca6..e12cdffdc 100644
--- a/connectors/mongodb-connector/pom.xml
+++ b/connectors/mongodb-connector/pom.xml
@@ -13,7 +13,7 @@
 
     <properties>
         <java.version>8</java.version>
-        <tapdata.pdk.api.version>2.0.5-SNAPSHOT</tapdata.pdk.api.version>
+        <tapdata.pdk.api.version>2.0.6-SNAPSHOT</tapdata.pdk.api.version>
     </properties>
     <dependencies>
         <dependency>
diff --git a/connectors/mongodb-connector/src/main/java/io/tapdata/mongodb/MongodbConnector.java b/connectors/mongodb-connector/src/main/java/io/tapdata/mongodb/MongodbConnector.java
index 633677291..91bc8104a 100644
--- a/connectors/mongodb-connector/src/main/java/io/tapdata/mongodb/MongodbConnector.java
+++ b/connectors/mongodb-connector/src/main/java/io/tapdata/mongodb/MongodbConnector.java
@@ -1823,6 +1823,8 @@ protected TableInfo getTableInfo(TapConnectionContext tapConnectorContext, Strin
 			tableInfo.setNumOfRows(numOfRows.longValue());
 			BigDecimal storageSize = new BigDecimal(String.valueOf(collStats.get("size")));
 			tableInfo.setStorageSize(storageSize.longValue());
+			BigDecimal avgObjSize = new BigDecimal(String.valueOf(collStats.get("avgObjSize")));
+			tableInfo.setAvgObjSize(avgObjSize.longValue());
 		}catch (Exception e){
 			exceptionCollector.collectTerminateByServer(e);
 			exceptionCollector.collectReadPrivileges(e);