We are trying to implement Sample given here . We have installed Livy and server is running 127.0.0.1:8998.
But when we start ExecuteSparkInteractive processor, it gives following error :
ERROR [Timer-Driven Process Thread-3] o.a.n.p.livy.ExecuteSparkInteractive ExecuteSparkInteractive[id=9a338053-0173-1000-fbe9-e613558ad33b] Spark Session returned an error, sending the output JSON object as the flow file content to failure (after penalizing)
and jobs are now shown in livy server ui. What are we missing? This is our first attempt to implement this.