提交 0dc95ab2 编写于 作者: G Ganlin Zhao

increase retry counter and add log

上级 87f12010
......@@ -431,7 +431,7 @@ void tscProcessActivityTimer(void *handle, void *tmrId) {
int tscSendMsgToServer(SSqlObj *pSql) {
STscObj* pObj = pSql->pTscObj;
SSqlCmd* pCmd = &pSql->cmd;
char *pMsg = rpcMallocCont(pCmd->payloadLen);
if (NULL == pMsg) {
tscError("0x%"PRIx64" msg:%s malloc failed", pSql->self, taosMsg[pSql->cmd.msgType]);
......
......@@ -3568,6 +3568,8 @@ static void multiVnodeInsertFinalize(void* param, TAOS_RES* tres, int numOfRows)
pParentObj->res.code = TSDB_CODE_SUCCESS;
if (TSDB_QUERY_HAS_TYPE(pParentObj->cmd.insertParam.insertType, TSDB_QUERY_TYPE_STMT_INSERT)) {
tscDebug("0x%"PRIx64" re-try stmt with same submit data, retry:%d", pParentObj->self, pParentObj->retry);
pParentObj->retry++;
tscRestoreTableDataBlocks(&pParentObj->cmd.insertParam);
tscMergeTableDataBlocks(pParentObj, &pParentObj->cmd.insertParam, false);
tscHandleMultivnodeInsert(pParentObj);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册