[SPARK-36030][SQL][FOLLOW-UP] Avoid procedure syntax deprecated in Scala 2.13
### What changes were proposed in this pull request?
This PR avoid using procedure syntax deprecated in Scala 2.13.
https://github.com/apache/spark/runs/3120481756?check_suite_focus=true
```
[error] /home/runner/work/spark/spark/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriterMetricSuite.scala:44:90: procedure syntax is deprecated: instead, add `: Unit =` to explicitly declare `testMetricOnDSv2`'s return type
[error] private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit) {
[error] ^
[error] /home/runner/work/spark/spark/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/InMemoryTableMetricSuite.scala:44:90: procedure syntax is deprecated: instead, add `: Unit =` to explicitly declare `testMetricOnDSv2`'s return type
[error] private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit) {
[error] ^
[warn] 100 warnings found
[error] two errors found
[error] (sql / Test / compileIncremental) Compilation failed
[error] Total time: 579 s (09:39), completed Jul 21, 2021 4:14:26 AM
```
### Why are the changes needed?
To make the build compatible with Scala 2.13 in Spark.
### Does this PR introduce _any_ user-facing change?
No, dev-only.
### How was this patch tested?
Manually tested:
```bash
./dev/change-scala-version.sh 2.13
./build/mvn -DskipTests -Phive-2.3 -Phive clean package -Pscala-2.13
```
Closes #33452 from HyukjinKwon/SPARK-36030.
Authored-by: Hyukjin Kwon <gurwls223@apache.org>
Signed-off-by: Hyukjin Kwon <gurwls223@apache.org>
(cherry picked from commit 99006e515b
)
Signed-off-by: Hyukjin Kwon <gurwls223@apache.org>
This commit is contained in:
parent
86d1fb4698
commit
6041d1c51b
|
@ -41,7 +41,7 @@ class FileFormatDataWriterMetricSuite
|
|||
spark.sessionState.conf.clear()
|
||||
}
|
||||
|
||||
private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit) {
|
||||
private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit): Unit = {
|
||||
withTable("testcat.table_name") {
|
||||
val statusStore = spark.sharedState.statusStore
|
||||
val oldCount = statusStore.executionsList().size
|
||||
|
|
|
@ -41,7 +41,7 @@ class InMemoryTableMetricSuite
|
|||
spark.sessionState.conf.clear()
|
||||
}
|
||||
|
||||
private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit) {
|
||||
private def testMetricOnDSv2(func: String => Unit, checker: Map[Long, String] => Unit): Unit = {
|
||||
withTable("testcat.table_name") {
|
||||
val statusStore = spark.sharedState.statusStore
|
||||
val oldCount = statusStore.executionsList().size
|
||||
|
|
Loading…
Reference in a new issue