diff --git a/.github/workflows/backend.yml b/.github/workflows/backend.yml
index 0dd2dce91..97ef214cb 100644
--- a/.github/workflows/backend.yml
+++ b/.github/workflows/backend.yml
@@ -40,11 +40,11 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v2
-      - name: Set up JDK 11
+      - name: Set up JDK 17
         uses: actions/setup-java@v2
         with:
-          java-version:  11
-          distribution: 'adopt'      
+          java-version:  17
+          distribution: 'temurin'
       - name: Install Protoc
         run: sudo apt install -y protobuf-compiler
       - uses: actions/cache@v4
diff --git a/.github/workflows/codeql.yml b/.github/workflows/codeql.yml
index 55e351ffb..6ffd81c94 100644
--- a/.github/workflows/codeql.yml
+++ b/.github/workflows/codeql.yml
@@ -36,11 +36,11 @@ jobs:
         uses: actions/checkout@v2
         with:
           submodules: true
-      - name: Set up JDK 11
+      - name: Set up JDK 17
         uses: actions/setup-java@v2
         with:
-          java-version: 11
-          distribution: 'adopt'
+          java-version: 17
+          distribution: 'temurin'
       - name: Install Protoc
         run: sudo apt install -y protobuf-compiler
       - uses: actions/cache@v4
diff --git a/.github/workflows/documentation.yml b/.github/workflows/documentation.yml
index b2ebba156..b1bf026a9 100644
--- a/.github/workflows/documentation.yml
+++ b/.github/workflows/documentation.yml
@@ -36,11 +36,11 @@ jobs:
       API_KEY: $HOME/gems
     steps:
       - uses: actions/checkout@v2
-      - name: Set up JDK 1.8
+      - name: Set up JDK 17
         uses: actions/setup-java@v2
         with:
-          java-version:  8
-          distribution: 'adopt'
+          java-version:  17
+          distribution: 'temurin'
       - name: Install ruby
         run: |
           sudo apt install -y ruby-full build-essential zlib1g-dev
diff --git a/README.md b/README.md
index 6d80678f3..3e2eec588 100644
--- a/README.md
+++ b/README.md
@@ -81,11 +81,13 @@ source ~/.zshrc
 
 ### Requirements at Runtime
 
-Since Apache Wayang (incubating) is not an execution engine itself but rather manages the execution engines for you, it is important to have the necessary requirements installed.
+Apache Wayang (incubating) relies on external execution engines and Java to function correctly. Below are the updated runtime requirements:
 
-- Apache Wayang supports Java versions 8 and above. However, the Wayang team recommends using Java version 11. Don’t forget to set the `JAVA_HOME` environment variable.
-- You need to install Apache Spark version 3 or higher. Don’t forget to set the `SPARK_HOME` environment variable.
-- You need to install Apache Hadoop version 3 or higher. Don’t forget to set the `HADOOP_HOME` environment variable.
+- **Java 17**: Make sure `JAVA_HOME` is correctly set to your Java 17 installation.
+- **Apache Spark 3.4.4**: Compatible with Scala 2.12. Set the `SPARK_HOME` environment variable.
+- **Apache Hadoop 3+**: Set the `HADOOP_HOME` environment variable.
+
+> 🛠️ **Note:** When using Java 17, you _must_ add JVM flags to allow Wayang and Spark to access internal Java APIs, or you will encounter `IllegalAccessError`. See below.
 
 ### Validating the installation
 
@@ -95,6 +97,26 @@ To execute your first application with Apache Wayang, you need to execute your p
 bin/wayang-submit org.apache.wayang.apps.wordcount.Main java file://$(pwd)/README.md
 ```
 
+### ⚙️ Java 17 Compatibility
+
+When running Wayang applications using Java 17 (especially with Spark), you must add JVM flags to open specific internal Java modules. These flags resolve access issues with `sun.nio.ch.DirectBuffer` and others.
+
+Update your `wayang-submit` (wayang-assembly/target/wayang-1.0.1-SNAPSHOT/bin/wayang-submit) script (or command) with:
+
+```bash
+eval "$RUNNER \
+  --add-exports=java.base/sun.nio.ch=ALL-UNNAMED \
+  --add-opens=java.base/java.nio=ALL-UNNAMED \
+  --add-opens=java.base/java.lang=ALL-UNNAMED \
+  --add-opens=java.base/java.util=ALL-UNNAMED \
+  --add-opens=java.base/java.io=ALL-UNNAMED \
+  --add-opens=java.base/java.lang.reflect=ALL-UNNAMED \
+  --add-opens=java.base/java.util.concurrent=ALL-UNNAMED \
+  --add-opens=java.base/java.net=ALL-UNNAMED \
+  --add-opens=java.base/java.lang.invoke=ALL-UNNAMED \
+  $FLAGS -cp \"${WAYANG_CLASSPATH}\" $CLASS ${ARGS}"
+```
+
 ## Getting Started
 
 Wayang is available via Maven Central. To use it with Maven, include the following code snippet into your POM file:
@@ -128,15 +150,17 @@ In addition, you can obtain the most recent snapshot version of Wayang via Sonat
 ```
 
 ### Prerequisites
-Apache Wayang (incubating) is built with Java 11 and Scala 2.12. However, to run Apache Wayang it is sufficient to have just Java 11 installed. Please also consider that processing platforms employed by Wayang might have further requirements.
+Apache Wayang (incubating) is built with Java 17 and Scala 2.12. However, to run Apache Wayang it is sufficient to have just Java 17 installed. Please also consider that processing platforms employed by Wayang might have further requirements.
 ```
-Java 11
-[Scala 2.12]
+Java 17
+Scala 2.12.17
+Spark 3.4.4, Compatible with Scala 2.12.
+Maven
 ```
 
 > **NOTE:** In windows, you need to define the variable `HADOOP_HOME` with the winutils.exe, an not official option to obtain [this repository](https://github.com/steveloughran/winutils), or you can generate your winutils.exe following the instructions in the repository. Also, you may need to install [msvcr100.dll](https://www.microsoft.com/en-us/download/details.aspx?id=26999)
 
-> **NOTE:** Make sure that the JAVA_HOME environment variable is set correctly to Java 11 as the prerequisite checker script currently supports up to Java 11 and checks the latest version of Java if you have higher version installed. In Linux, it is preferably to use the export JAVA_HOME method inside the project folder. It is also recommended running './mvnw clean install' before opening the project using IntelliJ.
+> **NOTE:** Make sure that the JAVA_HOME environment variable is set correctly to Java 17 as the prerequisite checker script currently supports up to Java 17 and checks the latest version of Java if you have higher version installed. In Linux, it is preferably to use the export JAVA_HOME method inside the project folder. It is also recommended running './mvnw clean install' before opening the project using IntelliJ.
 
 
 ### Building
@@ -152,11 +176,24 @@ If you need to rebuild Wayang, e.g., to use a different Scala version, you can s
     ```
 > **NOTE:** If you receive an error about not finding `MathExBaseVisitor`, then the problem might be that you are trying to build from IntelliJ, without Maven. MathExBaseVisitor is generated code, and a Maven build should generate it automatically.
 
-> **NOTE:** In the current Maven setup, the version of scala is tied to the Java version, you can compile the profile `scala-11` with Java 8 and profile `scala-12` with Java 11.
+> **NOTE:**: In the current Maven setup, Wayang supports Java 17. The default Scala version is 2.12.17, which is compatible with Java 17. Ensure that your Spark distribution is also built with Scala 2.12 (e.g., `spark-3.4.4-bin-hadoop3-scala2.12`).
 
 > **NOTE:** For compiling and testing the code it is required to have Hadoop installed on your machine.
 
 > **NOTE:**  the `standalone` profile to fix Hadoop and Spark versions, so that Wayang apps do not explicitly need to declare the corresponding dependencies.
+
+> **NOTE**: When running applications (e.g., WordCount) with Java 17, you must pass additional flags to allow internal module access:
+
+>--add-exports=java.base/sun.nio.ch=ALL-UNNAMED \
+--add-opens=java.base/java.nio=ALL-UNNAMED \
+--add-opens=java.base/java.lang=ALL-UNNAMED \
+--add-opens=java.base/java.util=ALL-UNNAMED \
+--add-opens=java.base/java.io=ALL-UNNAMED \
+--add-opens=java.base/java.lang.reflect=ALL-UNNAMED \
+--add-opens=java.base/java.util.concurrent=ALL-UNNAMED \
+--add-opens=java.base/java.net=ALL-UNNAMED \
+--add-opens=java.base/java.lang.invoke=ALL-UNNAMED \
+
 >
 > Also, note the `distro` profile, which assembles a binary Wayang distribution.
 To activate these profiles, you need to specify them when running maven, i.e.,
@@ -176,8 +213,8 @@ You can see examples on how to start using Wayang [here](guides/wayang-examples.
 
 ## Built With
 
-* [Java 11](https://www.oracle.com/de/java/technologies/javase/jdk11-archive-downloads.html)
-* [Scala 2.12](https://www.scala-lang.org/download/2.12.0.html)
+* [Java 17](https://www.oracle.com/java/technologies/javase/17-0-14-relnotes.html)
+* [Scala 2.12.17](https://www.scala-lang.org/download/2.12.17.html)
 * [Maven](https://maven.apache.org/)
 
 ## Contributing
diff --git a/guides/tutorial.md b/guides/tutorial.md
index 320b96169..0dfb914ff 100644
--- a/guides/tutorial.md
+++ b/guides/tutorial.md
@@ -63,6 +63,23 @@ To execute the WordCount example with Apache Wayang, you need to execute your pr
 cd wayang-1.0.1-SNAPSHOT
 ./bin/wayang-submit org.apache.wayang.apps.wordcount.Main java file://$(pwd)/README.md
 ```
+##  If you're using Java 17, add the following JVM flags:
+Update your `wayang-submit` (wayang-assembly/target/wayang-1.0.1-SNAPSHOT/bin/wayang-submit) script (or command) with:
+
+```shell 
+eval "$RUNNER \
+  --add-exports=java.base/sun.nio.ch=ALL-UNNAMED \
+  --add-opens=java.base/java.nio=ALL-UNNAMED \
+  --add-opens=java.base/java.lang=ALL-UNNAMED \
+  --add-opens=java.base/java.util=ALL-UNNAMED \
+  --add-opens=java.base/java.io=ALL-UNNAMED \
+  --add-opens=java.base/java.lang.reflect=ALL-UNNAMED \
+  --add-opens=java.base/java.util.concurrent=ALL-UNNAMED \
+  --add-opens=java.base/java.net=ALL-UNNAMED \
+  --add-opens=java.base/java.lang.invoke=ALL-UNNAMED \
+  $FLAGS -cp \"${WAYANG_CLASSPATH}\" $CLASS ${ARGS}"
+```
+
 Then you should be able to see outputs like this:
 
 ![img.png](../images/wordcount_result.png)
diff --git a/pom.xml b/pom.xml
index 54a7efee2..37bdfcfa3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -102,33 +102,33 @@
         <!-- Timestamp for the reproducible builds -->
         <project.build.outputTimestamp>2025-02-04T20:09:34Z</project.build.outputTimestamp>
 
-        <scala.version>2.12.12</scala.version>
+        <scala.version>2.12.17</scala.version>
         <scala.mayor.version>2.12</scala.mayor.version>
-        <spark.version>3.1.2</spark.version>
+        <spark.version>3.4.4</spark.version>
         <flink.version>1.20.0</flink.version>
 
-        <java.version>11</java.version>
-        <source.level>11</source.level>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
-        <maven.compiler.release>11</maven.compiler.release>
+        <java.version>17</java.version>
+        <source.level>17</source.level>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <maven.compiler.release>17</maven.compiler.release>
         <jaxb.version>2.2.11</jaxb.version>
         <java-activation.version>1.1.1</java-activation.version>
         <javax-annotation-api>1.3.2</javax-annotation-api>
 
-        <assertj.version>3.17.2</assertj.version>
-        <commons-io.version>2.5</commons-io.version>
-        <guava.version>19.0</guava.version>
-        <hamcrest.version>1.3</hamcrest.version>
-        <jackson.version>2.10.2</jackson.version>
-        <jacoco.version>0.8.5</jacoco.version>
+        <assertj.version>3.25.3</assertj.version>
+        <commons-io.version>2.15.1</commons-io.version>
+        <guava.version>32.1.3-jre</guava.version>
+        <hamcrest.version>2.2</hamcrest.version>
+        <jackson.version>2.15.4</jackson.version>
+        <jacoco.version>0.8.9</jacoco.version>
         <jodatime.version>2.10.6</jodatime.version>
         <jsonpath.version>2.4.0</jsonpath.version>
-        <junit5.version>5.6.1</junit5.version>
-        <mockito.version>3.5.10</mockito.version>
+        <junit5.version>5.10.2</junit5.version>
+        <mockito.version>5.11.0</mockito.version>
         <mockk.version>1.10.0</mockk.version>
         <external.platforms.scope>provided</external.platforms.scope>
-        <hadoop.version>3.1.2</hadoop.version>
+        <hadoop.version>3.3.6</hadoop.version>
         <!-- To be overridden by individual modules -->
         <java-module-name>org.apache.wayang.default</java-module-name>
         <code.coverage.project.folder>${basedir}/</code.coverage.project.folder>
@@ -286,16 +286,16 @@
 
         <!-- Used to build Java 11+ -->
         <profile>
-            <id>java11</id>
+            <id>java17</id>
             <activation>
-                <jdk>11</jdk>
+                <jdk>17</jdk>
             </activation>
             <properties>
-                <java.version>11</java.version>
-                <source.level>11</source.level>
-                <maven.compiler.source>11</maven.compiler.source>
-                <maven.compiler.target>11</maven.compiler.target>
-                <maven.compiler.release>11</maven.compiler.release>
+                <java.version>17</java.version>
+                <source.level>17</source.level>
+                <maven.compiler.source>17</maven.compiler.source>
+                <maven.compiler.target>17</maven.compiler.target>
+                <maven.compiler.release>17</maven.compiler.release>
                 <jaxb.version>2.2.11</jaxb.version>
                 <java-activation.version>1.1.1</java-activation.version>
                 <javax-annotation-api>1.3.2</javax-annotation-api>
@@ -314,7 +314,7 @@
                                 <configuration>
                                     <rules>
                                         <requireJavaVersion>
-                                            <version>11</version>
+                                            <version>17</version>
                                         </requireJavaVersion>
                                     </rules>
                                 </configuration>
@@ -325,7 +325,7 @@
                         <groupId>org.apache.maven.plugins</groupId>
                         <artifactId>maven-javadoc-plugin</artifactId>
                         <configuration>
-                            <source>11</source>
+                            <source>17</source>
                             <detectJavaApiLink>false</detectJavaApiLink>
                         </configuration>
                     </plugin>
@@ -393,7 +393,7 @@
                         <plugin>
                             <groupId>net.alchim31.maven</groupId>
                             <artifactId>scala-maven-plugin</artifactId>
-                            <version>4.8.1</version>
+                            <version>4.9.5</version>
                             <executions>
                                 <execution>
                                     <id>compile-scala</id>
@@ -447,9 +447,9 @@
                 </file>
             </activation>
             <properties>
-                <scala.version>2.12.12</scala.version>
+                <scala.version>2.12.17</scala.version>
                 <scala.mayor.version>2.12</scala.mayor.version>
-                <spark.version>3.1.2</spark.version>
+                <spark.version>3.4.4</spark.version>
             </properties>
             <build>
                 <plugins>
@@ -555,7 +555,7 @@
                 </file>
             </activation>
             <properties>
-                <antlr.version>4.9.1</antlr.version>
+                <antlr.version>4.13.1</antlr.version>
             </properties>
             <build>
                 <pluginManagement>
@@ -775,7 +775,7 @@
             <dependency>
                 <groupId>org.apache.logging.log4j</groupId>
                 <artifactId>log4j-bom</artifactId>
-                <version>2.17.0</version>
+                <version>2.20.0</version>
                 <scope>import</scope>
                 <type>pom</type>
             </dependency>
@@ -959,8 +959,22 @@
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-surefire-plugin</artifactId>
-                    <version>3.0.0-M5</version>
+                    <version>3.0.0</version>
                     <configuration>
+                        <argLine>
+                            --add-exports=java.base/sun.nio.ch=ALL-UNNAMED
+                            --add-exports=java.base/jdk.internal.misc=ALL-UNNAMED
+                            --add-opens=java.base/java.nio=ALL-UNNAMED
+                            --add-opens=java.base/sun.nio.ch=ALL-UNNAMED
+                            --add-opens=java.base/java.lang=ALL-UNNAMED
+                            --add-opens=java.base/java.util=ALL-UNNAMED
+                            --add-opens=java.base/java.io=ALL-UNNAMED
+                            --add-opens=java.base/java.lang.reflect=ALL-UNNAMED
+                            --add-opens=java.base/sun.reflect.annotation=ALL-UNNAMED
+                            --add-opens=java.base/java.util.concurrent=ALL-UNNAMED
+                            --add-opens=java.base/java.net=ALL-UNNAMED
+                            --add-opens=java.base/java.lang.invoke=ALL-UNNAMED
+                        </argLine>
                         <useSystemClassLoader>false</useSystemClassLoader>
                     </configuration>
                 </plugin>
@@ -1242,7 +1256,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-enforcer-plugin</artifactId>
-                <version>3.0.0</version>
+                <version>3.0.0-M3</version>
                 <executions>
                     <execution>
                         <id>enforce-maven-version</id>
@@ -1263,7 +1277,7 @@
             <plugin>
                 <groupId>org.jacoco</groupId>
                 <artifactId>jacoco-maven-plugin</artifactId>
-                <version>0.8.3</version>
+                <version>0.8.9</version>
                 <executions>
                     <execution>
                         <id>coverage-initialize</id>
diff --git a/src/main/script/prerequisiteCheck.groovy b/src/main/script/prerequisiteCheck.groovy
index a076b649a..d3d561695 100644
--- a/src/main/script/prerequisiteCheck.groovy
+++ b/src/main/script/prerequisiteCheck.groovy
@@ -190,7 +190,7 @@ if (os == "windows") {
 // profiles.
 /////////////////////////////////////////////////////
 
-checkJavaVersion("1.8", "11")
+checkJavaVersion("1.8", "17")
 
 // Check if hadoop is available
 // It seems that this is only required on Windows systems.
diff --git a/wayang-api/wayang-api-json/pom.xml b/wayang-api/wayang-api-json/pom.xml
index bb31dd916..064de548b 100644
--- a/wayang-api/wayang-api-json/pom.xml
+++ b/wayang-api/wayang-api-json/pom.xml
@@ -34,10 +34,10 @@
 
   <properties>
     <java-module-name>org.apache.wayang.api.json</java-module-name>
-    <maven.compiler.source>1.8</maven.compiler.source>
-    <maven.compiler.target>1.8</maven.compiler.target>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
     <encoding>UTF-8</encoding>
-    <scala.version>2.12.10</scala.version>
+    <scala.version>2.12.17</scala.version>
     <scala.compat.version>2.12</scala.compat.version>
     <spec2.version>4.2.0</spec2.version>
   </properties>
@@ -125,7 +125,7 @@
     <dependency>
       <groupId>com.fasterxml.jackson.module</groupId>
       <artifactId>jackson-module-scala_2.12</artifactId>
-      <version>2.13.1</version>
+      <version>2.15.4</version>
     </dependency>
 
 
diff --git a/wayang-api/wayang-api-scala-java/pom.xml b/wayang-api/wayang-api-scala-java/pom.xml
index 6f57caa35..7bcf9b60f 100644
--- a/wayang-api/wayang-api-scala-java/pom.xml
+++ b/wayang-api/wayang-api-scala-java/pom.xml
@@ -34,7 +34,7 @@
 
     <properties>
         <java-module-name>org.apache.wayang.api</java-module-name>
-        <tensorflow.version>1.0.0-rc.2</tensorflow.version>
+        <tensorflow.version>1.0.0</tensorflow.version>
     </properties>
 
     <dependencyManagement>
@@ -131,7 +131,7 @@
         <dependency>
           <groupId>io.netty</groupId>
           <artifactId>netty-all</artifactId>
-          <version>4.1.45.Final</version>
+          <version>4.1.89.Final</version>
         </dependency>
         <dependency>
           <groupId>com.google.protobuf</groupId>
@@ -141,6 +141,7 @@
          <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
+            <version>2.15.4</version>
         </dependency>
         <dependency>
             <groupId>com.fasterxml.jackson.module</groupId>
diff --git a/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala b/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala
index 2514f09ee..da2babc66 100644
--- a/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala
+++ b/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala
@@ -35,8 +35,8 @@ import scala.language.implicitConversions
 import scala.reflect.ClassTag
 
 /**
-  * Provides implicits for the basic Wayang API.
-  */
+ * Provides implicits for the basic Wayang API.
+ */
 /**
  * TODO: add the documentation in the implicit of org.apache.wayang.api
  * labels: documentation,todo
@@ -151,4 +151,4 @@ package object api {
   implicit def elevateRecordDataQuanta(dataQuanta: DataQuanta[Record]): RecordDataQuanta =
     new RecordDataQuanta(dataQuanta)
 
-}
+}
\ No newline at end of file
diff --git a/wayang-applications/pom.xml b/wayang-applications/pom.xml
index 57477baff..f51482982 100644
--- a/wayang-applications/pom.xml
+++ b/wayang-applications/pom.xml
@@ -38,23 +38,23 @@
         <DATA_REPO_002>https://kamir.solidcommunity.net/public/ecolytiq-sustainability-profile</DATA_REPO_002>
         <DIST_WAYANG_HOME>${project.basedir}/../wayang-assembly/target/apache-wayang-assembly-0.7.1-incubating-dist/wayang-0.7.1</DIST_WAYANG_HOME>
 
-        <spark.version>3.5.0</spark.version>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <spark.version>3.4.4</spark.version>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
 
         <!-- We also specify the file encoding of our source files, to avoid a warning -->
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-        <assertj.version>3.17.2</assertj.version>
-        <commons-io.version>2.5</commons-io.version>
-        <guava.version>19.0</guava.version>
-        <hamcrest.version>1.3</hamcrest.version>
-        <jackson.version>2.10.2</jackson.version>
-        <jacoco.version>0.8.5</jacoco.version>
+        <assertj.version>3.25.3</assertj.version>
+        <commons-io.version>2.15.1</commons-io.version>
+        <guava.version>32.1.3-jre</guava.version>
+        <hamcrest.version>2.2</hamcrest.version>
+        <jackson.version>2.15.4</jackson.version>
+        <jacoco.version>0.8.9</jacoco.version>
         <jodatime.version>2.10.6</jodatime.version>
         <jsonpath.version>2.4.0</jsonpath.version>
-        <junit5.version>5.6.1</junit5.version>
-        <mockito.version>3.5.10</mockito.version>
+        <junit5.version>5.10.2</junit5.version>
+        <mockito.version>5.11.0</mockito.version>
     </properties>
 
     <dependencies>
@@ -92,12 +92,12 @@
         <dependency>
             <groupId>org.scala-lang</groupId>
             <artifactId>scala-library</artifactId>
-            <version>2.12.0</version>
+            <version>2.12.17</version>
         </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-simple</artifactId>
-            <version>1.7.13</version>
+            <version>2.0.6</version>
         </dependency>
 
         <dependency>
diff --git a/wayang-benchmark/pom.xml b/wayang-benchmark/pom.xml
index ff0516aba..574dd3f3a 100644
--- a/wayang-benchmark/pom.xml
+++ b/wayang-benchmark/pom.xml
@@ -67,17 +67,17 @@
     <dependency>
       <groupId>org.apache.hadoop</groupId>
       <artifactId>hadoop-aws</artifactId>
-      <version>3.1.2</version>
+      <version>3.3.6</version>
     </dependency>
     <dependency>
         <groupId>org.apache.hadoop</groupId>
         <artifactId>hadoop-common</artifactId>
-        <version>3.2.4</version>
+        <version>3.3.6</version>
     </dependency>
     <dependency>
         <groupId>org.apache.hadoop</groupId>
         <artifactId>hadoop-client</artifactId>
-        <version>3.1.2</version>
+        <version>3.3.6</version>
     </dependency>
     <dependency>
       <groupId>org.apache.wayang</groupId>
diff --git a/wayang-benchmark/src/main/java/org/apache/wayang/apps/pi/PiEstimation.java b/wayang-benchmark/src/main/java/org/apache/wayang/apps/pi/PiEstimation.java
new file mode 100644
index 000000000..3f7b511f2
--- /dev/null
+++ b/wayang-benchmark/src/main/java/org/apache/wayang/apps/pi/PiEstimation.java
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.wayang.apps.pi;
+
+
+
+import org.apache.wayang.api.JavaPlanBuilder;
+import org.apache.wayang.core.api.WayangContext;
+import org.apache.wayang.core.api.Configuration;
+import org.apache.wayang.java.Java;
+import org.apache.wayang.spark.Spark;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ThreadLocalRandom;
+
+public class PiEstimation {
+    public static void main(String[] args) {
+        try {
+            if (args.length == 0) {
+                System.err.print("Usage: <platform1>[,<platform2>]* <input file URL>");
+                System.exit(1);
+            }
+
+
+
+            int slices = (args.length > 1) ? Integer.parseInt(args[1]) : 2;
+            int n = 100000 * slices; // Total points
+
+            var wayangContext = new WayangContext(new Configuration());
+            for (String platform : args[0].split(",")) {
+                switch (platform) {
+                    case "java":
+                        wayangContext.register(Java.basicPlugin());
+                        break;
+                    case "spark":
+                        wayangContext.register(Spark.basicPlugin());
+                        break;
+                    default:
+                        System.err.format("Unknown platform: \"%s\"\n", platform);
+                        System.exit(3);
+                        return;
+                }
+            }
+
+            var planBuilder = new JavaPlanBuilder(wayangContext)
+                    .withJobName("Wayang Pi Estimation");
+
+            // Create dataset of numbers from 0 to n
+            List<Integer> numbers = new ArrayList<>();
+            for (int i = 0; i < n; i++) {
+                numbers.add(i);
+            }
+
+            // Wayang data pipeline
+            long count = planBuilder
+                    .loadCollection(numbers)
+                    .map(i -> {
+                        double x = ThreadLocalRandom.current().nextDouble(-1, 1);
+                        double y = ThreadLocalRandom.current().nextDouble(-1, 1);
+                        return (x * x + y * y <= 1) ? 1 : 0;
+                    })
+                    .reduce(Integer::sum)
+                    .collect()
+                    .iterator().next();
+
+            // Estimate Pi
+            double pi = 4.0 * count / n;
+            System.out.println("Pi is roughly: " + pi);
+
+        } catch (NumberFormatException e) {
+            System.err.println("Invalid number format for slices. Please provide an integer.");
+        } catch (IllegalArgumentException e) {
+            System.err.println(e.getMessage());
+        } catch (Exception e) {
+            System.err.println("Unexpected error occurred: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file
diff --git a/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/LogisticRegressionModel.java b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/LogisticRegressionModel.java
new file mode 100644
index 000000000..fb1f961e3
--- /dev/null
+++ b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/LogisticRegressionModel.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.wayang.basic.model;
+
+
+
+
+public interface LogisticRegressionModel extends Model {
+    // No extra methods for now — predictions handled via SparkMLModel
+}
diff --git a/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LogisticRegressionOperator.java b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LogisticRegressionOperator.java
new file mode 100644
index 000000000..9f07841a1
--- /dev/null
+++ b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LogisticRegressionOperator.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.wayang.basic.operators;
+
+
+import org.apache.wayang.basic.model.LogisticRegressionModel;
+import org.apache.wayang.core.api.Configuration;
+import org.apache.wayang.core.optimizer.cardinality.CardinalityEstimator;
+import org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator;
+import org.apache.wayang.core.types.DataSetType;
+
+import java.util.Optional;
+
+public class LogisticRegressionOperator extends BinaryToUnaryOperator<double[], Double, LogisticRegressionModel> {
+
+    protected boolean fitIntercept;
+
+    public LogisticRegressionOperator(boolean fitIntercept) {
+        super(
+                DataSetType.createDefaultUnchecked(double[].class),
+                DataSetType.createDefaultUnchecked(Double.class),
+                DataSetType.createDefaultUnchecked(LogisticRegressionModel.class),
+                false
+        );
+        this.fitIntercept = fitIntercept;
+    }
+
+    public LogisticRegressionOperator(LogisticRegressionOperator that) {
+        super(that);
+        this.fitIntercept = that.fitIntercept;
+    }
+
+    public boolean getFitIntercept() {
+        return this.fitIntercept;
+    }
+
+    @Override
+    public Optional<CardinalityEstimator> createCardinalityEstimator(int outputIndex, Configuration configuration) {
+        return super.createCardinalityEstimator(outputIndex, configuration);
+    }
+}
diff --git a/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java
index 869d5f710..7a337c802 100644
--- a/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java
+++ b/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java
@@ -35,4 +35,7 @@ public static PredictOperator<double[], Double> linearRegression() {
     public static PredictOperator<double[], Integer> decisionTreeClassification() {
         return new PredictOperator<>(new TypeReference<double[]>() {}, new TypeReference<Integer>() {});
     }
+    public static PredictOperator<double[], Double> logisticRegression() {
+        return new PredictOperator<>(new TypeReference<double[]>() {}, new TypeReference<Double>() {});
+    }
 }
diff --git a/wayang-commons/wayang-core/pom.xml b/wayang-commons/wayang-core/pom.xml
index 348876dde..784a54187 100644
--- a/wayang-commons/wayang-core/pom.xml
+++ b/wayang-commons/wayang-core/pom.xml
@@ -84,7 +84,7 @@
         <dependency>
             <groupId>org.antlr</groupId>
             <artifactId>antlr4-runtime</artifactId>
-            <version>4.9.1</version>
+            <version>4.13.1</version>
         </dependency>
         <dependency>
             <groupId>org.apache.logging.log4j</groupId>
@@ -99,9 +99,20 @@
             <artifactId>wayang-utils-profile-db</artifactId>
             <version>1.0.1-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>2.15.4</version>
+        </dependency>
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
+            <version>2.15.4</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-annotations</artifactId>
+            <version>2.15.4</version>
         </dependency>
         <dependency>
             <groupId>com.amazonaws</groupId>
diff --git a/wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java b/wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java
index f9cfd4d1d..1a5bed5fd 100644
--- a/wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java
+++ b/wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java
@@ -18,7 +18,7 @@
 
 package org.apache.wayang.core.util;
 
-import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.wayang.core.api.exception.WayangException;
 import org.apache.wayang.core.plan.executionplan.ExecutionPlan;
 import org.apache.wayang.core.plan.wayangplan.WayangPlan;
diff --git a/wayang-commons/wayang-utils-profile-db/pom.xml b/wayang-commons/wayang-utils-profile-db/pom.xml
index 47f3d76be..9368364bf 100644
--- a/wayang-commons/wayang-utils-profile-db/pom.xml
+++ b/wayang-commons/wayang-utils-profile-db/pom.xml
@@ -38,4 +38,5 @@
     </dependencies>
 
 
+
 </project>
diff --git a/wayang-ml4all/pom.xml b/wayang-ml4all/pom.xml
index 17897da43..e0737f54c 100644
--- a/wayang-ml4all/pom.xml
+++ b/wayang-ml4all/pom.xml
@@ -77,7 +77,7 @@
         <dependency>
             <groupId>org.apache.spark</groupId>
             <artifactId>spark-core_2.12</artifactId>
-            <version>3.3.3</version>
+            <version>3.4.4</version>
         </dependency>
         <dependency>
           <groupId>org.apache.spark</groupId>
@@ -97,7 +97,7 @@
         <dependency>
             <groupId>org.scala-lang</groupId>
             <artifactId>scala-library</artifactId>
-            <version>2.12.12</version>
+            <version>2.12.17</version>
         </dependency>
     </dependencies>
 
diff --git a/wayang-platforms/wayang-java/pom.xml b/wayang-platforms/wayang-java/pom.xml
index ae2c0c74d..a0405e971 100644
--- a/wayang-platforms/wayang-java/pom.xml
+++ b/wayang-platforms/wayang-java/pom.xml
@@ -71,18 +71,18 @@
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>
-            <version>1.7.36</version>
+            <version>2.0.6</version>
         </dependency>
         <dependency>
             <groupId>org.apache.logging.log4j</groupId>
             <artifactId>log4j-slf4j-impl</artifactId>
-            <version>2.17.2</version>
+            <version>2.20.0</version>
         </dependency>
         <!-- Mockito for mocking -->
         <dependency>
             <groupId>org.mockito</groupId>
             <artifactId>mockito-core</artifactId>
-            <version>4.5.1</version>
+            <version>5.11.0</version>
             <scope>test</scope>
         </dependency>
     </dependencies>
diff --git a/wayang-platforms/wayang-spark/pom.xml b/wayang-platforms/wayang-spark/pom.xml
index 7cb6a6a48..36a154c1d 100644
--- a/wayang-platforms/wayang-spark/pom.xml
+++ b/wayang-platforms/wayang-spark/pom.xml
@@ -59,17 +59,17 @@
             <groupId>org.xerial.snappy</groupId>
             <artifactId>snappy-java</artifactId>
             <version>1.1.10.4</version>
-            <scope>${external.platforms.scope}</scope>
+            <scope>compile</scope>
         </dependency>
         <dependency>
             <groupId>org.apache.hadoop</groupId>
             <artifactId>hadoop-common</artifactId>
-            <version>3.4.0</version>
+            <version>3.3.6</version>
         </dependency>
         <dependency>
             <groupId>org.apache.hadoop</groupId>
             <artifactId>hadoop-client</artifactId>
-            <version>2.7.7</version>
+            <version>3.3.6</version>
         </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
@@ -79,7 +79,7 @@
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-core_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
           <exclusions>
             <exclusion>
               <groupId>org.xerial.snappy</groupId>
@@ -90,12 +90,17 @@
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-graphx_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.spark</groupId>
+            <artifactId>spark-sql_2.12</artifactId>
+            <version>3.4.4</version>
         </dependency>
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-mllib_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
         </dependency>
         <!--Error of ArrayIndexOutOfBoundsException-->
         <dependency>
@@ -108,7 +113,12 @@
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
             <!--version>2.15.4</version-->
-            <version>2.10.0</version>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.antlr</groupId>
+            <artifactId>antlr4-runtime</artifactId>
+            <version>4.8</version>
         </dependency>
 
     </dependencies>
diff --git a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java
index b884acf95..f22f2f3b5 100644
--- a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java
+++ b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java
@@ -73,6 +73,7 @@ public class Mappings {
             new LinearRegressionMapping(),
             new DecisionTreeClassificationMapping(),
             new ModelTransformMapping(),
+            new LogisticRegressionMapping(),
             new PredictMapping()
     );
 
diff --git a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/LogisticRegressionMapping.java b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/LogisticRegressionMapping.java
new file mode 100644
index 000000000..5a5d53af9
--- /dev/null
+++ b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/LogisticRegressionMapping.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+
+package org.apache.wayang.spark.mapping.ml;
+
+import org.apache.wayang.basic.operators.LogisticRegressionOperator;
+import org.apache.wayang.core.mapping.*;
+import org.apache.wayang.spark.operators.ml.SparkLogisticRegressionOperator;
+import org.apache.wayang.spark.platform.SparkPlatform;
+
+import java.util.Collection;
+import java.util.Collections;
+
+/**
+ * Mapping from {@link LogisticRegressionOperator} to {@link SparkLogisticRegressionOperator}.
+ */
+@SuppressWarnings("unchecked")
+public class LogisticRegressionMapping implements Mapping {
+
+    @Override
+    public Collection<PlanTransformation> getTransformations() {
+        return Collections.singleton(new PlanTransformation(
+                this.createSubplanPattern(),
+                this.createReplacementSubplanFactory(),
+                SparkPlatform.getInstance()
+        ));
+    }
+
+    private SubplanPattern createSubplanPattern() {
+        final OperatorPattern operatorPattern = new OperatorPattern(
+                "logisticRegression", new LogisticRegressionOperator(true), false
+        );
+        return SubplanPattern.createSingleton(operatorPattern);
+    }
+
+    private ReplacementSubplanFactory createReplacementSubplanFactory() {
+        return new ReplacementSubplanFactory.OfSingleOperators<LogisticRegressionOperator>(
+                (matchedOperator, epoch) -> new SparkLogisticRegressionOperator(matchedOperator).at(epoch)
+        );
+    }
+}
diff --git a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java
index 25212bef9..ce84f78d0 100644
--- a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java
+++ b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java
@@ -284,4 +284,4 @@ public List<V> apply(scala.collection.Iterator<V> iterator) {
             list.add(element);
         return list;
     }
-}
+}
\ No newline at end of file
diff --git a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java
index 3169da7bb..614734063 100644
--- a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java
+++ b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java
@@ -230,4 +230,4 @@ public List<V> apply(scala.collection.Iterator<V> iterator) {
         }
         return list;
     }
-}
+}
\ No newline at end of file
diff --git a/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLogisticRegressionOperator.java b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLogisticRegressionOperator.java
new file mode 100644
index 000000000..3d47362d0
--- /dev/null
+++ b/wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLogisticRegressionOperator.java
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.wayang.spark.operators.ml;
+
+
+
+import org.apache.spark.api.java.JavaRDD;
+import org.apache.spark.api.java.JavaPairRDD;
+import org.apache.spark.ml.classification.LogisticRegression;
+import org.apache.spark.ml.classification.LogisticRegressionModel;
+import org.apache.spark.ml.linalg.Vector;
+import org.apache.spark.ml.linalg.VectorUDT;
+import org.apache.spark.ml.linalg.Vectors;
+import org.apache.spark.sql.*;
+import org.apache.spark.sql.types.*;
+import org.apache.wayang.basic.data.Tuple2;
+import org.apache.wayang.basic.operators.LogisticRegressionOperator;
+import org.apache.wayang.core.optimizer.OptimizationContext;
+import org.apache.wayang.core.plan.wayangplan.ExecutionOperator;
+import org.apache.wayang.core.platform.ChannelDescriptor;
+import org.apache.wayang.core.platform.ChannelInstance;
+import org.apache.wayang.core.platform.lineage.ExecutionLineageNode;
+import org.apache.wayang.core.util.Tuple;
+import org.apache.wayang.java.channels.CollectionChannel;
+import org.apache.wayang.spark.channels.RddChannel;
+import org.apache.wayang.spark.execution.SparkExecutor;
+import org.apache.wayang.spark.model.SparkMLModel;
+import org.apache.wayang.spark.operators.SparkExecutionOperator;
+
+import java.util.*;
+
+public class SparkLogisticRegressionOperator extends LogisticRegressionOperator implements SparkExecutionOperator {
+
+    private static final StructType SCHEMA = DataTypes.createStructType(new StructField[]{
+            DataTypes.createStructField(Attr.LABEL, DataTypes.DoubleType, false),
+            DataTypes.createStructField(Attr.FEATURES, new VectorUDT(), false)
+    });
+
+    private static Dataset<Row> convertToDataFrame(JavaRDD<double[]> features, JavaRDD<Double> labels) {
+        JavaPairRDD<double[], Double> zipped = features.zip(labels);
+        JavaRDD<Row> rowRDD = zipped.map(e -> RowFactory.create(e._2, Vectors.dense(e._1)));
+        return SparkSession.builder().getOrCreate().createDataFrame(rowRDD, SCHEMA);
+    }
+
+    public SparkLogisticRegressionOperator(boolean fitIntercept) {
+        super(fitIntercept);
+    }
+
+    public SparkLogisticRegressionOperator(LogisticRegressionOperator that) {
+        super(that);
+    }
+
+    @Override
+    public List<ChannelDescriptor> getSupportedInputChannels(int index) {
+        return Arrays.asList(RddChannel.UNCACHED_DESCRIPTOR, RddChannel.CACHED_DESCRIPTOR);
+    }
+
+    @Override
+    public List<ChannelDescriptor> getSupportedOutputChannels(int index) {
+        return Collections.singletonList(CollectionChannel.DESCRIPTOR);
+    }
+
+    @Override
+    public Tuple<Collection<ExecutionLineageNode>, Collection<ChannelInstance>> evaluate(
+            ChannelInstance[] inputs,
+            ChannelInstance[] outputs,
+            SparkExecutor sparkExecutor,
+            OptimizationContext.OperatorContext operatorContext) {
+
+        RddChannel.Instance featuresInput = (RddChannel.Instance) inputs[0];
+        RddChannel.Instance labelsInput = (RddChannel.Instance) inputs[1];
+        CollectionChannel.Instance output = (CollectionChannel.Instance) outputs[0];
+
+        JavaRDD<double[]> features = featuresInput.provideRdd();
+        JavaRDD<Double> labels = labelsInput.provideRdd();
+
+        Dataset<Row> df = convertToDataFrame(features, labels);
+
+        LogisticRegression lr = new LogisticRegression()
+                .setFitIntercept(this.fitIntercept)
+                .setLabelCol(Attr.LABEL)
+                .setFeaturesCol(Attr.FEATURES)
+                .setPredictionCol(Attr.PREDICTION);
+
+        LogisticRegressionModel model = lr.fit(df);
+        output.accept(Collections.singletonList(new Model(model)));
+
+        return ExecutionOperator.modelLazyExecution(inputs, outputs, operatorContext);
+    }
+
+    @Override
+    public boolean containsAction() {
+        return false;
+    }
+
+    public static class Model implements org.apache.wayang.basic.model.LogisticRegressionModel, SparkMLModel<double[], Double> {
+
+        private static final StructType PREDICT_SCHEMA = DataTypes.createStructType(new StructField[]{
+                DataTypes.createStructField(Attr.FEATURES, new VectorUDT(), false)
+        });
+
+        private final LogisticRegressionModel model;
+
+        public Model(LogisticRegressionModel model) {
+            this.model = model;
+        }
+
+        private static Dataset<Row> convertToDataFrame(JavaRDD<double[]> features) {
+            JavaRDD<Row> rows = features.map(f -> RowFactory.create(Vectors.dense(f)));
+            return SparkSession.builder().getOrCreate().createDataFrame(rows, PREDICT_SCHEMA);
+        }
+
+        @Override
+        public JavaRDD<Tuple2<double[], Double>> transform(JavaRDD<double[]> input) {
+            Dataset<Row> df = convertToDataFrame(input);
+            Dataset<Row> result = model.transform(df);
+            return result.toJavaRDD().map(row ->
+                    new Tuple2<>(row.getAs(Attr.FEATURES), row.<Double>getAs(Attr.PREDICTION)));
+        }
+
+        @Override
+        public JavaRDD<Double> predict(JavaRDD<double[]> input) {
+            Dataset<Row> df = convertToDataFrame(input);
+            Dataset<Row> result = model.transform(df);
+            return result.toJavaRDD().map(row -> row.<Double>getAs(Attr.PREDICTION));
+        }
+    }
+}
diff --git a/wayang-platforms/wayang-tensorflow/pom.xml b/wayang-platforms/wayang-tensorflow/pom.xml
index 5d8be0968..c6faec028 100644
--- a/wayang-platforms/wayang-tensorflow/pom.xml
+++ b/wayang-platforms/wayang-tensorflow/pom.xml
@@ -34,9 +34,9 @@
     </description>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
-        <tensorflow.version>1.0.0-rc.2</tensorflow.version>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <tensorflow.version>1.0.0</tensorflow.version>
     </properties>
 
     <dependencies>
diff --git a/wayang-profiler/pom.xml b/wayang-profiler/pom.xml
index bd44e442c..e32b07ada 100644
--- a/wayang-profiler/pom.xml
+++ b/wayang-profiler/pom.xml
@@ -94,5 +94,11 @@
           <artifactId>spark-mllib_2.12</artifactId>
           <version>${spark.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.12.0</version>
+        </dependency>
+
     </dependencies>
 </project>
diff --git a/wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java b/wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java
index f72b37da3..9373b6672 100644
--- a/wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java
+++ b/wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java
@@ -18,7 +18,7 @@
 
 package org.apache.wayang.profiler.hardware;
 
-import org.apache.commons.lang.Validate;
+import org.apache.commons.lang3.Validate;
 import org.apache.wayang.core.util.Formats;
 import org.apache.wayang.core.util.fs.FileSystem;
 import org.apache.wayang.core.util.fs.FileSystems;
diff --git a/wayang-tests-integration/pom.xml b/wayang-tests-integration/pom.xml
index d498b19e0..d6509e345 100644
--- a/wayang-tests-integration/pom.xml
+++ b/wayang-tests-integration/pom.xml
@@ -91,17 +91,17 @@
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-core_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
         </dependency>
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-graphx_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
         </dependency>
         <dependency>
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-mllib_2.12</artifactId>
-          <version>${spark.version}</version>
+          <version>3.4.4</version>
         </dependency>
 
         <!-- depencies of flink -->
@@ -224,13 +224,13 @@
         <dependency>
             <groupId>org.codehaus.janino</groupId>
             <artifactId>janino</artifactId>
-            <version>3.0.16</version>
+            <version>3.1.6</version>
         </dependency>
         <!-- https://mvnrepository.com/artifact/org.codehaus.janino/commons-compiler -->
         <dependency>
             <groupId>org.codehaus.janino</groupId>
             <artifactId>commons-compiler</artifactId>
-            <version>3.0.16</version>
+            <version>3.1.6</version>
         </dependency>
     </dependencies>
 
@@ -263,6 +263,24 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-failsafe-plugin</artifactId>
+                <version>2.22.2</version>
+                <configuration>
+                    <argLine>
+                        --add-exports=java.base/sun.nio.ch=ALL-UNNAMED
+                        --add-opens=java.base/java.nio=ALL-UNNAMED
+                        --add-opens=java.base/sun.nio.ch=ALL-UNNAMED
+                        --add-opens=java.base/java.lang=ALL-UNNAMED
+                        --add-opens=java.base/java.util=ALL-UNNAMED
+                        --add-opens=java.base/java.io=ALL-UNNAMED
+                        --add-opens=java.base/java.lang.reflect=ALL-UNNAMED
+                        --add-exports=java.base/jdk.internal.misc=ALL-UNNAMED
+                        --add-opens=java.base/sun.reflect.annotation=ALL-UNNAMED
+                        --add-opens=java.base/java.util.concurrent=ALL-UNNAMED
+                        --add-opens=java.base/java.net=ALL-UNNAMED
+                        --add-opens=java.base/java.lang.invoke=ALL-UNNAMED
+                    </argLine>
+                    <useSystemClassLoader>false</useSystemClassLoader>
+                </configuration>
                 <executions>
                     <execution>
                         <goals>
@@ -273,10 +291,26 @@
                 </executions>
             </plugin>
 
+
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>
+                <version>3.0.0</version>
                 <configuration>
+                    <argLine>
+                        --add-exports=java.base/sun.nio.ch=ALL-UNNAMED
+                        --add-opens=java.base/java.nio=ALL-UNNAMED
+                        --add-opens=java.base/sun.nio.ch=ALL-UNNAMED
+                        --add-opens=java.base/java.lang=ALL-UNNAMED
+                        --add-opens=java.base/java.util=ALL-UNNAMED
+                        --add-opens=java.base/java.io=ALL-UNNAMED
+                        --add-opens=java.base/java.lang.reflect=ALL-UNNAMED
+                        --add-exports=java.base/jdk.internal.misc=ALL-UNNAMED
+                        --add-opens=java.base/sun.reflect.annotation=ALL-UNNAMED
+                        --add-opens=java.base/java.util.concurrent=ALL-UNNAMED
+                        --add-opens=java.base/java.net=ALL-UNNAMED
+                        --add-opens=java.base/java.lang.invoke=ALL-UNNAMED
+                    </argLine>
                     <useSystemClassLoader>false</useSystemClassLoader>
                     <useFile>false</useFile>
                     <includes>
diff --git a/wayang-tests-integration/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java b/wayang-tests-integration/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java
index ccea3d9f0..ac89bfae9 100644
--- a/wayang-tests-integration/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java
+++ b/wayang-tests-integration/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java
@@ -449,6 +449,50 @@ public void testBroadcasts() {
         Assert.assertEquals(expectedValues, collectedValues);
     }
 
+    @Test
+    public void testLogisticRegressionOperator() {
+        CollectionSource<double[]> xSource = new CollectionSource<>(
+                Arrays.asList(
+                        new double[]{0.0, 1.0},
+                        new double[]{1.0, 0.0},
+                        new double[]{1.0, 1.0},
+                        new double[]{0.0, 0.0}
+                ), double[].class
+        );
+        CollectionSource<Double> ySource = new CollectionSource<>(
+                Arrays.asList(1.0, 1.0, 0.0, 0.0), Double.class
+        );
+
+        xSource.addTargetPlatform(Spark.platform());
+        ySource.addTargetPlatform(Spark.platform());
+
+        LogisticRegressionOperator train = new LogisticRegressionOperator(true);
+        PredictOperator<double[], Double> predict = PredictOperators.logisticRegression();
+
+        List<Double> results = new ArrayList<>();
+        LocalCallbackSink<Double> sink = LocalCallbackSink.createCollectingSink(results, DataSetType.createDefault(Double.class));
+
+        xSource.connectTo(0, train, 0);
+        ySource.connectTo(0, train, 1);
+        train.connectTo(0, predict, 0);
+        xSource.connectTo(0, predict, 1);
+        predict.connectTo(0, sink, 0);
+
+        WayangPlan plan = new WayangPlan(sink);
+
+        WayangContext context = new WayangContext()
+                .with(Spark.basicPlugin())
+                .with(Spark.mlPlugin());
+
+        context.execute(plan);
+
+        Assert.assertEquals(4, results.size());
+        for (double pred : results) {
+            Assert.assertTrue(pred == 0.0 || pred == 1.0);
+        }
+    }
+
+
     @Test
     public void testKMeans() {
         CollectionSource<double[]> collectionSource = new CollectionSource<>(