[
https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14338714#comment-14338714
]
Stephan Ewen commented on FLINK-1613:
-------------------------------------
This is somewhat expected, currently. The remote executor needs a JAR file with
all the user defined classes. It will shiip that JAR into the cluster.
There is work to collect these classes automatically. If you want, pick up the
pull request and use the jarfile creator to automatically gather the classes
and generate the JAR to ship.
https://github.com/apache/flink/pull/35
> Cannost submit to remote ExecutionEnvironment from IDE
> ------------------------------------------------------
>
> Key: FLINK-1613
> URL: https://issues.apache.org/jira/browse/FLINK-1613
> Project: Flink
> Issue Type: Bug
> Components: Distributed Runtime
> Affects Versions: 0.8.1
> Environment: * Ubuntu Linux 14.04
> * Flink 0.9-SNAPSHOT or 0.8.1 running in standalone mode on localhost
> Reporter: Alexander Alexandrov
> Fix For: 0.9, 0.8.2
>
>
> I am reporting this as [~rmetzler] mentioned offline that it was working in
> the past.
> At the moment it is not possible to submit jobs directly from the IDE. Both
> the Java and the Scala quickstart guides fail on both 0.8.1 and 0.9-SNAPSHOT
> with ClassNotFoundException exceptions.
> To reproduce the error, run the quickstart scripts and change the
> ExecutionEnvironment initialization:
> {code:java}
> env = ExecutionEnvironment.createRemoteEnvironment("localhost", 6123)
> {code}
> This is the cause for Java:
> {noformat}
> Caused by: java.lang.ClassNotFoundException:
> org.myorg.quickstart.WordCount$LineSplitter
> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> at java.security.AccessController.doPrivileged(Native Method)
> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> at java.lang.Class.forName0(Native Method)
> at java.lang.Class.forName(Class.java:274)
> at
> org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:54)
> at
> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
> at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
> at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1990)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1915)
> at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
> at
> org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:274)
> at
> org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:236)
> at
> org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:281)
> {noformat}
> This is for Scala:
> {noformat}
> java.lang.ClassNotFoundException:
> org.myorg.quickstart.WordCount$$anon$2$$anon$1
> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> at java.security.AccessController.doPrivileged(Native Method)
> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> at java.lang.Class.forName0(Native Method)
> at java.lang.Class.forName(Class.java:274)
> at
> org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:54)
> at
> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
> at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
> at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
> at
> org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:274)
> at
> org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:236)
> at
> org.apache.flink.api.java.typeutils.runtime.RuntimeSerializerFactory.readParametersFromConfig(RuntimeSerializerFactory.java:76)
> at
> org.apache.flink.runtime.operators.util.TaskConfig.getTypeSerializerFactory(TaskConfig.java:1084)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
