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

enh(stream): forbid source db replica > 1

This commit is contained in:
Liu Jicong 2022-12-16 14:45:52 +08:00
parent be03f7aa8b
commit 4ab9638f9a
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/dnode/mnode/impl/src/mndStream.c
View File

@ -633,6 +633,7 @@ static int32_t mndProcessCreateStreamReq(SRpcMsg *pReq) {
pDb = NULL; pDb = NULL;
goto _OVER; goto _OVER;
} }
mndReleaseDb(pMnode, pDb);
STrans *pTrans = mndTransCreate(pMnode, TRN_POLICY_ROLLBACK, TRN_CONFLICT_DB_INSIDE, pReq, "create-stream"); STrans *pTrans = mndTransCreate(pMnode, TRN_POLICY_ROLLBACK, TRN_CONFLICT_DB_INSIDE, pReq, "create-stream");
if (pTrans == NULL) { if (pTrans == NULL) {

4
tests/system-test/1-insert/drop.py
View File

@ -132,7 +132,7 @@ class TDTestCase:
tdSql.execute(f'drop database {self.dbname}') tdSql.execute(f'drop database {self.dbname}')
def drop_stream_check(self): def drop_stream_check(self):
tdSql.execute(f'create database {self.dbname} replica {self.replicaVar}') tdSql.execute(f'create database {self.dbname} replica 1')
tdSql.execute(f'use {self.dbname}') tdSql.execute(f'use {self.dbname}')
stbname = tdCom.getLongName(5,"letters") stbname = tdCom.getLongName(5,"letters")
stream_name = tdCom.getLongName(5,"letters") stream_name = tdCom.getLongName(5,"letters")
@ -158,4 +158,4 @@ class TDTestCase:
tdLog.success("%s successfully executed" % __file__) tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase()) tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase()) tdCases.addLinux(__file__, TDTestCase())