Use JVM version check in SparkR

Author: HyukjinKwon

R/pkg/R/sparkR.R

@@ -334,6 +334,17 @@ sparkR.session <- function(
     assign(".sparkRsession", sparkSession, envir = .sparkREnv)
   }
 
+  # Check if version number of SparkSession matches version number of SparkR package
+  jvmVersion <- callJMethod(sparkSession, "version")
+  # Remove -SNAPSHOT from jvm versions
+  jvmVersionStrip <- gsub("-preview", "", jvmVersion)
+  rPackageVersion <- paste0(packageVersion("SparkR"))
+
+  if (jvmVersionStrip != rPackageVersion) {
+    warning(paste("Version mismatch between Spark JVM and SparkR package. JVM version was",
+                  jvmVersion, ", while R package version was", rPackageVersion))
+  }
+
   sparkSession
 }