From cf8d35a1c75dec91998288cc3d364b1d769423e9 Mon Sep 17 00:00:00 2001 From: Yuming Wang Date: Fri, 3 Feb 2023 10:01:07 -0800 Subject: [PATCH] [SPARK-42333][SQL] Change log level to debug when fetching result set from SparkExecuteStatementOperation ### What changes were proposed in this pull request? Change log level from info to debug when fetching result set from `SparkExecuteStatementOperation`. ### Why are the changes needed? Avoid generating too many logs: image ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Unit test. Closes #39876 from wangyum/SPARK-42333. Authored-by: Yuming Wang Signed-off-by: Dongjoon Hyun (cherry picked from commit 4ebfc0e2e9405282e3fa044aaa59b69ddb8a1162) Signed-off-by: Dongjoon Hyun --- .../hive/thriftserver/SparkExecuteStatementOperation.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala index 3292cbef41772..c41e92e618bac 100644 --- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala +++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala @@ -96,7 +96,7 @@ private[hive] class SparkExecuteStatementOperation( private def getNextRowSetInternal( order: FetchOrientation, maxRowsL: Long): TRowSet = withLocalProperties { - log.info(s"Received getNextRowSet request order=${order} and maxRowsL=${maxRowsL} " + + log.debug(s"Received getNextRowSet request order=${order} and maxRowsL=${maxRowsL} " + s"with ${statementId}") validateDefaultFetchOrientation(order) assertState(OperationState.FINISHED) @@ -112,7 +112,7 @@ private[hive] class SparkExecuteStatementOperation( val maxRows = maxRowsL.toInt val offset = iter.getPosition val rows = iter.take(maxRows).toList - log.info(s"Returning result set with ${rows.length} rows from offsets " + + log.debug(s"Returning result set with ${rows.length} rows from offsets " + s"[${iter.getFetchStart}, ${offset}) with $statementId") RowSetUtils.toTRowSet(offset, rows, dataTypes, getProtocolVersion, getTimeFormatters) }