Adding main method for LaunchDataIngestionJobCommand for spark-submit…

… command (#8168)
apache · Feb 10, 2022 · b404e4a · b404e4a
1 parent 8d867ed
commit b404e4a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ols/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java b/...ols/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java
@@ -25,6 +25,7 @@
 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 String toString() {
   public String description() {
     return "Launch a data ingestion job.";
   }
+
+  public static void main(String[] args) {
+    PluginManager.get().init();
+    new CommandLine(new LaunchDataIngestionJobCommand()).execute(args);
+  }
 }