diff --git a/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h b/cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h
index c35d8dfc0c453f2f1aae6423279645850f971faa..6a9e0642a5f400c22ac159d18e8c4dbeb69fb07e 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)) {