Fix.

infiniflow · Jan 26, 2025 · 8abf993 · 8abf993
1 parent 73cf22f
commit 8abf993
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/scheduler/fragment_context.cpp b/src/scheduler/fragment_context.cpp
@@ -1100,10 +1100,10 @@ void FragmentContext::MakeSinkState(i64 parallel_count) {
             break;
         }
         case PhysicalOperatorType::kLimit: {
-            if (fragment_type_ != FragmentType::kParallelStream) {
-                String error_message = fmt::format("{} should in parallel stream fragment", PhysicalOperatorToString(last_operator->operator_type()));
-                UnrecoverableError(error_message);
-            }
+            // if (fragment_type_ != FragmentType::kParallelStream) {
+            //     String error_message = fmt::format("{} should in parallel stream fragment", PhysicalOperatorToString(last_operator->operator_type()));
+            //     UnrecoverableError(error_message);
+            // }
 
             if ((i64)tasks_.size() != parallel_count) {
                 String error_message = fmt::format("{} task count isn't correct.", PhysicalOperatorToString(last_operator->operator_type()));