fix(stream): fix concurrent bug in save task meta.

a803eaee · Haojun Liao · c20ac4fe · a803eaee
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/stream/src/streamRecover.c source/libs/stream/src/streamRecover.c +3 -1

未找到文件。
--- a/source/libs/stream/src/streamRecover.c
+++ b/source/libs/stream/src/streamRecover.c
@@ -553,8 +553,10 @@ int32_t streamTaskScanHistoryDataComplete(SStreamTask* pTask) {
  streamSetStatusNormal(pTask);
  atomic_store_8(&pTask->status.schedStatus, TASK_SCHED_STATUS__INACTIVE);
-  // todo check rsp, commit data
+  taosWLockLatch(&pMeta->lock);
  streamMetaSaveTask(pMeta, pTask);
+  taosWUnLockLatch(&pMeta->lock);
  return 0;
 }