flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <mj...@informatik.hu-berlin.de>
Subject Re: java.lang.ClassNotFoundException when deploying streaming jar locally
Date Thu, 06 Aug 2015 11:51:20 GMT
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
> <m.huelfenhaus@davengo.com <mailto:m.huelfenhaus@davengo.com>>:
> 
>> 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 <rmetzger@apache.org
>> <mailto:rmetzger@apache.org>>:
>>
>>> 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
>>> <m.huelfenhaus@davengo.com <mailto:m.huelfenhaus@davengo.com>> 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>
>>>
>>>
>>
> 


Mime
View raw message