WIP

filodb · Dec 13, 2023 · f6ac82f · f6ac82f
1 parent f5595f6
commit f6ac82f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 deletions.
diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala
@@ -566,11 +566,11 @@ class MultiPartitionPlanner(partitionLocationProvider: PartitionLocationProvider
         walkLogicalPlanTree(newLp, qContext, true).plans
       } else {
         if (queryConfig.supportRemoteRawExport) {
-          logger.warn("Remote raw export not supported")
-        } else {
           logger.warn(
             s"Remote raw export is supported and the $totalExpectedRawExport ms" +
               s" is greater than the max allowed raw export duration of ${queryConfig.maxRemoteRawExportTimeRange}")
+        } else {
+          logger.warn("Remote raw export not supported")
         }
         Seq(EmptyResultExec(qContext, dataset.ref, inProcessPlanDispatcher))
       }

diff --git a/query/src/main/scala/filodb/query/exec/StitchRvsExec.scala b/query/src/main/scala/filodb/query/exec/StitchRvsExec.scala
@@ -55,9 +55,7 @@ object StitchRvsExec {
           if (mins.isEmpty) {
             minTime = t
             mins += r
-          }
-
-          else if (t < minTime) {
+          } else if (t < minTime) {
             mins.clear()
             mins += r
             minTime = t
@@ -66,7 +64,6 @@ object StitchRvsExec {
           }
         }
       }
-      println(s"t: $minTime, mins.length ${mins.length}")
       if (mins.isEmpty && tsIter.isEmpty) throw new IllegalStateException("next was called when no element")
       if (minTime > tsIter.head) {
         nanResult.timestamp = tsIter.next()
@@ -81,7 +78,6 @@ object StitchRvsExec {
           // until we have a different indicator for "unable-to-calculate", use NaN when multiple values seen
           val minRows = mins.map(it => if (it.hasNext) it.next() else nanResult) // move iterators forward
           val minsWithoutNan = minRows.filter(!_.getDouble(1).isNaN)
-          println(s"multiple mins for time $minTime, values are ${minsWithoutNan.map(_.getDouble(1))}")
           // The second condition checks if these values are equal within the tolerable limits and if yes, do not
           // emit NaN.
           // TODO: Make the second check and tolerance configurable?