Skip to content
This repository has been archived by the owner on Sep 18, 2023. It is now read-only.

Commit

Permalink
[NSE-759] Add spark 3.1.2 & 3.1.3 as supported versions for 3.1.1 shi…
Browse files Browse the repository at this point in the history
…m layer (#760)

With this patch, the runtime checking for spark 3.1.2 & 3.1.3 will also pass.
  • Loading branch information
PHILO-HE authored Mar 10, 2022
1 parent 5f7d7b6 commit 45c5362
Showing 1 changed file with 7 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,13 @@ package com.intel.oap.sql.shims.spark311
import com.intel.oap.sql.shims.{SparkShims, SparkShimDescriptor}

object SparkShimProvider {
val DESCRIPTOR = SparkShimDescriptor(3, 1, 1)
val DESCRIPTOR_STRINGS = Seq(s"$DESCRIPTOR")
// The shim layer for spark 3.1.1 is also workable for 3.1.2 & 3.1.3.
val SPARK311_DESCRIPTOR = SparkShimDescriptor(3, 1, 1)
val SPARK312_DESCRIPTOR = SparkShimDescriptor(3, 1, 2)
val SPARK313_DESCRIPTOR = SparkShimDescriptor(3, 1, 3)
val DESCRIPTOR_STRINGS =
Seq(s"$SPARK311_DESCRIPTOR", s"$SPARK312_DESCRIPTOR", s"$SPARK313_DESCRIPTOR")
val DESCRIPTOR = SPARK311_DESCRIPTOR
}

class SparkShimProvider extends com.intel.oap.sql.shims.SparkShimProvider {
Expand Down

0 comments on commit 45c5362

Please sign in to comment.