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

fix(query):remove invalid assert.

This commit is contained in:
Haojun Liao 2024-05-16 19:26:07 +08:00
parent 76a296ca52
commit 66254c96a7
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
source/client/test/clientTests.cpp
View File

@ -901,13 +901,13 @@ TEST(clientCase, tsbs_perf_test) {
} }
TEST(clientCase, projection_query_stables) { TEST(clientCase, projection_query_stables) {
TAOS* pConn = taos_connect("localhost", "root", "taosdata", NULL, 0); TAOS* pConn = taos_connect("192.168.1.53", "root", "taosdata", NULL, 0);
ASSERT_NE(pConn, nullptr); ASSERT_NE(pConn, nullptr);
TAOS_RES* pRes = taos_query(pConn, "use test"); TAOS_RES* pRes = taos_query(pConn, "use qzdata");
taos_free_result(pRes); taos_free_result(pRes);
pRes = taos_query(pConn, "select * from meters limit 50000000"); pRes = taos_query(pConn, "select * from `X212MGPH018`");
if (taos_errno(pRes) != 0) { if (taos_errno(pRes) != 0) {
printf("failed to select from table, reason:%s\n", taos_errstr(pRes)); printf("failed to select from table, reason:%s\n", taos_errstr(pRes));
taos_free_result(pRes); taos_free_result(pRes);
@ -918,10 +918,13 @@ TEST(clientCase, projection_query_stables) {
TAOS_FIELD* pFields = taos_fetch_fields(pRes); TAOS_FIELD* pFields = taos_fetch_fields(pRes);
int32_t numOfFields = taos_num_fields(pRes); int32_t numOfFields = taos_num_fields(pRes);
char str[512] = {0}; int32_t i = 0;
char str[512] = {0};
while ((pRow = taos_fetch_row(pRes)) != NULL) { while ((pRow = taos_fetch_row(pRes)) != NULL) {
// int32_t code = taos_print_row(str, pRow, pFields, numOfFields); // int32_t code = taos_print_row(str, pRow, pFields, numOfFields);
// printf("%s\n", str); if (i++ % 100000 == 0) {
printf("%d\n", i);
}
} }
taos_free_result(pRes); taos_free_result(pRes);

2
source/libs/executor/src/exchangeoperator.c
View File

@ -681,7 +681,7 @@ int32_t doExtractResultBlocks(SExchangeInfo* pExchangeInfo, SSourceDataInfo* pDa
p = taosMemoryMalloc(pRetrieveRsp->payloadLen); p = taosMemoryMalloc(pRetrieveRsp->payloadLen);
int32_t t = tsDecompressString(pRetrieveRsp->data, pRetrieveRsp->compLen, 1, p, pRetrieveRsp->payloadLen, int32_t t = tsDecompressString(pRetrieveRsp->data, pRetrieveRsp->compLen, 1, p, pRetrieveRsp->payloadLen,
ONE_STAGE_COMP, NULL, 0); ONE_STAGE_COMP, NULL, 0);
ASSERT(t == pRetrieveRsp->payloadLen); // ASSERT(t == pRetrieveRsp->payloadLen);
pStart = p; pStart = p;
} }