Sparkling Water-Deep Learning Energy Forecasting template

[SUDHANSHU KAUSHIK <su...@gmail.com>]

Hi,

I am using Sparkling Water-Deep Learning Energy Forecasting template of
predictionio. I am able to build, train and deploy the engine. But when I
query the engine, I am getting following error :
Cannot call methods on a stopped SparkContext

Stack Trace: java.lang.IllegalStateException: Cannot call methods on a
stopped SparkContext atorg.apache.spark.SparkContext.org
<http://org.apache.spark.sparkcontext.org/>$apache$spark$SparkContext$$
assertNotStopped(SparkContext.scala:104) at org.apache.spark.SparkContext.
defaultParallelism(SparkContext.scala:2061) at
org.apache.spark.SparkContext.parallelize$default$2(SparkContext.scala:723)
at Algorithm.predict(Algorithm.scala:56) at
Algorithm.predict(Algorithm.scala:9)
at io.prediction.controller.P2LAlgorithm.predictBase(P2LAlgorithm.scala:70)
at io.prediction.workflow.ServerActor$$anonfun$24$$anonfun$25.apply(CreateServer.scala:536)
at io.prediction.workflow.ServerActor$$anonfun$24$$anonfun$25.apply(CreateServer.scala:535)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.immutable.List.foreach(List.scala:318) at
scala.collection.TraversableLike$class.map(TraversableLike.scala:244) at
scala.collection.AbstractTraversable.map(Traversable.scala:105) at
io.prediction.workflow.ServerActor$$anonfun$24.apply(CreateServer.scala:535)
at io.prediction.workflow.ServerActor$$anonfun$24.apply(CreateServer.scala:513)
at spray.routing.ApplyConverterInstances$$anon$22$$anonfun$
apply$1.apply(ApplyConverterInstances.scala:25) at
spray.routing.ApplyConverterInstances$$anon$22$$anonfun$
apply$1.apply(ApplyConverterInstances.scala:24) at
spray.routing.ConjunctionMagnet$$anon$1$$anon$2$$anonfun$
happly$1$$anonfun$apply$1.apply(Directive.scala:38) at
spray.routing.ConjunctionMagnet$$anon$1$$anon$2$$anonfun$
happly$1$$anonfun$apply$1.apply(Directive.scala:37) at
spray.routing.directives.BasicDirectives$$anon$1.happly(BasicDirectives.scala:26)
at spray.routing.ConjunctionMagnet$$anon$1$$anon$2$$anonfun$
happly$1.apply(Directive.scala:37) at spray.routing.ConjunctionMagne
t$$anon$1$$anon$2$$anonfun$happly$1.apply(Directive.scala:36) at
spray.routing.directives.BasicDirectives$$anon$2.happly(BasicDirectives.scala:79)
at spray.routing.Directive$$anon$7$$anonfun$happly$4.apply(Directive.scala:86)
at spray.routing.Directive$$anon$7$$anonfun$happly$4.apply(Directive.scala:86)
at spray.routing.directives.BasicDirectives$$anon$3$$anonfun$
happly$1.apply(BasicDirectives.scala:92) at spray.routing.directives.Basic
Directives$$anon$3$$anonfun$happly$1.apply(BasicDirectives.scala:92) at
spray.routing.directives.ExecutionDirectives$$anonfun$detach
$1$$anonfun$apply$7$$anonfun$apply$3.apply$mcV$sp(ExecutionDirectives.scala:89)
at spray.routing.directives.ExecutionDirectives$$anonfun$detach
$1$$anonfun$apply$7$$anonfun$apply$3.apply(ExecutionDirectives.scala:89) at
spray.routing.directives.ExecutionDirectives$$anonfun$detach
$1$$anonfun$apply$7$$anonfun$apply$3.apply(ExecutionDirectives.scala:89) at
scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(
ExecutionContextImpl.scala:107) at scala.concurrent.forkjoin.Fork
JoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.Fork
JoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinW
orkerThread.java:107)

So, please help me to resolve this bug.

Thanks and Regards,
Sudhanshu kaushik