Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2357#discussion_r192551344
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala ---
@@ -171,19 +170,25 @@ class CarbonSession(@transient val sc: SparkContext,
*/
private def trySearchMode(qe: QueryExecution, sse: SQLStart): DataFrame
= {
val analyzed = qe.analyzed
+ val LOG: LogService =
LogServiceFactory.getLogService(classOf[CarbonSession].getName)
analyzed match {
case _@Project(columns, _@Filter(expr, s: SubqueryAlias))
if s.child.isInstanceOf[LogicalRelation] &&
s.child.asInstanceOf[LogicalRelation].relation
.isInstanceOf[CarbonDatasourceHadoopRelation] =>
+ LOG.info(String.format("Search service started and supports: %s",
sse.sqlText))
runSearch(analyzed, columns, expr,
s.child.asInstanceOf[LogicalRelation])
case gl@GlobalLimit(_, ll@LocalLimit(_, p@Project(columns,
_@Filter(expr, s: SubqueryAlias))))
if s.child.isInstanceOf[LogicalRelation] &&
s.child.asInstanceOf[LogicalRelation].relation
.isInstanceOf[CarbonDatasourceHadoopRelation] =>
val logicalRelation = s.child.asInstanceOf[LogicalRelation]
+ LOG.info(String.format("Search service started and supports: %s",
sse.sqlText))
runSearch(analyzed, columns, expr, logicalRelation, gl.maxRows,
ll.maxRows)
case _ =>
+ LOG.info(String.format(
+ "Search service started, but don't support: %s, and running it
with SparkSQL",
--- End diff --
ok, done
---
