fix(query) the schema provided by _type_ does not match colIDs in the…

… data.
filodb · Oct 10, 2024 · a6c86f3 · a6c86f3
1 parent 22d0b08
commit a6c86f3
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/core/src/main/scala/filodb.core/memstore/OnDemandPagingShard.scala b/core/src/main/scala/filodb.core/memstore/OnDemandPagingShard.scala
@@ -141,6 +141,13 @@ TimeSeriesShard(ref, schemas, storeConfig, numShards, quotaSource, shardNum, buf
                               colIds: Seq[Types.ColumnId],
                               querySession: QuerySession): Observable[ReadablePartition] = {
 
+    // To support _type_ query, this filters the data schema that matches the colIds.
+    if (partLookupRes.firstSchemaId.map(schId => Schemas.global.apply(schId))
+      .filter(sch => sch != null)
+      .exists(sch => sch.data.columns.size <= colIds.max)) {
+      return Observable.empty
+    }
+
     capDataScannedPerShardCheck(partLookupRes, colIds, querySession.qContext, querySession.warnings)
 
     // For now, always read every data column.