diff --git a/src/tsdb/src/tsdbMain.c b/src/tsdb/src/tsdbMain.c
index 3241d617b694129cd55b140fe5f6fa82bccd1671..8e31ae502248a287a5481fb2ad7b7bfd795ea0df 100644
--- a/src/tsdb/src/tsdbMain.c
+++ b/src/tsdb/src/tsdbMain.c
@@ -616,17 +616,34 @@ static void tsdbStopStream(STsdbRepo *pRepo) {
   }
 }
 
+static STSchema* getTableLatestSchema(STable *pTable) {
+  if (pTable->numOfSchemas > 0) {
+    return pTable->schema[pTable->numOfSchemas - 1];
+  }
+
+  if (pTable->type == TSDB_CHILD_TABLE) {
+    if (pTable->pSuper && pTable->pSuper->numOfSchemas) {
+      tsdbDebug("getTableLatestSchema of table %s from super table %s", pTable->name->data, pTable->pSuper->name->data);
+      return pTable->pSuper->schema[pTable->pSuper->numOfSchemas - 1];
+    }
+  }
+  return NULL;
+}
+
 static int restoreLastColumns(STsdbRepo *pRepo, STable *pTable, SReadH* pReadh) {
-  if (pTable->numOfSchemas == 0) {
+  STSchema *pSchema = getTableLatestSchema(pTable);
+  if (pSchema == NULL) {
+    tsdbError("getTableLatestSchema of table %s fail", pTable->name->data);
     return 0;
   }
+
   SBlock* pBlock;
   int numColumns;
   int32_t blockIdx;
   SDataStatis* pBlockStatis = NULL;
   SDataRow row = NULL;
   // restore last column data with last schema
-  STSchema *pSchema = pTable->schema[pTable->numOfSchemas - 1];
+  
   int err = 0;
 
   numColumns = schemaNCols(pSchema);