sriramdas sivasai
07/14/2021, 5:38 PMTrying to create instance for class org.apache.pinot.plugin.ingestion.batch.spark.SparkSegmentGenerationJobRunner
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/api/java/function/VoidFunction
at java.base/java.lang.Class.getDeclaredConstructors0(Native Method)
at java.base/java.lang.Class.privateGetDeclaredConstructors(Class.java:3137)
at java.base/java.lang.Class.getConstructor0(Class.java:3342)
at java.base/java.lang.Class.getConstructor(Class.java:2151)
at org.apache.pinot.spi.plugin.PluginManager.createInstance(PluginManager.java:295)
at org.apache.pinot.spi.plugin.PluginManager.createInstance(PluginManager.java:264)
at org.apache.pinot.spi.plugin.PluginManager.createInstance(PluginManager.java:245)
at org.apache.pinot.spi.ingestion.batch.IngestionJobLauncher.kickoffIngestionJob(IngestionJobLauncher.java:135)
Xiang Fu
Xiang Fu
Xiang Fu
sriramdas sivasai
07/14/2021, 7:04 PMbin/pinot-admin.sh LaunchDataIngestionJob -jobSpecFile /data_ssd/spark-ingestion/spark-ingestion.yml
installed spark. added the SPARK_HOME and spark sbin to pathsriramdas sivasai
07/14/2021, 7:04 PMsriramdas sivasai
07/14/2021, 7:04 PMKulbir Nijjer
07/14/2021, 7:23 PMspark-core_*.jar
is included in <SPARK_HOME>/jars and running spark-submit should set required classpath variables. EMR can also be used if you have a running Spark cluster and subsequently Spark-Submit command you run in Pinot will require changes to master
and deploy-mode
settings accordingly.sriramdas sivasai
07/14/2021, 7:38 PMapachepinot/pinot:latest
. i tried it again and trying to run the examples one.sriramdas sivasai
07/14/2021, 7:40 PMXiang Fu
Xiang Fu
Xiang Fu
sriramdas sivasai
07/14/2021, 7:42 PMXiang Fu