use stitch instead of concat

filodb · Oct 5, 2023 · acd1535 · acd1535
1 parent 34c6583
commit acd1535
Show file tree

Hide file tree

Showing 3 changed files with 76 additions and 76 deletions.
diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala
@@ -277,8 +277,8 @@ class MultiPartitionPlanner(partitionLocationProvider: PartitionLocationProvider
       if (execPlans.size == 1) execPlans.head
       else {
         // TODO: Do we pass in QueryContext in LogicalPlan's helper rvRangeForPlan?
-        MultiPartitionDistConcatExec(
-          qContext, inProcessPlanDispatcher, execPlans.sortWith((x, _) => !x.isInstanceOf[PromQlRemoteExec]))
+        StitchRvsExec(qContext, inProcessPlanDispatcher, rvRangeFromPlan(logicalPlan),
+          execPlans.sortWith((x, _) => !x.isInstanceOf[PromQlRemoteExec]))
       }
       // Sort to move RemoteExec in end as it does not have schema
     }