revert some change

infiniflow · Oct 18, 2024 · 146a709 · 146a709
1 parent deb0377
commit 146a709
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/scheduler/fragment_context.cpp b/src/scheduler/fragment_context.cpp
@@ -480,6 +480,9 @@ MakeTaskState(SizeT operator_id, const Vector<PhysicalOperator *> &physical_ops,
         case PhysicalOperatorType::kAlter: {
             return MakeTaskStateTemplate<AlterOperatorState>(physical_ops[operator_id]);
         }
+        case PhysicalOperatorType::kReadCache: {
+            return MakeTaskStateTemplate<ReadCacheState>(physical_ops[operator_id]);
+        }
         default: {
             String error_message = fmt::format("Not support {} now", PhysicalOperatorToString(physical_ops[operator_id]->operator_type()));
             UnrecoverableError(error_message);
@@ -1005,7 +1008,8 @@ void FragmentContext::MakeSourceState(i64 parallel_count) {
         case PhysicalOperatorType::kOptimize:
         case PhysicalOperatorType::kFlush:
         case PhysicalOperatorType::kCompactFinish:
-        case PhysicalOperatorType::kCompactIndexPrepare: {
+        case PhysicalOperatorType::kCompactIndexPrepare:
+        case PhysicalOperatorType::kReadCache: {
             if (fragment_type_ != FragmentType::kSerialMaterialize) {
                 UnrecoverableError(
                     fmt::format("{} should in serial materialized fragment", PhysicalOperatorToString(first_operator->operator_type())));