Skip to content

Commit a746160

Browse files
committed
Update code
1 parent 5e56097 commit a746160

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/WholeStageCodegenSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -445,7 +445,7 @@ class WholeStageCodegenSuite extends QueryTest with SharedSparkSession
445445
"GROUP BY k").foreach { query =>
446446
val e = intercept[Exception] {
447447
sql(query).collect
448-
}.getCause
448+
}
449449
assert(e.isInstanceOf[IllegalStateException])
450450
assert(e.getMessage.contains(expectedErrMsg))
451451
}

sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -760,7 +760,7 @@ class AdaptiveQueryExecSuite
760760
val error = intercept[Exception] {
761761
aggregated.count()
762762
}
763-
assert(error.getCause().toString contains "Invalid bucket file")
763+
assert(error.toString contains "Invalid bucket file")
764764
assert(error.getSuppressed.size === 0)
765765
}
766766
}

sql/core/src/test/scala/org/apache/spark/sql/sources/BucketedReadSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -813,7 +813,7 @@ abstract class BucketedReadSuite extends QueryTest with SQLTestUtils with Adapti
813813
aggregated.count()
814814
}
815815

816-
assert(error.getCause().toString contains "Invalid bucket file")
816+
assert(error.toString contains "Invalid bucket file")
817817
}
818818
}
819819

0 commit comments

Comments
 (0)