Hi, I was probably too much of an early bird, removing the cache did solve that problem.
However this test program still does not end (cf. https://issues.apache.org/jira/browse/FLINK-10832 ) so I still can’t use that version… I wonder why I’m the only one with this problem ? I’ve tested it on two different computers… De : Till Rohrmann <trohrm...@apache.org> Envoyé : vendredi 30 novembre 2018 15:04 À : LINZ, Arnaud <al...@bouyguestelecom.fr> Cc : user <user@flink.apache.org> Objet : Re: Apache Flink 1.7.0 jar complete ? Hi Arnaud, I tried to setup the same testing project as you've described and it worked for me. Could you maybe try to clear your Maven repository? Maybe not all dependencies had been properly mirrored to Maven central. Cheers, Till On Fri, Nov 30, 2018 at 2:31 PM Till Rohrmann <trohrm...@apache.org<mailto:trohrm...@apache.org>> wrote: Thanks for reporting this problem Arnaud. I will investigate this problem. Cheers, Till On Fri, Nov 30, 2018 at 12:20 PM LINZ, Arnaud <al...@bouyguestelecom.fr<mailto:al...@bouyguestelecom.fr>> wrote: Hi, When trying to update to 1.7.0, a simple local cluster test fails with : 12:03:55.182 [main] DEBUG o.a.f.s.a.graph.StreamGraphGenerator - Transforming SinkTransformation{id=2, name='Print to Std. Out', outputType=GenericType<java.lang.Object>, parallelism=1} 12:03:55.182 [main] DEBUG o.a.f.s.a.graph.StreamGraphGenerator - Transforming SourceTransformation{id=1, name='Custom Source', outputType=String, parallelism=1} 12:03:55.182 [main] DEBUG o.a.f.s.api.graph.StreamGraph - Vertex: 1 12:03:55.182 [main] DEBUG o.a.f.s.api.graph.StreamGraph - Vertex: 2 Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/hash/Hashing at org.apache.flink.streaming.api.graph.StreamGraphHasherV2.traverseStreamGraphAndGenerateHashes(StreamGraphHasherV2.java:80) at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:145) at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:93) at org.apache.flink.streaming.api.graph.StreamGraph.getJobGraph(StreamGraph.java:669) at org.apache.flink.optimizer.plan.StreamingPlan.getJobGraph(StreamingPlan.java:40) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:92) at flink.flink_10832.App.testFlink10832(App.java:60) at flink.flink_10832.App.main(App.java:31) Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava18.com.google.common.hash.Hashing 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 sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 8 more Pom. is : <project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.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>flink</groupId> <artifactId>flink-10832</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>flink-10832</name> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <flink.version>1.7.0</flink.version> </properties> <dependencies> <!-- Flink --> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>1.0.13</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.5</version> </dependency> </dependencies> </project> Code is : public static void testFlink10832() throws Exception { // get the execution environment final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // get input data by connecting to the socket @SuppressWarnings("serial") final DataStreamSource<String> text = env.addSource(new SourceFunction<String>() { @Override public void run(final SourceContext<String> ctx) throws Exception { for (int count = 0; count < 5; count++) { ctx.collect(String.valueOf(count)); } } @Override public void cancel() { } }); text.print().setParallelism(1); env.execute("Simple Test"); System.out.println("If you see this the issue is resolved!"); } Any idea why ? Regards, Arnaud De : Till Rohrmann <trohrm...@apache.org<mailto:trohrm...@apache.org>> Envoyé : vendredi 30 novembre 2018 10:40 À : d...@flink.apache.org<mailto:d...@flink.apache.org>; user <user@flink.apache.org<mailto:user@flink.apache.org>>; annou...@apache.org<mailto:annou...@apache.org> Objet : [ANNOUNCE] Apache Flink 1.7.0 released The Apache Flink community is very happy to announce the release of Apache Flink 1.7.0, which is the next major release. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for download at: https://flink.apache.org/downloads.html Please check out the release blog post for an overview of the new features and improvements for this release: https://flink.apache.org/news/2018/11/30/release-1.7.0.html The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585 We would like to thank all contributors of the Apache Flink community who made this release possible! Cheers, Till ________________________________ L'intégrité de ce message n'étant pas assurée sur internet, la société expéditrice ne peut être tenue responsable de son contenu ni de ses pièces jointes. Toute utilisation ou diffusion non autorisée est interdite. Si vous n'êtes pas destinataire de ce message, merci de le détruire et d'avertir l'expéditeur. The integrity of this message cannot be guaranteed on the Internet. The company that sent this message cannot therefore be held liable for its content nor attachments. Any unauthorized use or dissemination is prohibited. If you are not the intended recipient of this message, then please delete it and notify the sender.
