This is an automated email from the ASF dual-hosted git repository.
maxgekk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new b0751ed22b9 [SPARK-41796][TESTS] Test the error class:
UNSUPPORTED_SUBQUERY_EXPRESSION_CATEGORY.UNSUPPORTED_CORRELATED_REFERENCE_DATA_TYPE
b0751ed22b9 is described below
commit b0751ed22b94a93a5a60a20b24a88ca77d67c694
Author: panbingkun <pbk1...@gmail.com>
AuthorDate: Sun Jan 1 21:45:56 2023 +0500
[SPARK-41796][TESTS] Test the error class:
UNSUPPORTED_SUBQUERY_EXPRESSION_CATEGORY.UNSUPPORTED_CORRELATED_REFERENCE_DATA_TYPE
### What changes were proposed in this pull request?
This PR aims to modify a test for the error class
UNSUPPORTED_SUBQUERY_EXPRESSION_CATEGORY.UNSUPPORTED_CORRELATED_REFERENCE_DATA_TYPE
in SubquerySuite.
### Why are the changes needed?
The changes improve test coverage, and document expected error messages in
tests.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass GA.
Update existed UT.
Closes #39320 from panbingkun/SPARK-41796.
Authored-by: panbingkun <pbk1...@gmail.com>
Signed-off-by: Max Gekk <max.g...@gmail.com>
---
.../scala/org/apache/spark/sql/SubquerySuite.scala | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SubquerySuite.scala
b/sql/core/src/test/scala/org/apache/spark/sql/SubquerySuite.scala
index 65dd911df31..3d4a629f7a9 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/SubquerySuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/SubquerySuite.scala
@@ -2452,16 +2452,24 @@ class SubquerySuite extends QueryTest
Row(2))
// Cannot use non-orderable data type in one row subquery that cannot be
collapsed.
- val error = intercept[AnalysisException] {
+ checkError(
+ exception = intercept[AnalysisException] {
sql(
- """
- |select (
+ """select (
| select concat(a, a) from
| (select upper(x['a'] + rand()) as a)
|) from v1
- |""".stripMargin).collect()
- }
- assert(error.getMessage.contains("Correlated column reference 'v1.x'
cannot be map type"))
+ |""".stripMargin
+ ).collect()
+ },
+ errorClass = "UNSUPPORTED_SUBQUERY_EXPRESSION_CATEGORY." +
+ "UNSUPPORTED_CORRELATED_REFERENCE_DATA_TYPE",
+ parameters = Map("expr" -> "v1.x", "dataType" -> "map"),
+ context = ExpectedContext(
+ fragment = "select upper(x['a'] + rand()) as a",
+ start = 39,
+ stop = 72)
+ )
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
