getUnityCatalogSparkArtifact

Signed-off-by: Yi Li <yi.li@databricks.com>

Author: yili-db

examples/scala/build.sbt

@@ -162,6 +162,18 @@ def resolveSparkVersion(deltaVersion: String): String = {
   else lookupSparkVersion.apply(getMajorMinor(deltaVersion))
 }
 
+// The OSS Unity Catalog project publishes one Spark connector artifact per Spark major.minor
+// (e.g. unitycatalog-spark_4.1_2.13) and, unlike delta-spark, has no unsuffixed backward-compat
+// variant. So its suffix must track the resolved Spark version -- matching what
+// setup_unitycatalog_main.sh publishes -- rather than `getSparkPackageSuffix`, which is empty for
+// the default Spark version (since `delta-spark_2.13` resolves unsuffixed).
+val getUnityCatalogSparkArtifact = settingKey[String](
+  "Unity Catalog Spark connector artifact base name, suffixed with the resolved Spark major.minor.")
+getUnityCatalogSparkArtifact := {
+  val (sparkMajor, sparkMinor) = getMajorMinor(resolveSparkVersion(getDeltaVersion.value))
+  s"unitycatalog-spark_${sparkMajor}.${sparkMinor}"
+}
+
 def getLibraryDependencies(
     deltaVersion: String,
     deltaArtifactName: String,
@@ -216,7 +228,7 @@ lazy val root = (project in file("."))
       scalaBinaryVersion.value,
       getSupportIceberg.value),
     libraryDependencies ++= Seq(
-      "io.unitycatalog" %% s"unitycatalog-spark${getSparkPackageSuffix.value}" % unityCatalogVersion excludeAll(
+      "io.unitycatalog" %% getUnityCatalogSparkArtifact.value % unityCatalogVersion excludeAll(
         ExclusionRule(organization = "com.fasterxml.jackson.core"),
         ExclusionRule(organization = "com.fasterxml.jackson.module"),
         ExclusionRule(organization = "com.fasterxml.jackson.datatype"),