flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Abhishek R. Singh" <abhis...@tetrationanalytics.com>
Subject Re: checkpoint notifier not found?
Date Wed, 14 Dec 2016 14:09:59 GMT
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 <rmetzger@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
<mailto: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/': <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
<mailto:abhishsi@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 <mailto:trohrmann@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
<mailto: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 <sewen@apache.org <mailto:sewen@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
<mailto: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
<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
<mailto: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>
>>> 
>>> 
>>> 
>> 
> 
> 


Mime
View raw message