Skip to content

Commit

Permalink
Update sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuShuff…
Browse files Browse the repository at this point in the history
…leEnv.scala

Co-authored-by: Gera Shegalov <[email protected]>
  • Loading branch information
zpuller and gerashegalov authored May 25, 2024
1 parent 3a109d4 commit d129d76
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -110,9 +110,9 @@ object GpuShuffleEnv extends Logging {
rapidsShuffleManager.initialize
case _ =>
val rsmLoaderViaShuffleManager = shuffleManager.getClass.getSuperclass.getInterfaces
.collectFirst {
case c if c.getName == classOf[RapidsShuffleManagerLike].getName => c.getClassLoader
}
.collectFirst {
case c if c.getName == classOf[RapidsShuffleManagerLike].getName => c.getClassLoader
}
val rsmLoaderDirect = classOf[RapidsShuffleManagerLike].getClassLoader

throw new IllegalStateException(s"Cannot initialize the RAPIDS Shuffle Manager " +
Expand Down

0 comments on commit d129d76

Please sign in to comment.