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

change default config

This commit is contained in:
yihaoDeng 2023-11-29 14:50:07 +08:00
parent ade2f322a0
commit 03b698d8ae
3 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -366,7 +366,11 @@ int32_t streamSnapRead(SStreamSnapReader* pReader, uint8_t** ppData, int64_t* si
int32_t code = 0; int32_t code = 0;
SStreamSnapHandle* pHandle = &pReader->handle; SStreamSnapHandle* pHandle = &pReader->handle;
int32_t idx = pHandle->currIdx; int32_t idx = pHandle->currIdx;
SBackendSnapFile2* pSnapFile = taosArrayGet(pHandle->pDbSnapSet, idx); SBackendSnapFile2* pSnapFile = taosArrayGet(pHandle->pDbSnapSet, idx);
if (pSnapFile == NULL) {
return 0;
}
SBackendFileItem* item = NULL; SBackendFileItem* item = NULL;
_NEXT: _NEXT:

2
tests/system-test/8-stream/snode_restart_with_checkpoint.py
View File

@ -31,7 +31,7 @@ class TDTestCase:
tdSql.query("use test") tdSql.query("use test")
tdSql.query("create snode on dnode 4") tdSql.query("create snode on dnode 4")
tdSql.query("create stream if not exists s1 trigger at_once ignore expired 0 ignore update 0 fill_history 1 into st1 as select _wstart,sum(voltage),groupid from meters partition by groupid interval(2s)") tdSql.query("create stream if not exists s1 trigger at_once ignore expired 0 ignore update 0 fill_history 1 into st1 as select _wstart,sum(voltage),groupid from meters partition by groupid interval(2s)")
tdLog.debug("========create stream useing snode and insert data ok========") tdLog.debug("========create stream using snode and insert data ok========")
time.sleep(60) time.sleep(60)
tdDnodes = cluster.dnodes tdDnodes = cluster.dnodes