refactor(query): do some internal refactor.
This commit is contained in:
parent
f867e8ea91
commit
cdc2002e70
|
@ -225,7 +225,6 @@ typedef struct SExecTaskInfo {
|
||||||
char* sql; // query sql string
|
char* sql; // query sql string
|
||||||
jmp_buf env; // jump to this position when error happens.
|
jmp_buf env; // jump to this position when error happens.
|
||||||
EOPTR_EXEC_MODEL execModel; // operator execution model [batch model|stream model]
|
EOPTR_EXEC_MODEL execModel; // operator execution model [batch model|stream model]
|
||||||
struct SSubplan *plan;
|
|
||||||
struct SOperatorInfo* pRoot;
|
struct SOperatorInfo* pRoot;
|
||||||
} SExecTaskInfo;
|
} SExecTaskInfo;
|
||||||
|
|
||||||
|
|
|
@ -5209,7 +5209,6 @@ int32_t createExecTaskInfoImpl(SSubplan* pPlan, SExecTaskInfo** pTaskInfo, SRead
|
||||||
goto _complete;
|
goto _complete;
|
||||||
}
|
}
|
||||||
|
|
||||||
(*pTaskInfo)->plan = pPlan;
|
|
||||||
return code;
|
return code;
|
||||||
|
|
||||||
_complete:
|
_complete:
|
||||||
|
|
Loading…
Reference in New Issue