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);