Adding main method for LaunchDataIngestionJobCommand for spark-submit command
@@ -25,6 +25,7 @@ import org.apache.pinot.core.util.TlsUtils;
import org.apache.pinot.spi.ingestion.batch.IngestionJobLauncher;
import org.apache.pinot.spi.ingestion.batch.spec.SegmentGenerationJobSpec;
import org.apache.pinot.spi.ingestion.batch.spec.TlsSpec;
+import org.apache.pinot.spi.plugin.PluginManager;
import org.apache.pinot.spi.utils.GroovyTemplateUtils;
import org.apache.pinot.tools.Command;
import org.slf4j.Logger;
@@ -146,4 +147,9 @@ public class LaunchDataIngestionJobCommand extends AbstractBaseAdminCommand impl
public String description() {
return "Launch a data ingestion job.";
}
+
+ public static void main(String[] args) {
+ PluginManager.get().init();
+ new CommandLine(new LaunchDataIngestionJobCommand()).execute(args);
+ }
}
