提交 17592ea2 编写于 作者: H Haojun Liao

refactor: do some internal refactor.

上级 3b6e052c
...@@ -28,11 +28,7 @@ char* createStreamTaskIdStr(int64_t streamId, int32_t taskId) { ...@@ -28,11 +28,7 @@ char* createStreamTaskIdStr(int64_t streamId, int32_t taskId) {
int32_t tqAddBlockNLaunchTask(SStreamTask* pTask, SPackedData *pPackedData) { int32_t tqAddBlockNLaunchTask(SStreamTask* pTask, SPackedData *pPackedData) {
SStreamDataSubmit* p = streamDataSubmitNew(pPackedData, STREAM_INPUT__DATA_SUBMIT); SStreamDataSubmit* p = streamDataSubmitNew(pPackedData, STREAM_INPUT__DATA_SUBMIT);
int32_t code = tAppendDataToInputQueue(pTask, (SStreamQueueItem*) p); int32_t code = tAppendDataToInputQueue(pTask, (SStreamQueueItem*) p);
streamDataSubmitDestroy(p);
taosFreeQitem(p);
if (code < 0) { if (code < 0) {
tqError("s-task:%s failed to put into queue, too many, next start ver:%" PRId64, pTask->id.idStr, pPackedData->ver); tqError("s-task:%s failed to put into queue, too many, next start ver:%" PRId64, pTask->id.idStr, pPackedData->ver);
return -1; return -1;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册