diff --git a/java/beam/pom.xml b/java/beam/pom.xml
index 80a1d1cfe8..4c94bd1a07 100644
--- a/java/beam/pom.xml
+++ b/java/beam/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <artifactId>hsfs-parent</artifactId>
     <groupId>com.logicalclocks</groupId>
-    <version>3.4.2</version>
+    <version>3.4.3</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/java/flink/pom.xml b/java/flink/pom.xml
index 10f4609bfa..7440d43f11 100644
--- a/java/flink/pom.xml
+++ b/java/flink/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <artifactId>hsfs-parent</artifactId>
     <groupId>com.logicalclocks</groupId>
-    <version>3.4.2</version>
+    <version>3.4.3</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/java/hsfs/pom.xml b/java/hsfs/pom.xml
index a1f8a5faaf..e30afc781e 100644
--- a/java/hsfs/pom.xml
+++ b/java/hsfs/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <artifactId>hsfs-parent</artifactId>
     <groupId>com.logicalclocks</groupId>
-    <version>3.4.2</version>
+    <version>3.4.3</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/java/pom.xml b/java/pom.xml
index cb6ad9737b..bb82b0c4da 100644
--- a/java/pom.xml
+++ b/java/pom.xml
@@ -7,7 +7,7 @@
     <groupId>com.logicalclocks</groupId>
     <artifactId>hsfs-parent</artifactId>
     <packaging>pom</packaging>
-    <version>3.4.2</version>
+    <version>3.4.3</version>
     <modules>
         <module>hsfs</module>
         <module>spark</module>
diff --git a/java/spark/pom.xml b/java/spark/pom.xml
index 7e91dbed29..bd5b2fda86 100644
--- a/java/spark/pom.xml
+++ b/java/spark/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <artifactId>hsfs-parent</artifactId>
         <groupId>com.logicalclocks</groupId>
-        <version>3.4.2</version>
+        <version>3.4.3</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/python/hsfs/version.py b/python/hsfs/version.py
index b9ac0bad5e..6cdffd27f8 100644
--- a/python/hsfs/version.py
+++ b/python/hsfs/version.py
@@ -14,4 +14,4 @@
 #   limitations under the License.
 #
 
-__version__ = "3.4.2"
+__version__ = "3.4.3"
diff --git a/utils/java/pom.xml b/utils/java/pom.xml
index 63aa8dd2dd..b00c2e5823 100644
--- a/utils/java/pom.xml
+++ b/utils/java/pom.xml
@@ -5,7 +5,7 @@
 
     <groupId>com.logicalclocks</groupId>
     <artifactId>hsfs-utils</artifactId>
-    <version>3.4.2</version>
+    <version>3.4.3</version>
 
     <properties>
         <hops.version>3.2.0.0-SNAPSHOT</hops.version>
diff --git a/utils/java/src/main/java/com/logicalclocks/utils/MainClass.java b/utils/java/src/main/java/com/logicalclocks/utils/MainClass.java
index 65d0a7c4ea..c267309145 100644
--- a/utils/java/src/main/java/com/logicalclocks/utils/MainClass.java
+++ b/utils/java/src/main/java/com/logicalclocks/utils/MainClass.java
@@ -79,6 +79,14 @@ public static void main(String[] args) throws Exception {
         .hasArg()
         .build());
 
+    // This option here is used, however it's here to make the deltastreamer job
+    // working with the Hopsworks scheduler which adds the `start_time` option
+    options.addOption(Option.builder("start_time")
+        .argName("start_time")
+        .required(false)
+        .hasArg()
+        .build());
+
     CommandLineParser parser = new DefaultParser();
     CommandLine commandLine = parser.parse(options, args);