diff --git a/velox/experimental/stateful/StatefulTask.cpp b/velox/experimental/stateful/StatefulTask.cpp
index 2d12a5601ec9..dab972edc6d3 100644
--- a/velox/experimental/stateful/StatefulTask.cpp
+++ b/velox/experimental/stateful/StatefulTask.cpp
@@ -78,7 +78,7 @@ void StatefulTask::initOperators() {
 
 RowVectorPtr StatefulTask::next(int32_t& retCode) {
   retCode = 0;
-  initOperators();
+  // initOperators();
 
   // Run operators one by one. If an operator has output, run its downstream operators.
   // If the last operator has output, return the output.
@@ -112,7 +112,8 @@ RowVectorPtr StatefulTask::next(int32_t& retCode) {
           }
           return nullptr;
         } else {
-          break;
+          // break;
+          return nullptr;
         }
       }