That's the bug: https://issues.apache.org/jira/browse/FLINK-2632
On Tue, Sep 8, 2015 at 1:11 PM, Robert Metzger <[email protected]> wrote: > There is a bug in the web client which sets the wrong class loader when > running the user code. > > On Tue, Sep 8, 2015 at 12:05 PM, Florian Heyl <[email protected]> wrote: > >> Locally we are using the 0.9-SNAPSHOT but the cluster should work with >> the 0.10-SNAPSHOT. I have no direct control of the cluster because our prof >> is responsible for that. >> The students are using the flink web submission client to upload their >> jar and run it on the cluster. >> >> >> Am 08.09.2015 um 12:48 schrieb Robert Metzger <[email protected]>: >> >> Which version of Flink are you using? >> >> Have you tried submitting the job using the "./bin/flink run" tool? >> >> On Tue, Sep 8, 2015 at 11:44 AM, Florian Heyl <[email protected]> wrote: >> >>> Dear Sir or Madam, >>> Me and my colleague are developing a pipeline based on scala and java to >>> classify cancer stages. This pipeline should be uploaded on the hdfs >>> (apache flink). >>> The pipeline locally works fine but on the hdfs it crashes with the >>> following error (see below). The main method is simply structured we are >>> only passing one argument to set the working directory and then other >>> methods from different scala and java files are called. Sorry if I can not >>> give you more details because I can not figure out what the exact problem >>> is. I hope you can help me. >>> >>> Best wishes, >>> >>> Flo >>> >>> >>> An error occurred while invoking the program: >>> >>> The main method caused an error. >>> >>> >>> java.io.IOException: Class not found >>> at >>> com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.a(Unknown >>> Source) >>> at >>> com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassReader.<init>(Unknown >>> Source) >>> at >>> org.apache.flink.api.scala.ClosureCleaner$.org$apache$flink$api$scala$ClosureCleaner$$getClassReader(ClosureCleaner.scala:42) >>> at >>> org.apache.flink.api.scala.ClosureCleaner$.getInnerClasses(ClosureCleaner.scala:90) >>> pache.flink.api.scala.DataSet.clean(DataSet.scala:120) >>> at org.apache.flink.ap >>> at >>> org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:113) >>> at org. >>> ai.scala.DataSet$$anon$6.<init>(DataSet.scala:437) >>> at org.apache.flink.api.scala.DataSet.filter(DataSet.scala:436) >>> VI$sp(Regression2.scala:98) >>> at scala.collection.immutable.Range. >>> at AddFunctions$.splitIntoTrainingAndTest(AddFunctions.scala:42) >>> at Regression2$$anonfun$mainRegression$1.apply$m >>> cforeach$mVc$sp(Range.scala:141) >>> at Regression2$.mainRegression(Regression2.scala:91) >>> at MainClass$.main(MainClass.scala:41) >>> at MainClass.main(MainClass.scala) >>> elegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl >>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>> at >>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) >>> at sun.reflect. >>> D.java:43) >>> at java.lang.reflect.Method.invoke(Method.java:483) >>> at >>> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437) >>> tOptimizedPlan(Client.java:229) >>> at >>> org.apache.flink.client.web.JobSubmissionServlet.doGet(JobSubmissionServlet >>> at >>> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353) >>> at org.apache.flink.client.program.Client.g >>> e.java:186) >>> at javax.servlet.http.HttpServlet.service(HttpServlet.java:668) >>> at javax.servlet.http.HttpServlet.service(HttpServlet.java:770) >>> at >>> org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:532) >>> doHandle(ContextHandler.java:965) >>> at org.eclipse.jetty.servlet.ServletHandler >>> at >>> org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:453) >>> at >>> org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:227) >>> at org.eclipse.jetty.server.handler.ContextHandler >>> ..doScope(ServletHandler.java:388) >>> at >>> org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:187) >>> at >>> org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:901) >>> at >>> org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:117) >>> ection.java:596) >>> at org.eclipse.jetty.server.HttpConnection$RequestHandler. >>> at >>> org.eclipse.jetty.server.handler.HandlerList.handle(HandlerList.java:47) >>> at >>> org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:113) >>> at org.eclipse.jetty.server.Server.handle(Server.java:352) >>> at org.eclipse.jetty.server.HttpConnection.handleRequest(HttpCon >>> nheaderComplete(HttpConnection.java:1048) >>> at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:549) >>> at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:211) >>> at >>> org.eclipse.jetty.server.HttpConnection.handle(HttpConnection.java:425) >>> at >>> org.eclipse.jetty.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:489) >>> at >>> org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:436) >>> at java.lang.Thread.run(Thread.java:745) >>> >>> >>> >>> >> >> >
