diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c
index 9c285856d3d50c836389c851b451a7d035abe5b8..a5bc1fdf5838b2a5aa987924cc325a4f8b036d5f 100644
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -2229,7 +2229,7 @@ int32_t doCopyToSDataBlock(SExecTaskInfo* taskInfo, SSDataBlock* pBlock, SExprIn
       if (pCtx[j].fpSet.finalize) {
         int32_t code = TSDB_CODE_SUCCESS;
         code = pCtx[j].fpSet.finalize(&pCtx[j], pBlock);
-        if (code != TSDB_CODE_SUCCESS) {
+        if (TAOS_FAILED(code)) {
           qError("%s build result data block error, code %s", GET_TASKID(taskInfo), tstrerror(code));
           taskInfo->code = code;
           longjmp(taskInfo->env, code);