File tree Expand file tree Collapse file tree 2 files changed +10
-2
lines changed
main/scala/org/apache/spark/sql/delta
test/scala/org/apache/spark/sql/delta/skipping/clustering Expand file tree Collapse file tree 2 files changed +10
-2
lines changed Original file line number Diff line number Diff line change @@ -47,6 +47,15 @@ class DeltaAnalysisException(
47
47
messageParameters,
48
48
context)
49
49
with DeltaThrowable {
50
+
51
+ /* Implemented for testing */
52
+ private [delta] def getMessageParametersArray : Array [String ] = errorClass match {
53
+ case Some (eClass) =>
54
+ DeltaThrowableHelper
55
+ .getParameterNames(eClass, errorSubClass = null )
56
+ .map(messageParameters(_))
57
+ case None => Array .empty
58
+ }
50
59
51
60
def this (
52
61
errorClass : String ,
Original file line number Diff line number Diff line change @@ -550,8 +550,7 @@ trait ClusteredTableDDLSuiteBase
550
550
}
551
551
assert(e2.getErrorClass == " DELTA_DUPLICATE_COLUMNS_FOUND" )
552
552
assert(e2.getSqlState == " 42711" )
553
- assert(e2.getMessageParameters ===
554
- Map (" colType" -> " in CLUSTER BY" , " duplicateCols" -> " `id`" ))
553
+ assert(e2.getMessageParametersArray === Array (" in CLUSTER BY" , " `id`" ))
555
554
}
556
555
}
557
556
You can’t perform that action at this time.
0 commit comments