xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix stream case error

This commit is contained in:
yihaoDeng 2023-10-26 11:36:29 +08:00
parent db0f6258fe
commit 87db93e72e
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/streamMeta.c
View File

@ -229,7 +229,6 @@ int32_t streamMetaMayCvtDbFormat(SStreamMeta* pMeta) {
int32_t streamTaskSetDb(SStreamMeta* pMeta, void* arg, char *key) { int32_t streamTaskSetDb(SStreamMeta* pMeta, void* arg, char *key) {
SStreamTask* pTask = arg; SStreamTask* pTask = arg;
//char* key = (char*)pTask->id.idStr;
int64_t chkpId = pTask->checkpointingId; int64_t chkpId = pTask->checkpointingId;
taosThreadMutexLock(&pMeta->backendMutex); taosThreadMutexLock(&pMeta->backendMutex);