Merge branch 'TRY' of github.com:allwefantasy/streamingpro into TRY

waywtd · Mar 19, 2019 · 3cf4b89 · 3cf4b89
2 parents 9b69242 + 3e44b0b
commit 3cf4b89
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streamingpro-mlsql/src/main/java/org/apache/spark/SparkCoreVersion.scala b/streamingpro-mlsql/src/main/java/org/apache/spark/SparkCoreVersion.scala
@@ -55,7 +55,7 @@ object SparkCoreVersion {
 
 object CarbonCoreVersion {
   def coreCompatibility(version: String, exactVersion: String) = {
-    val vs = Seq(Core_2_2_x, Core_2_3_2).map(f => f.coreVersion).toSet
+    val vs = Seq(Core_2_2_x, Core_2_3_1).map(f => f.coreVersion).toSet
     vs.contains(version) || vs.contains(exactVersion)
   }
 }