You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:15:46 UTC
[jira] [Resolved] (FLINK-1613) Cannost submit to remote
ExecutionEnvironment from IDE
[ https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ufuk Celebi resolved FLINK-1613.
--------------------------------
Resolution: Not A Problem
As pointed out in the comments, the behaviour is expected.
> 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)