Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update MockTaskContext to support new functions added in Spark-4.0 [d…
…atabricks] (#11972) This fixes #11971 . This unblocks the scala_2.13 nightly build jobs. MockTaskContext extends TaskContext in spark-rapids code. Recently additional definitions were added in Spark-4.0's TaskContext. In this PR, we added the missing methods to MockTaskContext.scala file. We are not overriding these methods so that it can compile on all Spark versions. In Spark-4.0, these were added in TaskContext.scala: PR : apache/spark#49413 ``` private[spark] def interruptible(): Boolean private[spark] def pendingInterrupt(threadToInterrupt: Option[Thread], reason: String): Unit private[spark] def createResourceUninterruptibly[T <: Closeable](resourceBuilder: => T): T ``` Signed-off-by: Niranjan Artal <[email protected]> Co-authored-by: Gera Shegalov <[email protected]>
- Loading branch information