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>
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
> <http://maven.apache.org/POM/4.0.0>"*
>
> xmlns:xsi=*"http://www.w3.org/2001/XMLSchema-instance
> <http://www.w3.org/2001/XMLSchema-instance>"*
>
> xsi:schemaLocation=*"http://maven.apache.org/POM/4.0.0
> <http://maven.apache.org/POM/4.0.0>
> http://maven.apache.org/xsd/maven-4.0.0.xsd
> <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>
> *Envoyé :* vendredi 30 novembre 2018 10:40
> *À :* d...@flink.apache.org; user <user@flink.apache.org>;
> 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.
>
