Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 50155200C8E for ; Thu, 8 Jun 2017 17:43:45 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 4EBCE160BD5; Thu, 8 Jun 2017 15:43:45 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 46B5A160BCA for ; Thu, 8 Jun 2017 17:43:44 +0200 (CEST) Received: (qmail 96824 invoked by uid 500); 8 Jun 2017 15:43:43 -0000 Mailing-List: contact user-help@predictionio.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@predictionio.incubator.apache.org Delivered-To: mailing list user@predictionio.incubator.apache.org Received: (qmail 96815 invoked by uid 99); 8 Jun 2017 15:43:43 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Jun 2017 15:43:43 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 150A1C028B for ; Thu, 8 Jun 2017 15:43:43 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -2.52 X-Spam-Level: X-Spam-Status: No, score=-2.52 tagged_above=-999 required=6.31 tests=[HTML_FONT_LOW_CONTRAST=0.001, HTML_MESSAGE=2, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id C0Qq-ieIvZDe for ; Thu, 8 Jun 2017 15:43:41 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 5EACB5F2AC for ; Thu, 8 Jun 2017 15:43:40 +0000 (UTC) Received: (qmail 96792 invoked by uid 99); 8 Jun 2017 15:43:39 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Jun 2017 15:43:39 +0000 Received: from mail-yw0-f176.google.com (mail-yw0-f176.google.com [209.85.161.176]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 3504E1A0048 for ; Thu, 8 Jun 2017 15:43:37 +0000 (UTC) Received: by mail-yw0-f176.google.com with SMTP id e142so5892109ywa.1 for ; Thu, 08 Jun 2017 08:43:36 -0700 (PDT) X-Gm-Message-State: AODbwcBjp7cVKN6GGFivQceSiax3Le/jkM89ZO3n2mwCWYia/uNPTfik VVX74+eXpEC2Uuuez/7rI85GW5xSXA== X-Received: by 10.13.254.68 with SMTP id o65mr12755847ywf.263.1496936615383; Thu, 08 Jun 2017 08:43:35 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Donald Szeto Date: Thu, 08 Jun 2017 15:43:25 +0000 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Sparkling Water-Deep Learning Energy Forecasting template To: user@predictionio.incubator.apache.org Content-Type: multipart/alternative; boundary="94eb2c081dca3646b7055174b712" archived-at: Thu, 08 Jun 2017 15:43:45 -0000 --94eb2c081dca3646b7055174b712 Content-Type: text/plain; charset="UTF-8" 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 > $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 > --94eb2c081dca3646b7055174b712 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi Sudhanshu,

What versions of Spark, Sparkli= ng Water, PredictionIO are you running on? The community might not have tes= ted the template on the latest versions of these technologies.
Regards,
Donald

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

I am using=C2= =A0Sparkling Water-Deep Learning Energy Forecasting template of predictioni= o. I am able to build, train and deploy the engine. But when I query the en= gine, I am getting following error :
<= span style=3D"color:rgb(36,41,46);font-family:SFMono-Regular,Consolas,"= ;Liberation Mono",Menlo,Courier,monospace;font-size:11.9px;background-= color:rgba(27,31,35,0.05)">Cannot call methods on a stopped SparkContext
Stack Tr= ace: java.lang.IllegalStateException: Cannot call methods on a stopped Spar= kContext atorg.apache.spark.SparkContext.org$apache$spark$SparkContext$$as= sertNotStopped(SparkContext.scala:104) at org.apache.spark.SparkContext.def= aultParallelism(SparkContext.scala:2061) at org.apache.spark.SparkContext.p= arallelize$default$2(SparkContext.scala:723) at Algorithm.predict(Algorithm= .scala:56) at Algorithm.predict(Algorithm.scala:9) at io.prediction.control= ler.P2LAlgorithm.predictBase(P2LAlgorithm.scala:70) at io.prediction.workfl= ow.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(Travers= ableLike.scala:244) at scala.collection.TraversableLike$$anonfun$map$1.appl= y(TraversableLike.scala:244) at scala.collection.immutable.List.foreach(Lis= t.scala:318) at scala.collection.TraversableLike$class.map(TraversableLike.= scala:244) at scala.collection.AbstractTraversable.map(Traversable.scala:10= 5) at io.prediction.workflow.ServerActor$$anonfun$24.apply(CreateServer.sca= la:535) at io.prediction.workflow.ServerActor$$anonfun$24.apply(CreateServe= r.scala:513) at spray.routing.ApplyConverterInstances$$anon$22$$anonfun$app= ly$1.apply(ApplyConverterInstances.scala:25) at spray.routing.ApplyConverte= rInstances$$anon$22$$anonfun$apply$1.apply(ApplyConverterInstances.scala:24= ) at spray.routing.ConjunctionMagnet$$anon$1$$anon$2$$anonfun$happly$1$$ano= nfun$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$happ= ly$1.apply(Directive.scala:37) at spray.routing.ConjunctionMagnet$$anon$1$$= anon$2$$anonfun$happly$1.apply(Directive.scala:36) at spray.routing.directi= ves.BasicDirectives$$anon$2.happly(BasicDirectives.scala:79) at spray.routi= ng.Directive$$anon$7$$anonfun$happly$4.apply(Directive.scala:86) at spray.r= outing.Directive$$anon$7$$anonfun$happly$4.apply(Directive.scala:86) at spr= ay.routing.directives.BasicDirectives$$anon$3$$anonfun$happly$1.apply(Basic= Directives.scala:92) at spray.routing.directives.BasicDirectives$$anon$3$$a= nonfun$happly$1.apply(BasicDirectives.scala:92) at spray.routing.directives= .ExecutionDirectives$$anonfun$detach$1$$anonfun$apply$7$$anonfun$apply$3.ap= ply$mcV$sp(ExecutionDirectives.scala:89) at spray.routing.directives.Execut= ionDirectives$$anonfun$detach$1$$anonfun$apply$7$$anonfun$apply$3.apply(Exe= cutionDirectives.scala:89) at spray.routing.directives.ExecutionDirectives$= $anonfun$detach$1$$anonfun$apply$7$$anonfun$apply$3.apply(ExecutionDirectiv= es.scala:89) at scala.concurrent.impl.Future$PromiseCompletingRunnable.lift= edTree1$1(Future.scala:24) at scala.concurrent.impl.Future$PromiseCompletin= gRunnable.run(Future.scala:24) at scala.concurrent.impl.ExecutionContextImp= l$$anon$3.exec(ExecutionContextImpl.scala:107) at scala.concurrent.forkjoin= .ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.Fo= rkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.fo= rkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.f= orkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
<= br style=3D"font-size:12.8px">So, please h= elp me to resolve this bug.=C2=A0

Thanks and Rega= rds,
= Sudhanshu kaushik
--94eb2c081dca3646b7055174b712--