predictionio-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Donald Szeto <don...@apache.org>
Subject Re: Sparkling Water-Deep Learning Energy Forecasting template
Date Thu, 08 Jun 2017 15:43:25 GMT
Hi Sudhanshu,

What versions of Spark, Sparkling Water, PredictionIO are you running on?
The community might not have tested the template on the latest versions of
these technologies.

Regards,
Donald

On Tue, Jun 6, 2017 at 9:43 PM SUDHANSHU KAUSHIK <
sudhanshukaushik1.61803@gmail.com> wrote:

> 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.ConjunctionMagnet$$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.BasicDirectives$$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.ForkJoinTask.doExec(ForkJoinTask.java:260) at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>
> So, please help me to resolve this bug.
>
> Thanks and Regards,
> Sudhanshu kaushik
>

Mime
View raw message