Merge branch 'fix/task_db' into enh/stream_buffer_param

51866dad · Liu Jicong · 089bc740 · 0c6f6d3a · 51866dad
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

source/libs/stream/src/streamMeta.c source/libs/stream/src/streamMeta.c +1 -0

未找到文件。
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -207,6 +207,7 @@ void streamMetaRemoveTask(SStreamMeta* pMeta, int32_t taskId) {
  if (ppTask) {
    SStreamTask* pTask = *ppTask;
    taosHashRemove(pMeta->pTasks, &taskId, sizeof(int32_t));
+    tdbTbDelete(pMeta->pTaskDb, &taskId, sizeof(int32_t), pMeta->txn);
    /*if (pTask->timer) {
     * taosTmrStop(pTask->timer);*/
    /*pTask->timer = NULL;*/