Skip to content

Commit 7af0544

Browse files
Ngone51cloud-fan
authored andcommitted
[SPARK-38266][3.2][FOLLOW-UP] Fix broken test failure in 3.2 build
### What changes were proposed in this pull request? Fix test failure of branch-3.2 build. ### Why are the changes needed? The error message in 3.2 hasn't been improved. So the unit test failed due to the mismatched error message. ``` [info] - SPARK-35937: GetDateFieldOperations should skip unresolved nodes *** FAILED *** (20 milliseconds) [info] "cannot resolve 'df1.timeStr' given input columns: [df3.timeStr, df1.tsStr]" did not contain "Column 'df1.timeStr' does not exist." (DataFrameSelfJoinSuite.scala:484) [info] org.scalatest.exceptions.TestFailedException: [info] at org.scalatest.Assertions.newAssertionFailedException(Assertions.scala:472) [info] at org.scalatest.Assertions.newAssertionFailedException$(Assertions.scala:471) [info] at org.scalatest.Assertions$.newAssertionFailedException(Assertions.scala:1231) [info] at org.scalatest.Assertions$AssertionsHelper.macroAssert(Assertions.scala:1295) [info] at org.apache.spark.sql.DataFrameSelfJoinSuite.$anonfun$new$108(DataFrameSelfJoinSuite.scala:484) [info] at org.apache.spark.sql.catalyst.plans.SQLHelper.withSQLConf(SQLHelper.scala:54) [info] at org.apache.spark.sql.catalyst.plans.SQLHelper.withSQLConf$(SQLHelper.scala:38) [info] at org.apache.spark.sql.DataFrameSelfJoinSuite.org$apache$spark$sql$test$SQLTestUtilsBase$$super$withSQLConf(DataFrameSelfJoinSuite.scala:30) [info] at org.apache.spark.sql.test.SQLTestUtilsBase.withSQLConf(SQLTestUtils.scala:246) [info] at org.apache.spark.sql.test.SQLTestUtilsBase.withSQLConf$(SQLTestUtils.scala:244) [info] at org.apache.spark.sql.DataFrameSelfJoinSuite.withSQLConf(DataFrameSelfJoinSuite.scala:30) [info] at org.apache.spark.sql.DataFrameSelfJoinSuite.$anonfun$new$107(DataFrameSelfJoinSuite.scala:472) [info] at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) [info] at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85) ... ``` ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Tested locally. Closes #35601 from Ngone51/SPARK-38266-followup. Authored-by: yi.wu <[email protected]> Signed-off-by: Wenchen Fan <[email protected]>
1 parent a963b35 commit 7af0544

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -481,7 +481,7 @@ class DataFrameSelfJoinSuite extends QueryTest with SharedSparkSession {
481481
val ex = intercept[AnalysisException](
482482
df3.join(df1, year($"df1.timeStr") === year($"df3.tsStr"))
483483
)
484-
assert(ex.message.contains("Column 'df1.timeStr' does not exist."))
484+
assert(ex.message.contains("cannot resolve 'df1.timeStr'"))
485485
}
486486
}
487487
}

0 commit comments

Comments
 (0)