Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1888#discussion_r165810948
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala
---
@@ -599,6 +599,8 @@ object PreAggregateUtil {
CarbonCommonConstants.VALIDATE_CARBON_INPUT_SEGMENTS +
parentTableIdentifier.database.getOrElse(sparkSession.catalog.currentDatabase)
+ "." +
parentTableIdentifier.table, validateSegments.toString)
+
CarbonSession.threadSet(CarbonCommonConstants.SUPPORT_DIRECT_QUERY_ON_DATAMAP,
--- End diff --
After applying pre aggregate rule we need to skip direct query on data map
check
---
