From 40474e721e429656224dcf2bb02dbfedd3f693e3 Mon Sep 17 00:00:00 2001 From: Kier Petrov Date: Tue, 21 Jan 2025 13:23:54 -0800 Subject: [PATCH] ensure that legacy failover stays legacy failover --- .../queryplanner/HighAvailabilityPlanner.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/HighAvailabilityPlanner.scala index 6bf039d71..492d469ce 100644 --- 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)