java.lang.ClassNotFoundExcepti
Locked
java.lang.ClassNotFoundExcepti
 
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
If I see it correctly your jar contains
> com/davengo/rfidcloud/flink/DaoJoin$1.class But your error message says > ClassNotFoundException: com.otter.ist.flink.DaoJoin$1 Both are different packages. Your jar seems not be correctly packaged. -Matthias On 08/06/2015 12:46 PM, Michael Huelfenhaus wrote: > I am back at work next Tuesday, any further ideas would be great until > then, for now I am continuing inside ecplise. > > Am 06.08.2015 um 11:27 schrieb Michael Huelfenhaus > <[hidden email] <mailto:[hidden email]>>: > >> hi, >> >>> how did you build the jar file? >> >> mvn clean install -Pbuild-jar >> >>> Have you checked whether your classes are in the jar file? >> >> yes, this seems alright for me >> >> > jar tf target/flink-test-0.1.jar >> META-INF/MANIFEST.MF >> META-INF/ >> com/ >> com/davengo/ >> com/davengo/rfidcloud/ >> com/davengo/rfidcloud/flink/ >> com/davengo/rfidcloud/flink/DaoJoin$1.class >> com/davengo/rfidcloud/flink/DaoJoin.class >> com/davengo/rfidcloud/flink/streampojos/ >> com/davengo/rfidcloud/flink/streampojos/EpcTuple.class >> log4j.properties >> META-INF/maven/ >> META-INF/maven/com.davengo.rfidcloud.flink/ >> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/ >> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/pom.xml >> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/pom.properties >> >> Am 06.08.2015 um 11:21 schrieb Robert Metzger <[hidden email] >> <mailto:[hidden email]>>: >> >>> Hi, >>> >>> how did you build the jar file? >>> Have you checked whether your classes are in the jar file? >>> >>> On Thu, Aug 6, 2015 at 11:08 AM, Michael Huelfenhaus >>> <[hidden email] <mailto:[hidden email]>> wrote: >>> >>> Hello everybody >>> >>> I am truing to build a very simple streaming application with the >>> nightly build of flink 0.10, my code runs fine in eclipse. >>> >>> But when I build and deploy the jar locally I always get >>> java.lang.ClassNotFoundException: com.otter.ist.flink.DaoJoin$1 >>> >>> There is also no plan visible in the web interface. >>> >>> I start the local flink 0.10 with start-local-streaming.sh after >>> building it from the git code >>> >>> Below you find the complete error, my code and the pom.xml any >>> help is appreciated. >>> >>> Cheers Michael >>> >>> >>> error log from web interface: >>> An error occurred while invoking the program: >>> >>> The main method caused an error. >>> >>> >>> org.apache.flink.runtime.client.JobExecutionException: Job >>> execution failed. >>> at >>> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:364) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25) >>> at >>> org.apache.flink.runtime.LeaderSessionMessages$$anonfun$receive$1.applyOrElse(LeaderSessionMessages.scala:40) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33) >>> at >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25) >>> at >>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) >>> at >>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) >>> at >>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118) >>> at >>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) >>> at akka.actor.Actor$class.aroundReceive(Actor.scala:465) >>> at >>> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:101) >>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>> at akka.actor.ActorCell.invoke(ActorCell.scala:487) >>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) >>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) >>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >>> 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) >>> Caused by: java.lang.Exception: Call to registerInputOutput() of >>> invokable failed >>> at >>> org.apache.flink.runtime.taskmanager.Task.run(Task.java:526) >>> at java.lang.Thread.run(Thread.java:745) >>> Caused by: >>> org.apache.flink.streaming.runtime.tasks.StreamTaskException: >>> Cannot instantiate user function. >>> at >>> org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:207) >>> at >>> org.apache.flink.streaming.runtime.tasks.OutputHandler.createChainedCollector(OutputHandler.java:173) >>> at >>> org.apache.flink.streaming.runtime.tasks.OutputHandler.createChainedCollector(OutputHandler.java:159) >>> at >>> org.apache.flink.streaming.runtime.tasks.OutputHandler.<init>(OutputHandler.java:107) >>> at >>> org.apache.flink.streaming.runtime.tasks.StreamTask.registerInputOutput(StreamTask.java:99) >>> at >>> org.apache.flink.runtime.taskmanager.Task.run(Task.java:523) >>> ... 1 more >>> Caused by: java.lang.ClassNotFoundException: >>> com.otter.ist.flink.DaoJoin$1 >>> at java.net.URLClassLoader$1.run(URLClassLoader.java:372) >>> at java.net.URLClassLoader$1.run(URLClassLoader.java:361) >>> at java.security.AccessController.doPrivileged(Native Method) >>> at java.net.URLClassLoader.findClass(URLClassLoader.java:360) >>> at java.lang.ClassLoader.loadClass(ClassLoader.java:424) >>> at java.lang.ClassLoader.loadClass(ClassLoader.java:357) >>> at java.lang.Class.forName0(Native Method) >>> at java.lang.Class.forName(Class.java:344) >>> at >>> org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:71) >>> at >>> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613) >>> at >>> java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) >>> at >>> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) >>> at >>> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) >>> at >>> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) >>> at >>> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) >>> at >>> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) >>> at >>> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) >>> at >>> java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) >>> at >>> org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:302) >>> at >>> org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:264) >>> at >>> org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:205) >>> ... 6 more >>> >>> my code: >>> >>> package com.otter.ist.flink; >>> >>> import org.apache.flink.api.common.functions.MapFunction; >>> import org.apache.flink.api.java.tuple.Tuple3; >>> import org.apache.flink.streaming.api.datastream.DataStream; >>> import >>> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; >>> >>> public class DaoJoin { >>> >>> public static void main(String[] args) throws Exception { >>> // >>> ************************************************************************* >>> // PROGRAM >>> // >>> ************************************************************************* >>> >>> if (!parseParameters(args)) { >>> return; >>> } >>> >>> // set up the execution environment >>> final StreamExecutionEnvironment env = >>> StreamExecutionEnvironment.createLocalEnvironment(); >>> // final StreamExecutionEnvironment env = >>> StreamExecutionEnvironment.getExecutionEnvironment(); >>> >>> >>> // get input data >>> DataStream<String> text = getTextDataStream(env); >>> >>> DataStream<Tuple3<String, String, Integer>> epcs >>> = text.map(new MapFunction<String, Tuple3<String, String, >>> Integer>>(){ >>> >>> private static final long >>> serialVersionUID = -7889264579632622427L; >>> >>> @Override >>> public Tuple3<String, String, Integer> >>> map(String line) throws Exception { >>> String[] fields = line.split(" "); >>> >>> return new Tuple3<String, String, >>> Integer>(fields[0], fields[1], Integer.parseInt(fields[2])); >>> } >>> >>> }); >>> >>> // emit result >>> if (fileOutput) { >>> epcs.writeAsText(outputPath); >>> } else { >>> epcs.print(); >>> } >>> System.out.println(env.getExecutionPlan()); >>> >>> // execute program >>> env.execute("DaoJoin"); >>> } >>> >>> // >>> ************************************************************************* >>> // UTIL METHODS >>> // >>> ************************************************************************* >>> >>> private static boolean fileOutput = false; >>> private static String textPath; >>> private static String outputPath; >>> >>> private static boolean parseParameters(String[] args) { >>> >>> if (args.length > 0) { >>> // parse input arguments >>> fileOutput = true; >>> if (args.length == 2) { >>> textPath = args[0]; >>> outputPath = args[1]; >>> } else { >>> System.err.println("Usage: >>> DaoJoin <text path> <result path>"); >>> return false; >>> } >>> System.out.println("fileout: " + fileOutput); >>> } else { >>> System.out.println("Executing WordCount >>> example with built-in default data."); >>> System.out.println(" Provide parameters >>> to read input data from a file."); >>> System.out.println(" Usage: WordCount >>> <text path> <result path>"); >>> } >>> return true; >>> } >>> >>> private static DataStream<String> >>> getTextDataStream(StreamExecutionEnvironment env) { >>> // read the text file from given input path >>> return env.readTextFile(textPath); >>> } >>> } >>> >>> >>> the pom.xml >>> <project xmlns="http://maven.apache.org/POM/4.0.0" >>> xmlns:xsi="http://xwww.w3.org/2001/XMLSchema-instance" >>> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 >>> http://maven.apache.org/xsd/maven-4.0.0.xsd"> >>> <modelVersion>4.0.0</modelVersion> >>> >>> <groupId>com.otter.ist.flink</groupId> >>> <artifactId>flink-test</artifactId> >>> <version>0.1</version> >>> <packaging>jar</packaging> >>> >>> <name>DaoJoin</name> >>> <url>http://www.otter.com <http://www.otter.com/></url> >>> >>> <properties> >>> >>> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> >>> </properties> >>> >>> <repositories> >>> <repository> >>> <id>apache.snapshots</id> >>> <name>Apache Development Snapshot >>> Repository</name> >>> >>> <url>https://repository.apache.org/content/repositories/snapshots/</url> >>> <releases> >>> <enabled>false</enabled> >>> </releases> >>> <snapshots> >>> <enabled>true</enabled> >>> </snapshots> >>> </repository> >>> </repositories> >>> >>> <!-- >>> >>> Execute "mvn clean package -Pbuild-jar" >>> to build a jar file out of this project! >>> >>> How to use the Flink Quickstart pom: >>> >>> a) Adding new dependencies: >>> You can add dependencies to the list below. >>> Please check if the maven-shade-plugin >>> below is filtering out your dependency >>> and remove the exclude from there. >>> >>> b) Build a jar for running on the cluster: >>> There are two options for creating a jar >>> from this project >>> >>> b.1) "mvn clean package" -> this will >>> create a fat jar which contains all >>> dependencies necessary >>> for running the jar created by this pom in a cluster. >>> The "maven-shade-plugin" >>> excludes everything that is provided on a running Flink cluster. >>> >>> b.2) "mvn clean package -Pbuild-jar" -> >>> This will also create a fat-jar, but with much >>> nicer dependency >>> exclusion handling. This approach is preferred and leads to >>> much cleaner jar files. >>> --> >>> >>> <dependencies> >>> <dependency> >>> <groupId>org.apache.flink</groupId> >>> <artifactId>flink-java</artifactId> >>> <version>0.10-SNAPSHOT</version> >>> </dependency> >>> <dependency> >>> <groupId>org.apache.flink</groupId> >>> <artifactId>flink-streaming-core</artifactId> >>> <version>0.10-SNAPSHOT</version> >>> </dependency> >>> <dependency> >>> <groupId>org.apache.flink</groupId> >>> <artifactId>flink-clients</artifactId> >>> <version>0.10-SNAPSHOT</version> >>> </dependency> >>> </dependencies> >>> >>> <build> >>> <plugins> >>> <!-- We use the maven-shade plugin to >>> create a fat jar that contains all dependencies >>> except flink and it's transitive >>> dependencies. The resulting fat-jar can be executed >>> on a cluster. Change the value of >>> Program-Class if your program entry point changes. --> >>> <plugin> >>> >>> <groupId>org.apache.maven.plugins</groupId> >>> >>> <artifactId>maven-shade-plugin</artifactId> >>> <version>2.3</version> >>> <executions> >>> <!-- Run shade goal on >>> package phase --> >>> <execution> >>> >>> <phase>package</phase> >>> <goals> >>> >>> <goal>shade</goal> >>> </goals> >>> <configuration> >>> <artifactSet> >>> >>> <excludes> >>> >>> <!-- This list contains all dependencies of flink-dist >>> >>> Everything else will be packaged into the fat-jar >>> >>> --> >>> >>> <exclude>org.apache.flink:flink-shaded-*</exclude> >>> >>> <exclude>org.apache.flink:flink-core</exclude> >>> >>> <exclude>org.apache.flink:flink-java</exclude> >>> >>> <exclude>org.apache.flink:flink-scala</exclude> >>> >>> <exclude>org.apache.flink:flink-runtime</exclude> >>> >>> <exclude>org.apache.flink:flink-optimizer</exclude> >>> >>> <exclude>org.apache.flink:flink-clients</exclude> >>> >>> <exclude>org.apache.flink:flink-spargel</exclude> >>> >>> <exclude>org.apache.flink:flink-avro</exclude> >>> >>> <exclude>org.apache.flink:flink-java-examples</exclude> >>> >>> <exclude>org.apache.flink:flink-scala-examples</exclude> >>> >>> <exclude>org.apache.flink:flink-streaming-examples</exclude> >>> >>> <exclude>org.apache.flink:flink-streaming-core</exclude> >>> >>> >>> <!-- Also exclude very big transitive dependencies of Flink >>> >>> >>> WARNING: You have to remove these excludes if your code >>> relies on other >>> >>> versions of these dependencies. >>> >>> >>> --> >>> >>> <exclude>org.scala-lang:scala-library</exclude> >>> >>> <exclude>org.scala-lang:scala-compiler</exclude> >>> >>> <exclude>org.scala-lang:scala-reflect</exclude> >>> >>> <exclude>com.amazonaws:aws-java-sdk</exclude> >>> >>> <exclude>com.typesafe.akka:akka-actor_*</exclude> >>> >>> <exclude>com.typesafe.akka:akka-remote_*</exclude> >>> >>> <exclude>com.typesafe.akka:akka-slf4j_*</exclude> >>> >>> <exclude>io.netty:netty-all</exclude> >>> >>> <exclude>io.netty:netty</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-server</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-continuation</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-http</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-io</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-util</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-security</exclude> >>> >>> <exclude>org.eclipse.jetty:jetty-servlet</exclude> >>> >>> <exclude>commons-fileupload:commons-fileupload</exclude> >>> >>> <exclude>org.apache.avro:avro</exclude> >>> >>> <exclude>commons-collections:commons-collections</exclude> >>> >>> <exclude>org.codehaus.jackson:jackson-core-asl</exclude> >>> >>> <exclude>org.codehaus.jackson:jackson-mapper-asl</exclude> >>> >>> <exclude>com.thoughtworks.paranamer:paranamer</exclude> >>> >>> <exclude>org.xerial.snappy:snappy-java</exclude> >>> >>> <exclude>org.apache.commons:commons-compress</exclude> >>> >>> <exclude>org.tukaani:xz</exclude> >>> >>> <exclude>com.esotericsoftware.kryo:kryo</exclude> >>> >>> <exclude>com.esotericsoftware.minlog:minlog</exclude> >>> >>> <exclude>org.objenesis:objenesis</exclude> >>> >>> <exclude>com.twitter:chill_*</exclude> >>> >>> <exclude>com.twitter:chill-java</exclude> >>> >>> <exclude>com.twitter:chill-avro_*</exclude> >>> >>> <exclude>com.twitter:chill-bijection_*</exclude> >>> >>> <exclude>com.twitter:bijection-core_*</exclude> >>> >>> <exclude>com.twitter:bijection-avro_*</exclude> >>> >>> <exclude>commons-lang:commons-lang</exclude> >>> >>> <exclude>junit:junit</exclude> >>> >>> <exclude>de.javakaffee:kryo-serializers</exclude> >>> >>> <exclude>joda-time:joda-time</exclude> >>> >>> <exclude>org.apache.commons:commons-lang3</exclude> >>> >>> <exclude>org.slf4j:slf4j-api</exclude> >>> >>> <exclude>org.slf4j:slf4j-log4j12</exclude> >>> >>> <exclude>log4j:log4j</exclude> >>> >>> <exclude>org.apache.commons:commons-math</exclude> >>> >>> >>> <exclude>org.apache.sling:org.apache.sling.commons.json</exclude> >>> >>> <exclude>commons-logging:commons-logging</exclude> >>> >>> <exclude>org.apache.httpcomponents:httpclient</exclude> >>> >>> <exclude>org.apache.httpcomponents:httpcore</exclude> >>> >>> <exclude>commons-codec:commons-codec</exclude> >>> >>> <exclude>com.fasterxml.jackson.core:jackson-core</exclude> >>> >>> <exclude>com.fasterxml.jackson.core:jackson-databind</exclude> >>> >>> >>> <exclude>com.fasterxml.jackson.core:jackson-annotations</exclude> >>> >>> <exclude>org.codehaus.jettison:jettison</exclude> >>> >>> <exclude>stax:stax-api</exclude> >>> >>> <exclude>com.typesafe:config</exclude> >>> >>> <exclude>org.uncommons.maths:uncommons-maths</exclude> >>> >>> <exclude>com.github.scopt:scopt_*</exclude> >>> >>> <exclude>org.mortbay.jetty:servlet-api</exclude> >>> >>> <exclude>commons-io:commons-io</exclude> >>> >>> <exclude>commons-cli:commons-cli</exclude> >>> >>> </excludes> >>> >>> </artifactSet> >>> <filters> >>> >>> <filter> >>> >>> <artifact>org.apache.flink:*</artifact> >>> >>> <excludes> >>> >>> <exclude>org/apache/flink/shaded/**</exclude> >>> >>> <exclude>web-docs/**</exclude> >>> >>> </excludes> >>> >>> </filter> >>> </filters> >>> >>> <transformers> >>> >>> <!-- add Main-Class to manifest file --> >>> >>> <transformer >>> implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"> >>> >>> <mainClass>com.otter.ist.flink.DaoJoin</mainClass> >>> >>> </transformer> >>> >>> </transformers> >>> >>> <createDependencyReducedPom>false</createDependencyReducedPom> >>> </configuration> >>> </execution> >>> </executions> >>> </plugin> >>> >>> <!-- Configure the jar plugin to add the >>> main class as a manifest entry --> >>> <plugin> >>> >>> <groupId>org.apache.maven.plugins</groupId> >>> >>> <artifactId>maven-jar-plugin</artifactId> >>> <version>2.5</version> >>> <configuration> >>> <archive> >>> <manifestEntries> >>> >>> <Main-Class>com.otter.ist.flink.DaoJoin</Main-Class> >>> </manifestEntries> >>> </archive> >>> </configuration> >>> </plugin> >>> >>> <plugin> >>> >>> <groupId>org.apache.maven.plugins</groupId> >>> >>> <artifactId>maven-compiler-plugin</artifactId> >>> <version>3.1</version> >>> <configuration> >>> <source>1.8</source> <!-- >>> If you want to use Java 8, change this to "1.8" --> >>> <target>1.8</target> <!-- >>> If you want to use Java 8, change this to "1.8" --> >>> </configuration> >>> </plugin> >>> </plugins> >>> >>> >>> <!-- If you want to use Java 8 Lambda Expressions >>> uncomment the following lines --> >>> <!-- >>> <pluginManagement> >>> <plugins> >>> <plugin> >>> >>> <artifactId>maven-compiler-plugin</artifactId> >>> <configuration> >>> <source>1.8</source> >>> <target>1.8</target> >>> >>> <compilerId>jdt</compilerId> >>> </configuration> >>> <dependencies> >>> <dependency> >>> >>> <groupId>org.eclipse.tycho</groupId> >>> >>> <artifactId>tycho-compiler-jdt</artifactId> >>> >>> <version>0.21.0</version> >>> </dependency> >>> </dependencies> >>> </plugin> >>> >>> <plugin> >>> >>> <groupId>org.eclipse.m2e</groupId> >>> >>> <artifactId>lifecycle-mapping</artifactId> >>> <version>1.0.0</version> >>> <configuration> >>> >>> <lifecycleMappingMetadata> >>> >>> <pluginExecutions> >>> >>> <pluginExecution> >>> >>> <pluginExecutionFilter> >>> >>> <groupId>org.apache.maven.plugins</groupId> >>> >>> <artifactId>maven-assembly-plugin</artifactId> >>> >>> <versionRange>[2.4,)</versionRange> >>> >>> <goals> >>> >>> <goal>single</goal> >>> >>> </goals> >>> >>> </pluginExecutionFilter> >>> >>> <action> >>> >>> <ignore/> >>> >>> </action> >>> >>> </pluginExecution> >>> >>> <pluginExecution> >>> >>> <pluginExecutionFilter> >>> >>> <groupId>org.apache.maven.plugins</groupId> >>> >>> <artifactId>maven-compiler-plugin</artifactId> >>> >>> <versionRange>[3.1,)</versionRange> >>> >>> <goals> >>> >>> <goal>testCompile</goal> >>> >>> <goal>compile</goal> >>> >>> </goals> >>> >>> </pluginExecutionFilter> >>> >>> <action> >>> >>> <ignore/> >>> >>> </action> >>> >>> </pluginExecution> >>> >>> </pluginExecutions> >>> >>> </lifecycleMappingMetadata> >>> </configuration> >>> </plugin> >>> </plugins> >>> </pluginManagement> >>> --> >>> >>> </build> >>> <profiles> >>> <profile> >>> <!-- A profile that does everyting correctly: >>> We set the Flink dependencies to provided --> >>> <id>build-jar</id> >>> <activation> >>> >>> <activeByDefault>false</activeByDefault> >>> </activation> >>> <dependencies> >>> <dependency> >>> >>> <groupId>org.apache.flink</groupId> >>> >>> <artifactId>flink-java</artifactId> >>> >>> <version>0.10-SNAPSHOT</version> >>> <scope>provided</scope> >>> </dependency> >>> <dependency> >>> >>> <groupId>org.apache.flink</groupId> >>> >>> <artifactId>flink-streaming-core</artifactId> >>> >>> <version>0.10-SNAPSHOT</version> >>> <scope>provided</scope> >>> </dependency> >>> <dependency> >>> >>> <groupId>org.apache.flink</groupId> >>> >>> <artifactId>flink-clients</artifactId> >>> >>> <version>0.10-SNAPSHOT</version> >>> <scope>provided</scope> >>> </dependency> >>> </dependencies> >>> </profile> >>> </profiles> >>> </project> >>> >>> >> > |
signature.asc (836 bytes)
Re: java.lang.ClassNotFoundExcepti
|
|
Never mind. Just saw that this in not the problem...
Sounds weird to me. Maybe you can try to name the class. Anonymous classes should not be a problem, but it should be worth a try. -Matthias On 08/06/2015 01:51 PM, Matthias J. Sax wrote: > If I see it correctly your jar contains > >> com/davengo/rfidcloud/flink/DaoJoin$1.class > > But your error message says > >> ClassNotFoundException: com.otter.ist.flink.DaoJoin$1 > > Both are different packages. Your jar seems not be correctly packaged. > > > -Matthias > > On 08/06/2015 12:46 PM, Michael Huelfenhaus wrote: >> I am back at work next Tuesday, any further ideas would be great until >> then, for now I am continuing inside ecplise. >> >> Am 06.08.2015 um 11:27 schrieb Michael Huelfenhaus >> <[hidden email] <mailto:[hidden email]>>: >> >>> hi, >>> >>>> how did you build the jar file? >>> >>> mvn clean install -Pbuild-jar >>> >>>> Have you checked whether your classes are in the jar file? >>> >>> yes, this seems alright for me >>> >>>> jar tf target/flink-test-0.1.jar >>> META-INF/MANIFEST.MF >>> META-INF/ >>> com/ >>> com/davengo/ >>> com/davengo/rfidcloud/ >>> com/davengo/rfidcloud/flink/ >>> com/davengo/rfidcloud/flink/DaoJoin$1.class >>> com/davengo/rfidcloud/flink/DaoJoin.class >>> com/davengo/rfidcloud/flink/streampojos/ >>> com/davengo/rfidcloud/flink/streampojos/EpcTuple.class >>> log4j.properties >>> META-INF/maven/ >>> META-INF/maven/com.davengo.rfidcloud.flink/ >>> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/ >>> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/pom.xml >>> META-INF/maven/com.davengo.rfidcloud.flink/flink-test/pom.properties >>> >>> Am 06.08.2015 um 11:21 schrieb Robert Metzger <[hidden email] >>> <mailto:[hidden email]>>: >>> >>>> Hi, >>>> >>>> how did you build the jar file? >>>> Have you checked whether your classes are in the jar file? >>>> >>>> On Thu, Aug 6, 2015 at 11:08 AM, Michael Huelfenhaus >>>> <[hidden email] <mailto:[hidden email]>> wrote: >>>> >>>> Hello everybody >>>> >>>> I am truing to build a very simple streaming application with the >>>> nightly build of flink 0.10, my code runs fine in eclipse. >>>> >>>> But when I build and deploy the jar locally I always get >>>> java.lang.ClassNotFoundException: com.otter.ist.flink.DaoJoin$1 >>>> >>>> There is also no plan visible in the web interface. >>>> >>>> I start the local flink 0.10 with start-local-streaming.sh after >>>> building it from the git code >>>> >>>> Below you find the complete error, my code and the pom.xml any >>>> help is appreciated. >>>> >>>> Cheers Michael >>>> >>>> >>>> error log from web interface: >>>> An error occurred while invoking the program: >>>> >>>> The main method caused an error. >>>> >>>> >>>> org.apache.flink.runtime.client.JobExecutionException: Job >>>> execution failed. >>>> at >>>> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:364) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25) >>>> at >>>> org.apache.flink.runtime.LeaderSessionMessages$$anonfun$receive$1.applyOrElse(LeaderSessionMessages.scala:40) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33) >>>> at >>>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) >>>> at >>>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118) >>>> at >>>> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) >>>> at akka.actor.Actor$class.aroundReceive(Actor.scala:465) >>>> at >>>> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:101) >>>> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>>> at akka.actor.ActorCell.invoke(ActorCell.scala:487) >>>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) >>>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) >>>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >>>> 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) >>>> Caused by: java.lang.Exception: Call to registerInputOutput() of >>>> invokable failed >>>> at >>>> org.apache.flink.runtime.taskmanager.Task.run(Task.java:526) >>>> at java.lang.Thread.run(Thread.java:745) >>>> Caused by: >>>> org.apache.flink.streaming.runtime.tasks.StreamTaskException: >>>> Cannot instantiate user function. >>>> at >>>> org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:207) >>>> at >>>> org.apache.flink.streaming.runtime.tasks.OutputHandler.createChainedCollector(OutputHandler.java:173) >>>> at >>>> org.apache.flink.streaming.runtime.tasks.OutputHandler.createChainedCollector(OutputHandler.java:159) >>>> at >>>> org.apache.flink.streaming.runtime.tasks.OutputHandler.<init>(OutputHandler.java:107) >>>> at >>>> org.apache.flink.streaming.runtime.tasks.StreamTask.registerInputOutput(StreamTask.java:99) >>>> at >>>> org.apache.flink.runtime.taskmanager.Task.run(Task.java:523) >>>> ... 1 more >>>> Caused by: java.lang.ClassNotFoundException: >>>> com.otter.ist.flink.DaoJoin$1 >>>> at java.net.URLClassLoader$1.run(URLClassLoader.java:372) >>>> at java.net.URLClassLoader$1.run(URLClassLoader.java:361) >>>> at java.security.AccessController.doPrivileged(Native Method) >>>> at java.net.URLClassLoader.findClass(URLClassLoader.java:360) >>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:424) >>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:357) >>>> at java.lang.Class.forName0(Native Method) >>>> at java.lang.Class.forName(Class.java:344) >>>> at >>>> org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:71) >>>> at >>>> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613) >>>> at >>>> java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) >>>> at >>>> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) >>>> at >>>> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) >>>> at >>>> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) >>>> at >>>> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) >>>> at >>>> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) >>>> at >>>> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) >>>> at >>>> java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) >>>> at >>>> org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:302) >>>> at >>>> org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:264) >>>> at >>>> org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:205) >>>> ... 6 more >>>> >>>> my code: >>>> >>>> package com.otter.ist.flink; >>>> >>>> import org.apache.flink.api.common.functions.MapFunction; >>>> import org.apache.flink.api.java.tuple.Tuple3; >>>> import org.apache.flink.streaming.api.datastream.DataStream; >>>> import >>>> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; >>>> >>>> public class DaoJoin { >>>> >>>> public static void main(String[] args) throws Exception { >>>> // >>>> ************************************************************************* >>>> // PROGRAM >>>> // >>>> ************************************************************************* >>>> >>>> if (!parseParameters(args)) { >>>> return; >>>> } >>>> >>>> // set up the execution environment >>>> final StreamExecutionEnvironment env = >>>> StreamExecutionEnvironment.createLocalEnvironment(); >>>> // final StreamExecutionEnvironment env = >>>> StreamExecutionEnvironment.getExecutionEnvironment(); >>>> >>>> >>>> // get input data >>>> DataStream<String> text = getTextDataStream(env); >>>> >>>> DataStream<Tuple3<String, String, Integer>> epcs >>>> = text.map(new MapFunction<String, Tuple3<String, String, >>>> Integer>>(){ >>>> >>>> private static final long >>>> serialVersionUID = -7889264579632622427L; >>>> >>>> @Override >>>> public Tuple3<String, String, Integer> >>>> map(String line) throws Exception { >>>> String[] fields = line.split(" "); >>>> >>>> return new Tuple3<String, String, >>>> Integer>(fields[0], fields[1], Integer.parseInt(fields[2])); >>>> } >>>> >>>> }); >>>> >>>> // emit result >>>> if (fileOutput) { >>>> epcs.writeAsText(outputPath); >>>> } else { >>>> epcs.print(); >>>> } >>>> System.out.println(env.getExecutionPlan()); >>>> >>>> // execute program >>>> env.execute("DaoJoin"); >>>> } >>>> >>>> // >>>> ************************************************************************* >>>> // UTIL METHODS >>>> // >>>> ************************************************************************* >>>> >>>> private static boolean fileOutput = false; >>>> private static String textPath; >>>> private static String outputPath; >>>> >>>> private static boolean parseParameters(String[] args) { >>>> >>>> if (args.length > 0) { >>>> // parse input arguments >>>> fileOutput = true; >>>> if (args.length == 2) { >>>> textPath = args[0]; >>>> outputPath = args[1]; >>>> } else { >>>> System.err.println("Usage: >>>> DaoJoin <text path> <result path>"); >>>> return false; >>>> } >>>> System.out.println("fileout: " + fileOutput); >>>> } else { >>>> System.out.println("Executing WordCount >>>> example with built-in default data."); >>>> System.out.println(" Provide parameters >>>> to read input data from a file."); >>>> System.out.println(" Usage: WordCount >>>> <text path> <result path>"); >>>> } >>>> return true; >>>> } >>>> >>>> private static DataStream<String> >>>> getTextDataStream(StreamExecutionEnvironment env) { >>>> // read the text file from given input path >>>> return env.readTextFile(textPath); >>>> } >>>> } >>>> >>>> >>>> the pom.xml >>>> <project xmlns="http://maven.apache.org/POM/4.0.0" >>>> xmlns:xsi="http://xwww.w3.org/2001/XMLSchema-instance" >>>> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 >>>> http://maven.apache.org/xsd/maven-4.0.0.xsd"> >>>> <modelVersion>4.0.0</modelVersion> >>>> >>>> <groupId>com.otter.ist.flink</groupId> >>>> <artifactId>flink-test</artifactId> >>>> <version>0.1</version> >>>> <packaging>jar</packaging> >>>> >>>> <name>DaoJoin</name> >>>> <url>http://www.otter.com <http://www.otter.com/></url> >>>> >>>> <properties> >>>> >>>> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> >>>> </properties> >>>> >>>> <repositories> >>>> <repository> >>>> <id>apache.snapshots</id> >>>> <name>Apache Development Snapshot >>>> Repository</name> >>>> >>>> <url>https://repository.apache.org/content/repositories/snapshots/</url> >>>> <releases> >>>> <enabled>false</enabled> >>>> </releases> >>>> <snapshots> >>>> <enabled>true</enabled> >>>> </snapshots> >>>> </repository> >>>> </repositories> >>>> >>>> <!-- >>>> >>>> Execute "mvn clean package -Pbuild-jar" >>>> to build a jar file out of this project! >>>> >>>> How to use the Flink Quickstart pom: >>>> >>>> a) Adding new dependencies: >>>> You can add dependencies to the list below. >>>> Please check if the maven-shade-plugin >>>> below is filtering out your dependency >>>> and remove the exclude from there. >>>> >>>> b) Build a jar for running on the cluster: >>>> There are two options for creating a jar >>>> from this project >>>> >>>> b.1) "mvn clean package" -> this will >>>> create a fat jar which contains all >>>> dependencies necessary >>>> for running the jar created by this pom in a cluster. >>>> The "maven-shade-plugin" >>>> excludes everything that is provided on a running Flink cluster. >>>> >>>> b.2) "mvn clean package -Pbuild-jar" -> >>>> This will also create a fat-jar, but with much >>>> nicer dependency >>>> exclusion handling. This approach is preferred and leads to >>>> much cleaner jar files. >>>> --> >>>> >>>> <dependencies> >>>> <dependency> >>>> <groupId>org.apache.flink</groupId> >>>> <artifactId>flink-java</artifactId> >>>> <version>0.10-SNAPSHOT</version> >>>> </dependency> >>>> <dependency> >>>> <groupId>org.apache.flink</groupId> >>>> <artifactId>flink-streaming-core</artifactId> >>>> <version>0.10-SNAPSHOT</version> >>>> </dependency> >>>> <dependency> >>>> <groupId>org.apache.flink</groupId> >>>> <artifactId>flink-clients</artifactId> >>>> <version>0.10-SNAPSHOT</version> >>>> </dependency> >>>> </dependencies> >>>> >>>> <build> >>>> <plugins> >>>> <!-- We use the maven-shade plugin to >>>> create a fat jar that contains all dependencies >>>> except flink and it's transitive >>>> dependencies. The resulting fat-jar can be executed >>>> on a cluster. Change the value of >>>> Program-Class if your program entry point changes. --> >>>> <plugin> >>>> >>>> <groupId>org.apache.maven.plugins</groupId> >>>> >>>> <artifactId>maven-shade-plugin</artifactId> >>>> <version>2.3</version> >>>> <executions> >>>> <!-- Run shade goal on >>>> package phase --> >>>> <execution> >>>> >>>> <phase>package</phase> >>>> <goals> >>>> >>>> <goal>shade</goal> >>>> </goals> >>>> <configuration> >>>> <artifactSet> >>>> >>>> <excludes> >>>> >>>> <!-- This list contains all dependencies of flink-dist >>>> >>>> Everything else will be packaged into the fat-jar >>>> >>>> --> >>>> >>>> <exclude>org.apache.flink:flink-shaded-*</exclude> >>>> >>>> <exclude>org.apache.flink:flink-core</exclude> >>>> >>>> <exclude>org.apache.flink:flink-java</exclude> >>>> >>>> <exclude>org.apache.flink:flink-scala</exclude> >>>> >>>> <exclude>org.apache.flink:flink-runtime</exclude> >>>> >>>> <exclude>org.apache.flink:flink-optimizer</exclude> >>>> >>>> <exclude>org.apache.flink:flink-clients</exclude> >>>> >>>> <exclude>org.apache.flink:flink-spargel</exclude> >>>> >>>> <exclude>org.apache.flink:flink-avro</exclude> >>>> >>>> <exclude>org.apache.flink:flink-java-examples</exclude> >>>> >>>> <exclude>org.apache.flink:flink-scala-examples</exclude> >>>> >>>> <exclude>org.apache.flink:flink-streaming-examples</exclude> >>>> >>>> <exclude>org.apache.flink:flink-streaming-core</exclude> >>>> >>>> >>>> <!-- Also exclude very big transitive dependencies of Flink >>>> >>>> >>>> WARNING: You have to remove these excludes if your code >>>> relies on other >>>> >>>> versions of these dependencies. >>>> >>>> >>>> --> >>>> >>>> <exclude>org.scala-lang:scala-library</exclude> >>>> >>>> <exclude>org.scala-lang:scala-compiler</exclude> >>>> >>>> <exclude>org.scala-lang:scala-reflect</exclude> >>>> >>>> <exclude>com.amazonaws:aws-java-sdk</exclude> >>>> >>>> <exclude>com.typesafe.akka:akka-actor_*</exclude> >>>> >>>> <exclude>com.typesafe.akka:akka-remote_*</exclude> >>>> >>>> <exclude>com.typesafe.akka:akka-slf4j_*</exclude> >>>> >>>> <exclude>io.netty:netty-all</exclude> >>>> >>>> <exclude>io.netty:netty</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-server</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-continuation</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-http</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-io</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-util</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-security</exclude> >>>> >>>> <exclude>org.eclipse.jetty:jetty-servlet</exclude> >>>> >>>> <exclude>commons-fileupload:commons-fileupload</exclude> >>>> >>>> <exclude>org.apache.avro:avro</exclude> >>>> >>>> <exclude>commons-collections:commons-collections</exclude> >>>> >>>> <exclude>org.codehaus.jackson:jackson-core-asl</exclude> >>>> >>>> <exclude>org.codehaus.jackson:jackson-mapper-asl</exclude> >>>> >>>> <exclude>com.thoughtworks.paranamer:paranamer</exclude> >>>> >>>> <exclude>org.xerial.snappy:snappy-java</exclude> >>>> >>>> <exclude>org.apache.commons:commons-compress</exclude> >>>> >>>> <exclude>org.tukaani:xz</exclude> >>>> >>>> <exclude>com.esotericsoftware.kryo:kryo</exclude> >>>> >>>> <exclude>com.esotericsoftware.minlog:minlog</exclude> >>>> >>>> <exclude>org.objenesis:objenesis</exclude> >>>> >>>> <exclude>com.twitter:chill_*</exclude> >>>> >>>> <exclude>com.twitter:chill-java</exclude> >>>> >>>> <exclude>com.twitter:chill-avro_*</exclude> >>>> >>>> <exclude>com.twitter:chill-bijection_*</exclude> >>>> >>>> <exclude>com.twitter:bijection-core_*</exclude> >>>> >>>> <exclude>com.twitter:bijection-avro_*</exclude> >>>> >>>> <exclude>commons-lang:commons-lang</exclude> >>>> >>>> <exclude>junit:junit</exclude> >>>> >>>> <exclude>de.javakaffee:kryo-serializers</exclude> >>>> >>>> <exclude>joda-time:joda-time</exclude> >>>> >>>> <exclude>org.apache.commons:commons-lang3</exclude> >>>> >>>> <exclude>org.slf4j:slf4j-api</exclude> >>>> >>>> <exclude>org.slf4j:slf4j-log4j12</exclude> >>>> >>>> <exclude>log4j:log4j</exclude> >>>> >>>> <exclude>org.apache.commons:commons-math</exclude> >>>> >>>> >>>> <exclude>org.apache.sling:org.apache.sling.commons.json</exclude> >>>> >>>> <exclude>commons-logging:commons-logging</exclude> >>>> >>>> <exclude>org.apache.httpcomponents:httpclient</exclude> >>>> >>>> <exclude>org.apache.httpcomponents:httpcore</exclude> >>>> >>>> <exclude>commons-codec:commons-codec</exclude> >>>> >>>> <exclude>com.fasterxml.jackson.core:jackson-core</exclude> >>>> >>>> <exclude>com.fasterxml.jackson.core:jackson-databind</exclude> >>>> >>>> >>>> <exclude>com.fasterxml.jackson.core:jackson-annotations</exclude> >>>> >>>> <exclude>org.codehaus.jettison:jettison</exclude> >>>> >>>> <exclude>stax:stax-api</exclude> >>>> >>>> <exclude>com.typesafe:config</exclude> >>>> >>>> <exclude>org.uncommons.maths:uncommons-maths</exclude> >>>> >>>> <exclude>com.github.scopt:scopt_*</exclude> >>>> >>>> <exclude>org.mortbay.jetty:servlet-api</exclude> >>>> >>>> <exclude>commons-io:commons-io</exclude> >>>> >>>> <exclude>commons-cli:commons-cli</exclude> >>>> >>>> </excludes> >>>> >>>> </artifactSet> >>>> <filters> >>>> >>>> <filter> >>>> >>>> <artifact>org.apache.flink:*</artifact> >>>> >>>> <excludes> >>>> >>>> <exclude>org/apache/flink/shaded/**</exclude> >>>> >>>> <exclude>web-docs/**</exclude> >>>> >>>> </excludes> >>>> >>>> </filter> >>>> </filters> >>>> >>>> <transformers> >>>> >>>> <!-- add Main-Class to manifest file --> >>>> >>>> <transformer >>>> implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"> >>>> >>>> <mainClass>com.otter.ist.flink.DaoJoin</mainClass> >>>> >>>> </transformer> >>>> >>>> </transformers> >>>> >>>> <createDependencyReducedPom>false</createDependencyReducedPom> >>>> </configuration> >>>> </execution> >>>> </executions> >>>> </plugin> >>>> >>>> <!-- Configure the jar plugin to add the >>>> main class as a manifest entry --> >>>> <plugin> >>>> >>>> <groupId>org.apache.maven.plugins</groupId> >>>> >>>> <artifactId>maven-jar-plugin</artifactId> >>>> <version>2.5</version> >>>> <configuration> >>>> <archive> >>>> <manifestEntries> >>>> >>>> <Main-Class>com.otter.ist.flink.DaoJoin</Main-Class> >>>> </manifestEntries> >>>> </archive> >>>> </configuration> >>>> </plugin> >>>> >>>> <plugin> >>>> >>>> <groupId>org.apache.maven.plugins</groupId> >>>> >>>> <artifactId>maven-compiler-plugin</artifactId> >>>> <version>3.1</version> >>>> <configuration> >>>> <source>1.8</source> <!-- >>>> If you want to use Java 8, change this to "1.8" --> >>>> <target>1.8</target> <!-- >>>> If you want to use Java 8, change this to "1.8" --> >>>> </configuration> >>>> </plugin> >>>> </plugins> >>>> >>>> >>>> <!-- If you want to use Java 8 Lambda Expressions >>>> uncomment the following lines --> >>>> <!-- >>>> <pluginManagement> >>>> <plugins> >>>> <plugin> >>>> >>>> <artifactId>maven-compiler-plugin</artifactId> >>>> <configuration> >>>> <source>1.8</source> >>>> <target>1.8</target> >>>> >>>> <compilerId>jdt</compilerId> >>>> </configuration> >>>> <dependencies> >>>> <dependency> >>>> >>>> <groupId>org.eclipse.tycho</groupId> >>>> >>>> <artifactId>tycho-compiler-jdt</artifactId> >>>> >>>> <version>0.21.0</version> >>>> </dependency> >>>> </dependencies> >>>> </plugin> >>>> >>>> <plugin> >>>> >>>> <groupId>org.eclipse.m2e</groupId> >>>> >>>> <artifactId>lifecycle-mapping</artifactId> >>>> <version>1.0.0</version> >>>> <configuration> >>>> >>>> <lifecycleMappingMetadata> >>>> >>>> <pluginExecutions> >>>> >>>> <pluginExecution> >>>> >>>> <pluginExecutionFilter> >>>> >>>> <groupId>org.apache.maven.plugins</groupId> >>>> >>>> <artifactId>maven-assembly-plugin</artifactId> >>>> >>>> <versionRange>[2.4,)</versionRange> >>>> >>>> <goals> >>>> >>>> <goal>single</goal> >>>> >>>> </goals> >>>> >>>> </pluginExecutionFilter> >>>> >>>> <action> >>>> >>>> <ignore/> >>>> >>>> </action> >>>> >>>> </pluginExecution> >>>> >>>> <pluginExecution> >>>> >>>> <pluginExecutionFilter> >>>> >>>> <groupId>org.apache.maven.plugins</groupId> >>>> >>>> <artifactId>maven-compiler-plugin</artifactId> >>>> >>>> <versionRange>[3.1,)</versionRange> >>>> >>>> <goals> >>>> >>>> <goal>testCompile</goal> >>>> >>>> <goal>compile</goal> >>>> >>>> </goals> >>>> >>>> </pluginExecutionFilter> >>>> >>>> <action> >>>> >>>> <ignore/> >>>> >>>> </action> >>>> >>>> </pluginExecution> >>>> >>>> </pluginExecutions> >>>> >>>> </lifecycleMappingMetadata> >>>> </configuration> >>>> </plugin> >>>> </plugins> >>>> </pluginManagement> >>>> --> >>>> >>>> </build> >>>> <profiles> >>>> <profile> >>>> <!-- A profile that does everyting correctly: >>>> We set the Flink dependencies to provided --> >>>> <id>build-jar</id> >>>> <activation> >>>> >>>> <activeByDefault>false</activeByDefault> >>>> </activation> >>>> <dependencies> >>>> <dependency> >>>> >>>> <groupId>org.apache.flink</groupId> >>>> >>>> <artifactId>flink-java</artifactId> >>>> >>>> <version>0.10-SNAPSHOT</version> >>>> <scope>provided</scope> >>>> </dependency> >>>> <dependency> >>>> >>>> <groupId>org.apache.flink</groupId> >>>> >>>> <artifactId>flink-streaming-core</artifactId> >>>> >>>> <version>0.10-SNAPSHOT</version> >>>> <scope>provided</scope> >>>> </dependency> >>>> <dependency> >>>> >>>> <groupId>org.apache.flink</groupId> >>>> >>>> <artifactId>flink-clients</artifactId> >>>> >>>> <version>0.10-SNAPSHOT</version> >>>> <scope>provided</scope> >>>> </dependency> >>>> </dependencies> >>>> </profile> >>>> </profiles> >>>> </project> >>>> >>>> >>> >> > |
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
Re: java.lang.ClassNotFoundExcepti
|
|
| Free forum by Nabble | Edit this page |