error handling

2022-12-08 16:09:50 +08:00 · 2022-12-08 16:09:50 +08:00 · a8b97a3a52
parent 3d9cc76489
commit a8b97a3a52
1 changed files with 3 additions and 0 deletions
--- a/source/dnode/vnode/src/tq/tqSink.c
+++ b/source/dnode/vnode/src/tq/tqSink.c
@ -967,6 +967,9 @@ void tqSinkToTablePipeline2(SStreamTask* pTask, void* vnode, int64_t ver, void*
      if (tEncodeSSubmitReq2(&encoder, pReq) < 0) {
        terrno = TSDB_CODE_OUT_OF_MEMORY;
        tqError("failed to encode submit req since %s", terrstr());
+        tEncoderClear(&encoder);
+        rpcFreeCont(pBuf);
+        continue;
      }
      tEncoderClear(&encoder);