diff --git a/source/libs/executor/inc/dataSinkMgt.h b/include/libs/executor/dataSinkMgt.h
similarity index 96%
rename from source/libs/executor/inc/dataSinkMgt.h
rename to include/libs/executor/dataSinkMgt.h
index d13423b25db6b5fcb8f1daca2aeeb91512cd0410..6470f38ced4e7aadaa990604ccc2164f431424b2 100644
--- a/source/libs/executor/inc/dataSinkMgt.h
+++ b/include/libs/executor/dataSinkMgt.h
@@ -73,9 +73,9 @@ void dsEndPut(DataSinkHandle handle);
 /**
  * Get the length of the data returned by the next call to dsGetDataBlock.
  * @param handle
- * @return data length
+ * @param pLen data length
  */
-int32_t dsGetDataLength(DataSinkHandle handle, int32_t* pStatus);
+void dsGetDataLength(DataSinkHandle handle, int32_t* pLen, int32_t* pStatus);
 
 /**
  * Get data, the caller needs to allocate data memory.
diff --git a/source/libs/executor/src/dataSinkMgt.c b/source/libs/executor/src/dataSinkMgt.c
index 8a96c5d05fb844f63d646737a5de5c6deb51d24e..01cc84c4f704a4c04a0d6f60a63f6f23e2d04803 100644
--- a/source/libs/executor/src/dataSinkMgt.c
+++ b/source/libs/executor/src/dataSinkMgt.c
@@ -41,9 +41,9 @@ void dsEndPut(DataSinkHandle handle) {
   return pHandleImpl->fEndPut(pHandleImpl);
 }
 
-int32_t dsGetDataLength(DataSinkHandle handle, int32_t* pStatus) {
+void dsGetDataLength(DataSinkHandle handle, int32_t* pLen, int32_t* pStatus) {
   SDataSinkHandle* pHandleImpl = (SDataSinkHandle*)handle;
-  return pHandleImpl->fGetLen(pHandleImpl, pStatus);
+  *pLen = pHandleImpl->fGetLen(pHandleImpl, pStatus);
 }
 
 int32_t dsGetDataBlock(DataSinkHandle handle, SOutPutData* pOutput, int32_t* pStatus) {