fix invalid write & memory leak in stream test

cc8ae36f · Bomin Zhang · a5a054d8 · cc8ae36f · cc8ae36f
展开全部隐藏空白更改
内联并排

Showing with 292 addition and 290 deletion

src/client/src/tscSQLParser.c src/client/src/tscSQLParser.c +290 -290

src/cq/src/cqMain.c src/cq/src/cqMain.c +2 -0

未找到文件。
--- a/src/client/src/tscSQLParser.c
+++ b/src/client/src/tscSQLParser.c
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -213,6 +213,8 @@ void cqDrop(void *handle) {
  pObj->pStream = NULL;

  cTrace("vgId:%d, id:%d CQ:%s is dropped", pContext->vgId, pObj->tid, pObj->sqlStr); 
+  tdFreeSchema(pObj->pSchema);
+  free(pObj->sqlStr);
  free(pObj);

  pthread_mutex_unlock(&pContext->mutex);