Updated main dependency versions in pom.xml

- Apache Spark: 2.3.1 --> 2.4.0
- Apache Flink: 1.5.0 --> 1.7.0
- Apache Jena: 3.7.0 --> 3.9.0
- Jena Sparql API: 3.7.0-1 --> 3.9.0-1

Author: patrickwestphal

pom.xml

@@ -67,14 +67,13 @@
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <scala.version>2.11.12</scala.version>
     <scala.binary.version>2.11</scala.binary.version>
-    <sansa.version>0.3.1-SNAPSHOT</sansa.version>
-    <spark.version>2.3.1</spark.version>
-    <flink.version>1.5.0</flink.version>
-    <jena.version>3.7.0</jena.version>
+    <spark.version>2.4.0</spark.version>
+    <flink.version>1.7.0</flink.version>
+    <jena.version>3.9.0</jena.version>
     <sansa.stack.version>0.4.0</sansa.stack.version>
     <sansa.rdf.version>${sansa.stack.version}</sansa.rdf.version>
     <sansa.query.version>${sansa.stack.version}</sansa.query.version>
-    <sansa.owl.version>${sansa.stack.version}</sansa.owl.version>
+    <sansa.owl.version>0.4.1</sansa.owl.version>
     <jsa.subversion>1</jsa.subversion>
     <jsa.version>${jena.version}-${jsa.subversion}</jsa.version>
     <PermGen>64m</PermGen>
@@ -115,7 +114,7 @@
       <dependency>
         <groupId>net.sansa-stack</groupId>
         <artifactId>sansa-owl-spark_${scala.binary.version}</artifactId>
-        <version>${sansa.version}</version>
+        <version>${sansa.owl.version}</version>
       </dependency>
       <!-- Query Layer -->
       <dependency>
@@ -341,6 +340,12 @@
         <artifactId>hadoop-common</artifactId>
         <version>2.9.0</version>
       </dependency>
+
+      <dependency>
+        <groupId>org.apache.commons</groupId>
+        <artifactId>commons-compress</artifactId>
+        <version>1.18</version>
+      </dependency>
     </dependencies>
   </dependencyManagement>
 

sansa-inference-spark/pom.xml

@@ -228,6 +228,10 @@
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-compress</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/rules/plan/PlanExecutorNative.scala

@@ -15,6 +15,7 @@ import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, SubqueryAlias}
 import org.apache.spark.sql.catalyst.plans.{Inner, logical}
 import net.sansa_stack.inference.spark.data.model.{EmptyRDFGraphDataFrame, RDFGraphNative}
 import net.sansa_stack.inference.utils.{Logging, Tuple0}
+import org.apache.spark.sql.catalyst.AliasIdentifier
 
 /**
   * An executor that works on the the native Scala data structures and uses Spark joins, filters etc.
@@ -349,7 +350,7 @@ class PlanExecutorNative(sc: SparkContext) extends PlanExecutor[Jena, RDD[Triple
         projectList.toList
       case logical.Filter(condition, child) =>
         expressionsFor(child)
-      case SubqueryAlias(alias: String, child: LogicalPlan) =>
+      case SubqueryAlias(alias: AliasIdentifier, child: LogicalPlan) =>
         expressionsFor(child)
       case _ =>
         logicalPlan.expressions.toList