Check shuffle checksum enabled independently

Chong Gao · Chong Gao · commit 0f914f1203df · 2026-02-02T13:47:23.000+08:00
Signed-off-by: Chong Gao &lt;res_life@163.com&gt;
diff --git a/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/RapidsShuffleInternalManagerBase.scala b/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/RapidsShuffleInternalManagerBase.scala
@@ -1623,14 +1623,14 @@ class RapidsShuffleInternalManagerBase(conf: SparkConf, val isDriver: Boolean)
       if (GpuShuffleEnv.isSparkAuthenticateEnabled) {
         fallThroughReasons += "Spark authentication is enabled"
       }
-      if (GpuShuffleEnv.isRowBasedChecksumEnabled) {
-        fallThroughReasons += "Detected spark.shuffle.checksum.enabled=true. " +
-          "This feature is supported in Spark 4.1+, but is not yet supported by Spark-Rapids."
-      }
     }
     if (rapidsConf.isSqlExplainOnlyEnabled) {
       fallThroughReasons += "Plugin is in explain only mode"
     }
+    if (GpuShuffleEnv.isRowBasedChecksumEnabled) {
+      fallThroughReasons += "Detected spark.shuffle.checksum.enabled=true. " +
+        "This feature is supported in Spark 4.1+, but is not yet supported by Spark-Rapids."
+    }
     if (fallThroughReasons.nonEmpty) {
       logWarning(s"Rapids Shuffle Plugin is falling back to SortShuffleManager " +
           s"because: ${fallThroughReasons.mkString(", ")}")

Original file line number	Diff line number	Diff line change
`@@ -1623,14 +1623,14 @@ class RapidsShuffleInternalManagerBase(conf: SparkConf, val isDriver: Boolean)`
`1623`	`1623`	`if (GpuShuffleEnv.isSparkAuthenticateEnabled) {`
`1624`	`1624`	`fallThroughReasons += "Spark authentication is enabled"`
`1625`	`1625`	`}`
`1626`		`- if (GpuShuffleEnv.isRowBasedChecksumEnabled) {`
`1627`		`- fallThroughReasons += "Detected spark.shuffle.checksum.enabled=true. " +`
`1628`		`- "This feature is supported in Spark 4.1+, but is not yet supported by Spark-Rapids."`
`1629`		`- }`
`1630`	`1626`	`}`
`1631`	`1627`	`if (rapidsConf.isSqlExplainOnlyEnabled) {`
`1632`	`1628`	`fallThroughReasons += "Plugin is in explain only mode"`
`1633`	`1629`	`}`
	`1630`	`+ if (GpuShuffleEnv.isRowBasedChecksumEnabled) {`
	`1631`	`+ fallThroughReasons += "Detected spark.shuffle.checksum.enabled=true. " +`
	`1632`	`+ "This feature is supported in Spark 4.1+, but is not yet supported by Spark-Rapids."`
	`1633`	`+ }`
`1634`	`1634`	`if (fallThroughReasons.nonEmpty) {`
`1635`	`1635`	`logWarning(s"Rapids Shuffle Plugin is falling back to SortShuffleManager " +`
`1636`	`1636`	`s"because: ${fallThroughReasons.mkString(", ")}")`