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

refactor(stream): revised the display info.

This commit is contained in:
Haojun Liao 2023-10-07 09:04:38 +08:00
parent 28008f8263
commit f0c5b5a970
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/dnode/mnode/impl/src/mndStream.c
View File

@ -1603,10 +1603,10 @@ static int32_t mndRetrieveStreamTask(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock
// colDataSetVal(pColInfo, numOfRows, (const char*)vbuf, false); // colDataSetVal(pColInfo, numOfRows, (const char*)vbuf, false);
if (pTask->info.taskLevel == TASK_LEVEL__SINK) { if (pTask->info.taskLevel == TASK_LEVEL__SINK) {
const char* sinkStr = "Quota:%2.fMiB, SinkData:%.2fMiB"; const char* sinkStr = "SinkData:%.2fMiB";
sprintf(buf, sinkStr, pe->sinkQuota, pe->sinkDataSize); sprintf(buf, sinkStr, pe->sinkQuota, pe->sinkDataSize);
} else if (pTask->info.taskLevel == TASK_LEVEL__SOURCE) { } else if (pTask->info.taskLevel == TASK_LEVEL__SOURCE) {
// offset version info // offset info
const char *offsetStr = "%" PRId64 " [%" PRId64 ", %" PRId64 "]"; const char *offsetStr = "%" PRId64 " [%" PRId64 ", %" PRId64 "]";
sprintf(buf, offsetStr, pe->offset, pe->verStart, pe->verEnd); sprintf(buf, offsetStr, pe->offset, pe->verStart, pe->verEnd);
} }