Merge branch 'integration'

filodb · Jan 22, 2025 · 7ab2208 · 7ab2208
2 parents 5d4f14b + 5c56c2d
commit 7ab2208
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala
@@ -232,7 +232,12 @@ class HighAvailabilityPlanner(dsRef: DatasetRef,
   }
   //scalastyle:on method.length
 
-  def materializeLegacy(logicalPlan: LogicalPlan, qContext: QueryContext): ExecPlan = {
+  def materializeLegacy(logicalPlan: LogicalPlan, oqContext: QueryContext): ExecPlan = {
+    // ensure that we do not use any features of shard level failover
+    val plannerParams = oqContext.plannerParams.copy(
+      failoverMode = LegacyFailoverMode
+    )
+    val qContext = oqContext.copy(plannerParams = plannerParams)
     // lazy because we want to fetch failures only if needed
     lazy val offsetMillis = LogicalPlanUtils.getOffsetMillis(logicalPlan)
     lazy val periodicSeriesTime = getTimeFromLogicalPlan(logicalPlan)