This is an automated email from the ASF dual-hosted git repository. changchen pushed a commit to branch feature/41 in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
commit c30f5ae1d271e0b21c5a0ab6090250f700ce1ce5 Author: Chang chen <[email protected]> AuthorDate: Fri Dec 26 15:22:34 2025 +0800 [Fix] Refactor Spark version checks in VeloxHashJoinSuite to improve readability and maintainability --- .../scala/org/apache/gluten/execution/VeloxHashJoinSuite.scala | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/backends-velox/src/test/scala/org/apache/gluten/execution/VeloxHashJoinSuite.scala b/backends-velox/src/test/scala/org/apache/gluten/execution/VeloxHashJoinSuite.scala index 53f44a2ccc..604c0e841c 100644 --- a/backends-velox/src/test/scala/org/apache/gluten/execution/VeloxHashJoinSuite.scala +++ b/backends-velox/src/test/scala/org/apache/gluten/execution/VeloxHashJoinSuite.scala @@ -92,12 +92,9 @@ class VeloxHashJoinSuite extends VeloxWholeStageTransformerSuite { // The computing is combined into one single whole stage transformer. val wholeStages = plan.collect { case wst: WholeStageTransformer => wst } - if (SparkShimLoader.getSparkVersion.startsWith("3.2.")) { + if (isSparkVersionLE("3.2")) { assert(wholeStages.length == 1) - } else if ( - SparkShimLoader.getSparkVersion.startsWith("3.5.") || - SparkShimLoader.getSparkVersion.startsWith("4.0.") - ) { + } else if ( isSparkVersionGE("3.5")) { assert(wholeStages.length == 5) } else { assert(wholeStages.length == 3) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
