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

fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-08-30 09:08:15 +08:00
parent da1bdd689f
commit 52bb649615
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/streamStartHistory.c
View File

@ -116,8 +116,8 @@ int32_t streamTaskStartScanHistory(SStreamTask* pTask) {
if (((pTask->status.downstreamReady != 1) || (state.state != TASK_STATUS__SCAN_HISTORY) || if (((pTask->status.downstreamReady != 1) || (state.state != TASK_STATUS__SCAN_HISTORY) ||
(pTask->info.fillHistory != 1))) { (pTask->info.fillHistory != 1))) {
stFatal("s-task:%s invalid status to start fill-history task, downReady:%d, status:%s, is-fill-history task:%d", stFatal("s-task:%s invalid status:%s to start fill-history task, downReady:%d, is-fill-history task:%d",
pTask->id.idStr, state.name, pTask->info.fillHistory); pTask->id.idStr, state.name, pTask->status.downstreamReady, pTask->info.fillHistory);
return TSDB_CODE_STREAM_INTERNAL_ERROR; return TSDB_CODE_STREAM_INTERNAL_ERROR;
} }