提交 c330588d 编写于 作者: wmmhello's avatar wmmhello

fix:error in subscribe table for taosx

上级 c576d1fa
...@@ -1126,7 +1126,7 @@ static int32_t taosDeleteData(TAOS* taos, void* meta, int32_t metaLen) { ...@@ -1126,7 +1126,7 @@ static int32_t taosDeleteData(TAOS* taos, void* meta, int32_t metaLen) {
TAOS_RES* res = taos_query(taos, sql); TAOS_RES* res = taos_query(taos, sql);
SRequestObj* pRequest = (SRequestObj*)res; SRequestObj* pRequest = (SRequestObj*)res;
code = pRequest->code; code = pRequest->code;
if (code == TSDB_CODE_PAR_TABLE_NOT_EXIST) { if (code == TSDB_CODE_PAR_TABLE_NOT_EXIST || code == TSDB_CODE_PAR_GET_META_ERROR) {
code = TSDB_CODE_SUCCESS; code = TSDB_CODE_SUCCESS;
} }
taos_free_result(res); taos_free_result(res);
......
...@@ -971,9 +971,8 @@ static int32_t mndProcessCreateStbReq(SRpcMsg *pReq) { ...@@ -971,9 +971,8 @@ static int32_t mndProcessCreateStbReq(SRpcMsg *pReq) {
code = 0; code = 0;
goto _OVER; goto _OVER;
} else if (pStb->uid != createReq.suid) { } else if (pStb->uid != createReq.suid) {
mError("stb:%s, already exist while create, input suid:%" PRId64 " not match with exist suid:%" PRId64, mInfo("stb:%s, alter table does not need to be done, because table is deleted", createReq.name);
createReq.name, createReq.suid, pStb->uid); code = 0;
terrno = TSDB_CODE_MND_STABLE_UID_NOT_MATCH;
goto _OVER; goto _OVER;
} else if (createReq.tagVer > 0 || createReq.colVer > 0) { } else if (createReq.tagVer > 0 || createReq.colVer > 0) {
int32_t tagDelta = createReq.tagVer - pStb->tagVer; int32_t tagDelta = createReq.tagVer - pStb->tagVer;
......
...@@ -43,7 +43,7 @@ class TDTestCase: ...@@ -43,7 +43,7 @@ class TDTestCase:
tdSql.execute('use db_taosx') tdSql.execute('use db_taosx')
tdSql.query("show tables") tdSql.query("show tables")
if drop: if drop:
tdSql.checkRows(10) tdSql.checkRows(11)
else: else:
tdSql.checkRows(16) tdSql.checkRows(16)
tdSql.query("select * from jt order by i") tdSql.query("select * from jt order by i")
...@@ -74,7 +74,7 @@ class TDTestCase: ...@@ -74,7 +74,7 @@ class TDTestCase:
tdSql.execute('use abc1') tdSql.execute('use abc1')
tdSql.query("show tables") tdSql.query("show tables")
if drop: if drop:
tdSql.checkRows(10) tdSql.checkRows(11)
else: else:
tdSql.checkRows(16) tdSql.checkRows(16)
tdSql.query("select * from jt order by i") tdSql.query("select * from jt order by i")
......
...@@ -70,8 +70,9 @@ static void msg_process(TAOS_RES* msg) { ...@@ -70,8 +70,9 @@ static void msg_process(TAOS_RES* msg) {
tmq_get_raw(msg, &raw); tmq_get_raw(msg, &raw);
printf("write raw data type: %d\n", raw.raw_type); printf("write raw data type: %d\n", raw.raw_type);
int32_t ret = tmq_write_raw(pConn, raw); int32_t ret = tmq_write_raw(pConn, raw);
ASSERT(ret == 0);
printf("write raw data: %s\n", tmq_err2str(ret)); printf("write raw data: %s\n", tmq_err2str(ret));
ASSERT(ret == 0);
tmq_free_raw(raw); tmq_free_raw(raw);
taos_close(pConn); taos_close(pConn);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册