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> 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>
> 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.
>>
>
