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 > <abhis...@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 <trohrm...@apache.org >> <mailto:trohrm...@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 >> <abhis...@tetrationanalytics.com <mailto:abhis...@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 >> <mailto: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 >> <abhis...@tetrationanalytics.com <mailto:abhis...@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 >>> <abhis...@tetrationanalytics.com <mailto:abhis...@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> >> >> >> >
