fixup

oap-project · Nov 11, 2024 · 5e37fb4 · 5e37fb4
1 parent f9cf941
commit 5e37fb4
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/velox/exec/Task.cpp b/velox/exec/Task.cpp
@@ -604,15 +604,17 @@ bool Task::supportSerialExecutionMode() const {
     return false;
   }
 
-  std::vector<std::unique_ptr<DriverFactory>> driverFactories;
-  LocalPlanner::plan(
-      planFragment_, nullptr, &driverFactories, queryCtx_->queryConfig(), 1);
-
-  for (const auto& factory : driverFactories) {
-    if (!factory->supportsSerialExecution()) {
-      return false;
-    }
-  }
+  // PoC
+  //  std::vector<std::unique_ptr<DriverFactory>> driverFactories;
+  //  LocalPlanner::plan(
+  //      planFragment_, nullptr, &driverFactories, queryCtx_->queryConfig(),
+  //      1);
+  //
+  //  for (const auto& factory : driverFactories) {
+  //    if (!factory->supportsSerialExecution()) {
+  //      return false;
+  //    }
+  //  }
 
   return true;
 }
@@ -1887,7 +1889,7 @@ template <class TBridgeType, typename MemberType>
 std::shared_ptr<TBridgeType> Task::getJoinBridgeInternalLocked(
     uint32_t splitGroupId,
     const core::PlanNodeId& planNodeId,
-    MemberType SplitGroupState::*bridges_member) {
+    MemberType SplitGroupState::* bridges_member) {
   const auto& splitGroupState = splitGroupStates_[splitGroupId];
 
   auto it = (splitGroupState.*bridges_member).find(planNodeId);