From 5c2ea44d847208ba9847e06c2b7a898ff4dfb273 Mon Sep 17 00:00:00 2001 From: cht <765917163@qq.com> Date: Thu, 6 Nov 2025 21:24:19 +0800 Subject: [PATCH] test --- cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h | 1 + 1 file changed, 1 insertion(+) diff --git a/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h b/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h index c35d8df..6a9e064 100644 --- a/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h +++ b/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h @@ -346,6 +346,7 @@ public: } int numRows = collectedRows.size(); INFO_RELEASE("collectedRows: " << collectedRows.size()) + auto* outputBatch = new omnistream::VectorBatch(numRows); for (int colIndex = 0; colIndex < numColumns; ++colIndex) { switch (inputRowType->at(colIndex)) { -- Gitee