Skip to content

Commit 019e37f

Browse files
committed
add some comment
1 parent 58e1cf1 commit 019e37f

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/SQLQueryTestSuite.scala

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -390,6 +390,12 @@ class SQLQueryTestSuite extends QueryTest with SharedSparkSession {
390390
}
391391
}
392392

393+
/**
394+
* This method handles exceptions occurred during query execution as they may need special care
395+
* to become comparable to the expected output.
396+
*
397+
* @param result a function that returns a pair of schema and output
398+
*/
393399
protected def handleExceptions(result: => (String, Seq[String])): (String, Seq[String]) = {
394400
try {
395401
result

sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/ThriftServerQueryTestSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -255,6 +255,7 @@ class ThriftServerQueryTestSuite extends SQLQueryTestSuite {
255255
}
256256
}
257257

258+
/** ThriftServer wraps the root exception, so it needs to be extracted. */
258259
override def handleExceptions(result: => (String, Seq[String])): (String, Seq[String]) = {
259260
super.handleExceptions {
260261
try {

0 commit comments

Comments
 (0)