[FSTORE-1062] Materialisation job does not work with new Hopsworks sc… (

#1136)
logicalclocks · Nov 1, 2023 · d0a43b6 · d0a43b6
1 parent 286c644
commit d0a43b6
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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);