diff --git a/src/tsdb/src/tsdbMemTable.c b/src/tsdb/src/tsdbMemTable.c
index e1f6625ffad519e1283d2491613ed777e85bfaeb..1321d4365396c423e2cb4ba5c422a92138bfae05 100644
--- a/src/tsdb/src/tsdbMemTable.c
+++ b/src/tsdb/src/tsdbMemTable.c
@@ -993,6 +993,10 @@ static void updateTableLatestColumn(STsdbRepo *pRepo, STable *pTable, SDataRow r
     }
 
     STColumn *pTCol = schemaColAt(pSchema, j);
+    if (pTCol == NULL) {
+      // since schema maybe changed, check if STColumn NULL then ignore
+      continue;
+    }
     SDataCol *pDataCol = &(pLatestCols[j]);
     void* value = tdGetRowDataOfCol(row, (int8_t)pTCol->type, TD_DATA_ROW_HEAD_SIZE + pSchema->columns[j].offset);
     if (isNullN(value, pTCol->type)) {