fix: fix invalid ref.

4974ac78 · Haojun Liao · 336102b8 · 4974ac78
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamDispatch.c source/libs/stream/src/streamDispatch.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamDispatch.c
+++ b/source/libs/stream/src/streamDispatch.c
@@ -526,7 +526,7 @@ int32_t streamDispatch(SStreamTask* pTask, SStreamDataBlock** pBlock) {

  ASSERT(pDispatchedBlock->type == STREAM_INPUT__DATA_BLOCK);

-  int32_t code = streamDispatchAllBlocks(pTask, *pBlock);
+  int32_t code = streamDispatchAllBlocks(pTask, pDispatchedBlock);
  if (code != TSDB_CODE_SUCCESS) {
    streamQueueProcessFail(pTask->outputQueue);
    atomic_store_8(&pTask->outputStatus, TASK_OUTPUT_STATUS__NORMAL);