Convert Spark Submit Job to KNIME Equivalent

KNIME Extensions
,
5

Hi @bjoern.lohrmann and @Iris ,

As you suggested, I am trying to replicate the same thing in “Spark RDD Java Snippet (Source)” node. My node configurations look like this:

image
image1022×682 24.6 KB

After running this, I get the below error:
“ERROR Spark RDD Java Snippet (Source) 3:221:170:182 Execute failed: com.nfpa.demo.SparkAddressGeocoderOutputFormatter (ClassNotFoundException)”

image
image949×166 6.36 KB

Initially, it was giving an error on the class name so I added the jar file to the CDH spark job server location which resolved the issue. The jar file is also in the “Additional Libraries” page in the node.

Could you please help me in resolving this?

Thanks,
Radhika Maheshwari