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 <[email protected]>
Envoyé : vendredi 30 novembre 2018 10:40
À : [email protected]; user <[email protected]>; [email protected]
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.
