(DEPRECATED) Apache Flink User Mailing List archive.

Apache Flink 1.7.0 jar complete ?

classic Classic list List threaded Threaded
♦
♦
 4 messages Options
LINZ, Arnaud
Reply | Threaded
Open this post in threaded view
♦
♦
|

Apache Flink 1.7.0 jar complete ?

LINZ, Arnaud

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

 

Please check out the release blog post for an overview of the new features and improvements for this release:

 

The full release notes are available in Jira:

 

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.
Till Rohrmann
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: Apache Flink 1.7.0 jar complete ?

Till Rohrmann
Thanks for reporting this problem Arnaud. I will investigate this problem.

Cheers,
Till

On Fri, Nov 30, 2018 at 12:20 PM LINZ, Arnaud <[hidden email]> 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 <[hidden email]>
Envoyé : vendredi 30 novembre 2018 10:40
À : [hidden email]; user <[hidden email]>; [hidden email]
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:

 

Please check out the release blog post for an overview of the new features and improvements for this release:

 

The full release notes are available in Jira:

 

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.
Till Rohrmann
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: Apache Flink 1.7.0 jar complete ?

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

 

Please check out the release blog post for an overview of the new features and improvements for this release:

 

The full release notes are available in Jira:

 

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.
LINZ, Arnaud
Reply | Threaded
Open this post in threaded view
♦
♦
|

RE: Apache Flink 1.7.0 jar complete ?

LINZ, Arnaud

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 <[hidden email]>
Envoyé : vendredi 30 novembre 2018 15:04
À : LINZ, Arnaud <[hidden email]>
Cc : user <[hidden email]>
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 <[hidden email]> 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 <[hidden email]> 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 <[hidden email]>
Envoyé : vendredi 30 novembre 2018 10:40
À : [hidden email]; user <[hidden email]>; [hidden email]
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:

 

Please check out the release blog post for an overview of the new features and improvements for this release:

 

The full release notes are available in Jira:

 

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.
Free forum by Nabble Edit this page