Re: checkpoint notifier not found?

Posted by abhishekrs on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/checkpoint-notifier-not-found-tp10570p10576.html

Will be happy to. Could you guide me a bit in terms of what I need to do?

I am a newbie to open source contributing. And currently at Frankfurt airport. When I hit ground will be happy to contribute back. Love the project !!

Thanks for the awesomeness. 

On Mon, Dec 12, 2016 at 12:29 PM Stephan Ewen <[hidden email]> wrote:

Thanks for reporting this.

It would be awesome if you could file a JIRA or a pull request for fixing the docs for that.

On Sat, Dec 10, 2016 at 2:02 AM, Abhishek R. Singh <[hidden email]> wrote:

I was following the official documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/state.html

Looks like this is the right one to be using: import org.apache.flink.runtime.state.CheckpointListener;

-Abhishek-

On Dec 9, 2016, at 4:30 PM, Abhishek R. Singh <[hidden email]> wrote:

I can’t seem to find CheckpointNotifier. Appreciate help !

CheckpointNotifier is not a member of package org.apache.flink.streaming.api.checkpoint

From my pom.xml:

        <dependency>

                <groupId>org.apache.flink</groupId>

                <artifactId>flink-scala_2.11</artifactId>

                <version>1.1.3</version>

        </dependency>

        <dependency>

                <groupId>org.apache.flink</groupId>

                <artifactId>flink-streaming-scala_2.11</artifactId>

                <version>1.1.3</version>

        </dependency>

        <dependency>

                <groupId>org.apache.flink</groupId>

                <artifactId>flink-clients_2.11</artifactId>

                <version>1.1.3</version>

        </dependency>

        <dependency>

                <groupId>org.apache.flink</groupId>

                <artifactId>flink-statebackend-rocksdb_2.11</artifactId>

                <version>1.1.3</version>

        </dependency>