From 4d8cc7aedd682015b11fc19197ba530760f3eac1 Mon Sep 17 00:00:00 2001 From: Xiaoyu Wang Date: Tue, 11 Jan 2022 03:20:06 -0500 Subject: [PATCH] TD-12678 datasink interface adjust --- include/libs/executor/dataSinkMgt.h | 4 ++-- source/libs/executor/src/dataDispatcher.c | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/include/libs/executor/dataSinkMgt.h b/include/libs/executor/dataSinkMgt.h index 733e6d665d..a0819fcf85 100644 --- a/include/libs/executor/dataSinkMgt.h +++ b/include/libs/executor/dataSinkMgt.h @@ -21,7 +21,7 @@ extern "C" { #endif #include "os.h" -#include "executorimpl.h" +#include "thash.h" #define DS_BUF_LOW 1 #define DS_BUF_FULL 2 @@ -40,7 +40,7 @@ int32_t dsDataSinkMgtInit(SDataSinkMgtCfg *cfg); typedef void* DataSinkHandle; typedef struct SInputData { - const SSDataBlock* pData; + const struct SSDataBlock* pData; SHashObj* pTableRetrieveTsMap; } SInputData; diff --git a/source/libs/executor/src/dataDispatcher.c b/source/libs/executor/src/dataDispatcher.c index 954ed6daf1..e4b0557bff 100644 --- a/source/libs/executor/src/dataDispatcher.c +++ b/source/libs/executor/src/dataDispatcher.c @@ -19,6 +19,7 @@ #include "tcompression.h" #include "tglobal.h" #include "tqueue.h" +#include "executorimpl.h" #define DATA_META_LENGTH(tables) (sizeof(int32_t) + sizeof(STableIdInfo) * taosHashGetSize(tables) + sizeof(SRetrieveTableRsp))