Fix.

infiniflow · Oct 17, 2024 · a0b7e81 · a0b7e81
1 parent 8a43e18
commit a0b7e81
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/conf/pytest_parallel_infinity_conf.toml b/conf/pytest_parallel_infinity_conf.toml
@@ -17,6 +17,7 @@ persistence_dir          = "/var/infinity/persistence"
 [buffer]
 buffer_manager_size      = "8GB"
 temp_dir                 = "/var/infinity/tmp"
+result_cache_mode       = "on"
 
 [wal]
 wal_dir                  = "/var/infinity/wal"

diff --git a/conf/pytest_parallel_infinity_vfs_off.toml b/conf/pytest_parallel_infinity_vfs_off.toml
@@ -17,6 +17,7 @@ data_dir                 = "/var/infinity/data"
 [buffer]
 buffer_manager_size      = "8GB"
 temp_dir                 = "/var/infinity/tmp"
+result_cache_mode       = "on"
 
 [wal]
 wal_dir                  = "/var/infinity/wal"

diff --git a/src/scheduler/fragment_context.cpp b/src/scheduler/fragment_context.cpp
@@ -1119,7 +1119,7 @@ void FragmentContext::MakeSinkState(i64 parallel_count) {
             tasks_[0]->sink_state_ = MakeUnique<QueueSinkState>(plan_fragment_ptr_->FragmentID(), 0);
             break;
         }
-
+        case PhysicalOperatorType::kReadCache:
         case PhysicalOperatorType::kExplain:
         case PhysicalOperatorType::kShow: {
             if (fragment_type_ != FragmentType::kSerialMaterialize) {