You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by "Abhishek R. Singh" <ab...@tetrationanalytics.com> on 2016/12/10 00:30:29 UTC
checkpoint notifier not found?
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>
Re: checkpoint notifier not found?
Posted by "Abhishek R. Singh" <ab...@tetrationanalytics.com>.
Is this more appropriate for dev list? Anyway here is my first:
https://github.com/apache/flink/pull/3006 <https://github.com/apache/flink/pull/3006>
> On Dec 14, 2016, at 2:38 AM, Robert Metzger <rm...@apache.org> wrote:
>
> Hi Abhishek,
> you can not push to the Flink repository directly. Only Flink committers are allowed to do that.
> But you can fork the Flink repository on github to your own GitHub account and then push the changes to your Github.
> Then, you can create a pull request to offer those changes to the main Flink repository.
>
> On Wed, Dec 14, 2016 at 1:20 AM, Abhishek R. Singh <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
> Not sure how to go from here. How do I create a PR for this?
>
> $ git branch
> * doc-checkpoint-notify
> master
>
>
> $ git push origin master
> remote: Permission to apache/flink.git denied to abhishsi.
> fatal: unable to access 'https://github.com/apache/flink.git/': <https://github.com/apache/flink.git/':> The requested URL returned error: 403
>
>
> $ git diff HEAD^1
> diff --git a/docs/dev/state.md <http://state.md/> b/docs/dev/state.md <http://state.md/>
> index 37de0a8..a753ed1 100644
> --- a/docs/dev/state.md <http://state.md/>
> +++ b/docs/dev/state.md <http://state.md/>
> @@ -281,7 +281,7 @@ public static class CounterSource
> }
> {% endhighlight %}
>
> -Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `flink.streaming.api.checkpoint.CheckpointNotifier` interface.
> +Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `org.apache.flink.runtime.state.CheckpointListener` interface.
>
> ## State Checkpoints in Iterative Jobs
>
>
>
>> On Dec 12, 2016, at 3:11 PM, Abhishek R. Singh <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
>>
>> https://issues.apache.org/jira/browse/FLINK-5323 <https://issues.apache.org/jira/browse/FLINK-5323>
>>
>>> On Dec 12, 2016, at 5:37 AM, Till Rohrmann <trohrmann@apache.org <ma...@apache.org>> wrote:
>>>
>>> Hi Abhishek,
>>>
>>> great to hear that you like to become part of the Flink community. Here are some information for how to contribute [1].
>>>
>>> [1] http://flink.apache.org/how-to-contribute.html <http://flink.apache.org/how-to-contribute.html>
>>>
>>> Cheers,
>>> Till
>>>
>>> On Mon, Dec 12, 2016 at 12:36 PM, Abhishek Singh <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
>>> 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 <sewen@apache.org <ma...@apache.org>> 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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
>>> I was following the official documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/state.html <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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> 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>
>>>
>>>
>>>
>>
>
>
Re: checkpoint notifier not found?
Posted by Robert Metzger <rm...@apache.org>.
Hi Abhishek,
you can not push to the Flink repository directly. Only Flink committers
are allowed to do that.
But you can fork the Flink repository on github to your own GitHub account
and then push the changes to your Github.
Then, you can create a pull request to offer those changes to the main
Flink repository.
On Wed, Dec 14, 2016 at 1:20 AM, Abhishek R. Singh <
abhishsi@tetrationanalytics.com> wrote:
> Not sure how to go from here. How do I create a PR for this?
>
> $ git branch
> * doc-checkpoint-notify
> master
>
>
> $ git push origin master
> remote: Permission to apache/flink.git denied to abhishsi.
> fatal: unable to access 'https://github.com/apache/flink.git/': The
> requested URL returned error: 403
>
>
> $ git diff HEAD^1
> *diff --git a/docs/dev/state.md <http://state.md> b/docs/dev/state.md
> <http://state.md>*
> *index 37de0a8..a753ed1 100644*
> *--- a/docs/dev/state.md <http://state.md>*
> *+++ b/docs/dev/state.md <http://state.md>*
> @@ -281,7 +281,7 @@ public static class CounterSource
> }
> {% endhighlight %}
>
>
> -Some operators might need the information when a checkpoint is fully
> acknowledged by Flink to communicate that with the outside world. In this
> case see the `flink.streaming.api.checkpoint.CheckpointNotifier`
> interface.
> +Some operators might need the information when a checkpoint is fully
> acknowledged by Flink to communicate that with the outside world. In this
> case see the `org.apache.flink.runtime.state.CheckpointListener`
> interface.
>
>
> ## State Checkpoints in Iterative Jobs
>
>
>
>
> On Dec 12, 2016, at 3:11 PM, Abhishek R. Singh <
> abhishsi@tetrationanalytics.com> wrote:
>
> https://issues.apache.org/jira/browse/FLINK-5323
>
> On Dec 12, 2016, at 5:37 AM, Till Rohrmann <tr...@apache.org> wrote:
>
> Hi Abhishek,
>
> great to hear that you like to become part of the Flink community. Here
> are some information for how to contribute [1].
>
> [1] http://flink.apache.org/how-to-contribute.html
>
> Cheers,
> Till
>
> On Mon, Dec 12, 2016 at 12:36 PM, Abhishek Singh <
> abhishsi@tetrationanalytics.com> wrote:
>
>> 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 <se...@apache.org> 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 <
>>> abhishsi@tetrationanalytics.com> wrote:
>>>
>>> I was following the official documentation: https://ci.apac
>>> he.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 <
>>> abhishsi@tetrationanalytics.com> 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>
>>>
>>>
>>>
>>>
>
>
>
Re: checkpoint notifier not found?
Posted by "Abhishek R. Singh" <ab...@tetrationanalytics.com>.
Not sure how to go from here. How do I create a PR for this?
$ git branch
* doc-checkpoint-notify
master
$ git push origin master
remote: Permission to apache/flink.git denied to abhishsi.
fatal: unable to access 'https://github.com/apache/flink.git/': The requested URL returned error: 403
$ git diff HEAD^1
diff --git a/docs/dev/state.md b/docs/dev/state.md
index 37de0a8..a753ed1 100644
--- a/docs/dev/state.md
+++ b/docs/dev/state.md
@@ -281,7 +281,7 @@ public static class CounterSource
}
{% endhighlight %}
-Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `flink.streaming.api.checkpoint.CheckpointNotifier` interface.
+Some operators might need the information when a checkpoint is fully acknowledged by Flink to communicate that with the outside world. In this case see the `org.apache.flink.runtime.state.CheckpointListener` interface.
## State Checkpoints in Iterative Jobs
> On Dec 12, 2016, at 3:11 PM, Abhishek R. Singh <ab...@tetrationanalytics.com> wrote:
>
> https://issues.apache.org/jira/browse/FLINK-5323 <https://issues.apache.org/jira/browse/FLINK-5323>
>
>> On Dec 12, 2016, at 5:37 AM, Till Rohrmann <trohrmann@apache.org <ma...@apache.org>> wrote:
>>
>> Hi Abhishek,
>>
>> great to hear that you like to become part of the Flink community. Here are some information for how to contribute [1].
>>
>> [1] http://flink.apache.org/how-to-contribute.html <http://flink.apache.org/how-to-contribute.html>
>>
>> Cheers,
>> Till
>>
>> On Mon, Dec 12, 2016 at 12:36 PM, Abhishek Singh <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
>> 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 <sewen@apache.org <ma...@apache.org>> 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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
>> I was following the official documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/state.html <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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> 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>
>>
>>
>>
>
Re: checkpoint notifier not found?
Posted by "Abhishek R. Singh" <ab...@tetrationanalytics.com>.
https://issues.apache.org/jira/browse/FLINK-5323 <https://issues.apache.org/jira/browse/FLINK-5323>
> On Dec 12, 2016, at 5:37 AM, Till Rohrmann <tr...@apache.org> wrote:
>
> Hi Abhishek,
>
> great to hear that you like to become part of the Flink community. Here are some information for how to contribute [1].
>
> [1] http://flink.apache.org/how-to-contribute.html <http://flink.apache.org/how-to-contribute.html>
>
> Cheers,
> Till
>
> On Mon, Dec 12, 2016 at 12:36 PM, Abhishek Singh <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
> 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 <sewen@apache.org <ma...@apache.org>> 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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> wrote:
> I was following the official documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/state.html <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 <abhishsi@tetrationanalytics.com <ma...@tetrationanalytics.com>> 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>
>
>
>
Re: checkpoint notifier not found?
Posted by Till Rohrmann <tr...@apache.org>.
Hi Abhishek,
great to hear that you like to become part of the Flink community. Here are
some information for how to contribute [1].
[1] http://flink.apache.org/how-to-contribute.html
Cheers,
Till
On Mon, Dec 12, 2016 at 12:36 PM, Abhishek Singh <
abhishsi@tetrationanalytics.com> wrote:
> 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 <se...@apache.org> 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 <
>> abhishsi@tetrationanalytics.com> 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 <
>> abhishsi@tetrationanalytics.com> 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>
>>
>>
>>
>>
Re: checkpoint notifier not found?
Posted by Abhishek Singh <ab...@tetrationanalytics.com>.
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 <se...@apache.org> 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 <
> abhishsi@tetrationanalytics.com> 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 <
> abhishsi@tetrationanalytics.com> 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>
>
>
>
>
Re: checkpoint notifier not found?
Posted by Stephan Ewen <se...@apache.org>.
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 <
abhishsi@tetrationanalytics.com> 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 <
> abhishsi@tetrationanalytics.com> 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>
>
>
>
Re: checkpoint notifier not found?
Posted by "Abhishek R. Singh" <ab...@tetrationanalytics.com>.
I was following the official documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/state.html <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 <ab...@tetrationanalytics.com> 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>